Skills carbium
Build on Solana with Carbium infrastructure — bare-metal RPC, Standard WebSocket pubsub, gRPC Full Block streaming (~22ms), DEX aggregation via CQ1 engine (sub-ms quotes), gasless swaps, and MEV-protected execution via Jito bundling. Drop-in replacement for Helius, QuickNode, Triton, or Jupiter Swap API.
git clone https://github.com/sendaifun/skills
T=$(mktemp -d) && git clone --depth=1 https://github.com/sendaifun/skills "$T" && mkdir -p ~/.claude/skills && cp -r "$T/skills/carbium" ~/.claude/skills/sendaifun-skills-carbium && rm -rf "$T"
skills/carbium/SKILL.mdCarbium — Full-Stack Solana Infrastructure
Carbium is bare-metal Solana infrastructure — Swiss-engineered, no cloud middlemen. One platform covering the full transaction lifecycle.
Overview
| Product | Endpoint | Purpose |
|---|---|---|
| RPC | | Standard JSON-RPC for reads, writes, subscriptions |
| Standard WebSocket | | Native Solana pubsub (account changes, slots, logs, signatures) |
| gRPC / Stream | | Yellowstone Full Block streaming (~22ms latency) |
| Swap API | | DEX aggregation and execution powered by CQ1 engine |
| DEX App | | Consumer-facing trading interface |
| Docs | | Full documentation |
Key differentiators:
- Sub-millisecond DEX quotes via CQ1 routing engine with binary-native state
- ~22ms Full Block gRPC — atomic, complete blocks (no shred reassembly)
- Gasless swaps — users trade without holding SOL
- MEV protection — Jito bundling built into Swap API
- Swiss bare-metal servers — sub-50ms RPC latency, 99.99% uptime
When to Use This Skill
| I want to... | Use | Key needed |
|---|---|---|
| Read account data / balances | RPC | RPC key |
| Send a transaction | RPC | RPC key |
| Monitor a wallet in real time | Standard WebSocket | RPC key |
| Confirm a transaction without polling | Standard WebSocket | RPC key |
| Watch program account changes | Standard WebSocket | RPC key |
| Build a wallet app | RPC + Swap API | Both |
| Get a token swap quote | Swap API | API key |
| Execute a swap programmatically | Swap API | API key |
| Execute a swap with Jito bundling | Swap API (bundle endpoint) | API key |
| Compare quotes across all DEX providers | Swap API (quote/all) | API key |
| Swap without users holding SOL | Swap API (gasless flag) | API key |
| Snipe pump.fun tokens (pre-graduation) | gRPC + direct bonding curve tx | RPC key (Business+) |
| React to on-chain events in real time | gRPC (streaming) | RPC key (Business+) |
| Index transactions for a program | gRPC (streaming) | RPC key (Business+) |
| Build an arbitrage / MEV bot | gRPC + Swap API | Both |
Quick Start
1. Get API Keys
| Product | Signup | Notes |
|---|---|---|
| RPC + gRPC + WebSocket | rpc.carbium.io/signup | One key covers RPC, WebSocket, and gRPC |
| Swap API | api.carbium.io/login | Separate key, free account, instant |
Programmatic key provisioning is not yet available. Keys must be created via the dashboards.
2. Set Environment Variables
export CARBIUM_RPC_KEY="your-rpc-key" export CARBIUM_API_KEY="your-swap-api-key"
3. Security Rules (Non-Negotiable)
- Never embed keys in frontend/client-side code
- Never commit keys to version control
- Use environment variables:
,CARBIUM_RPC_KEYCARBIUM_API_KEY - Rotate immediately if exposed
- Keep keys server-side only
Pricing Tiers
| Tier | Price | Credits/mo | Max RPS | gRPC | WebSocket |
|---|---|---|---|---|---|
| Free | $0 | 500K | 10 | No | Yes |
| Developer | $32/mo | 10M | 50 | No | Yes |
| Business | $320/mo | 100M | 200 | Yes | Yes |
| Professional | $640/mo | 200M | 500 | Yes | Yes |
gRPC streaming requires Business tier or above.
RPC
Standard Solana JSON-RPC. Any Solana SDK works:
@solana/web3.js, solana-py, solana Rust crate.
Endpoint:
https://rpc.carbium.io/?apiKey=YOUR_RPC_KEY
TypeScript
import { Connection, PublicKey, LAMPORTS_PER_SOL } from "@solana/web3.js"; const connection = new Connection( `https://rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}`, "confirmed" ); // Read balance const pubkey = new PublicKey("YOUR_WALLET_ADDRESS"); const balance = await connection.getBalance(pubkey); console.log(`Balance: ${balance / LAMPORTS_PER_SOL} SOL`); // Send transaction const sig = await connection.sendRawTransaction(transaction.serialize(), { skipPreflight: false, maxRetries: 3, }); await connection.confirmTransaction(sig, "confirmed");
Python
from solana.rpc.api import Client from solders.pubkey import Pubkey import os rpc = Client(f"https://rpc.carbium.io/?apiKey={os.environ['CARBIUM_RPC_KEY']}") pubkey = Pubkey.from_string("YOUR_WALLET_ADDRESS") resp = rpc.get_balance(pubkey) print(f"Balance: {resp.value / 1e9} SOL")
Rust
use solana_client::rpc_client::RpcClient; use solana_sdk::pubkey::Pubkey; use std::str::FromStr; let url = format!( "https://rpc.carbium.io/?apiKey={}", std::env::var("CARBIUM_RPC_KEY").unwrap() ); let client = RpcClient::new(url); let pubkey = Pubkey::from_str("YOUR_WALLET_ADDRESS").unwrap(); let balance = client.get_balance(&pubkey).unwrap(); println!("Balance: {} lamports", balance);
Commitment Levels
| Level | Speed | Guarantee | Use for |
|---|---|---|---|
| ~400ms | May roll back | Price feeds, low-stakes UX |
| ~2s | Supermajority voted | Default — best balance |
| ~32s | Fully finalized | Irreversible confirmations, high-value ops |
Standard WebSocket (Solana Pubsub)
Native Solana WebSocket pubsub — any SDK built for Solana WebSocket works with zero modifications.
Endpoint:
wss://wss-rpc.carbium.io/?apiKey=YOUR_RPC_KEY
Auth: same RPC key as query parameter. Available on all tiers (Developer and above recommended for production).
WSS vs gRPC — When to Use Which
| Standard WSS | gRPC / Yellowstone | |
|---|---|---|
| Protocol | JSON-RPC over WebSocket | Binary protobuf over WebSocket (or HTTP/2) |
| What you get | Account changes, slot updates, logs, signatures | Full atomic blocks, all transactions |
| SDK support | Any Solana SDK (, ) | Yellowstone client or raw WS with JSON filter |
| Latency | Sub-100ms subscription ack | ~22ms full block delivery |
| Tier required | Developer+ | Business+ |
| Best for | Wallets, dApps, monitoring specific accounts | MEV bots, indexers, full-block processing |
Rule of thumb: watching specific accounts or signatures → WSS. Processing all transactions or need full block data → gRPC.
Subscription Methods
| Method | What it streams | Typical use case |
|---|---|---|
| New slot numbers | Block clock, liveness checks |
| Finalized slots | Finality tracking |
| Account data changes | Wallet balance updates, PDA state changes |
| All accounts owned by a program | DEX pool state, staking updates |
| Transaction confirmation status | Confirm sent transactions in real time |
| Transaction logs matching filter | Program event monitoring |
| Full block data | Block explorers, indexers |
| Detailed slot lifecycle events | Advanced timing, validator monitoring |
| Vote transactions | Validator monitoring |
TypeScript — Watch a Wallet
import WebSocket from "ws"; const ws = new WebSocket( `wss://wss-rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}` ); ws.on("open", () => { ws.send(JSON.stringify({ jsonrpc: "2.0", id: 1, method: "accountSubscribe", params: [ "YOUR_WALLET_ADDRESS", { encoding: "base64", commitment: "confirmed" }, ], })); }); ws.on("message", (raw) => { const msg = JSON.parse(raw.toString()); if (msg.result !== undefined) { console.log(`Subscribed, id: ${msg.result}`); return; } if (msg.method === "accountNotification") { const { lamports } = msg.params.result.value; console.log(`Balance changed: ${lamports / 1e9} SOL`); } });
TypeScript — Confirm Transaction via WSS
ws.send(JSON.stringify({ jsonrpc: "2.0", id: 1, method: "signatureSubscribe", params: ["YOUR_TX_SIGNATURE", { commitment: "confirmed" }], })); // signatureSubscribe auto-unsubscribes after first notification
TypeScript — Stream Program Logs
ws.send(JSON.stringify({ jsonrpc: "2.0", id: 1, method: "logsSubscribe", params: [ { mentions: ["PROGRAM_ID"] }, { commitment: "confirmed" }, ], }));
Using @solana/web3.js (Recommended)
The
Connection class handles subscriptions natively:
import { Connection, PublicKey } from "@solana/web3.js"; const connection = new Connection( `https://rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}`, { commitment: "confirmed", wsEndpoint: `wss://wss-rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}`, } ); // Account subscription connection.onAccountChange( new PublicKey("YOUR_WALLET"), (info, ctx) => console.log(`Balance: ${info.lamports / 1e9} SOL at slot ${ctx.slot}`), "confirmed" ); // Slot subscription connection.onSlotChange((slotInfo) => { console.log(`Slot: ${slotInfo.slot}`); }); // Log subscription connection.onLogs( new PublicKey("PROGRAM_ID"), (logs, ctx) => { console.log(`Tx: ${logs.signature}`); logs.logs.forEach(log => console.log(" ", log)); }, "confirmed" );
Python — Watch Account
import asyncio, json, os import websockets WALLET = "YOUR_WALLET_ADDRESS" async def watch_account(): uri = f"wss://wss-rpc.carbium.io/?apiKey={os.environ['CARBIUM_RPC_KEY']}" async with websockets.connect(uri) as ws: await ws.send(json.dumps({ "jsonrpc": "2.0", "id": 1, "method": "accountSubscribe", "params": [WALLET, {"encoding": "base64", "commitment": "confirmed"}], })) ack = json.loads(await ws.recv()) print(f"Subscribed: {ack['result']}") async for raw in ws: msg = json.loads(raw) if msg.get("method") == "accountNotification": val = msg["params"]["result"]["value"] print(f"Balance: {val['lamports'] / 1e9} SOL") asyncio.run(watch_account())
Unsubscribe
Every subscription method has a matching unsubscribe. Use the subscription ID from the ack:
{"jsonrpc": "2.0", "id": 2, "method": "accountUnsubscribe", "params": [SUBSCRIPTION_ID]}
| Subscribe | Unsubscribe |
|---|---|
| |
| |
| |
| (auto after first notification) |
| |
| |
| |
For full notification shapes and advanced patterns, see
resources/websocket-reference.md.
gRPC / Full Block Streaming
Real-time Yellowstone-compatible Full Block stream. ~22ms latency. Atomic complete blocks — no shred reassembly needed.
Endpoints & Auth
| Method | Format | Use case |
|---|---|---|
| WebSocket query param | | Recommended for TS/Python |
| HTTP/2 header | | For Rust yellowstone-grpc-client |
Requires Business tier or above.
Available Methods
| Method | Description |
|---|---|
| Subscribe to real-time transactions with filters |
| Unsubscribe from transaction stream |
TypeScript — Subscribe to Program Transactions
import WebSocket from "ws"; const PROGRAM_ID = "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P"; const ws = new WebSocket( `wss://grpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}` ); ws.on("open", () => { ws.send(JSON.stringify({ jsonrpc: "2.0", id: 1, method: "transactionSubscribe", params: [ { vote: false, failed: false, accountInclude: [PROGRAM_ID], accountExclude: [], accountRequired: [], }, { commitment: "confirmed", encoding: "base64", transactionDetails: "full", showRewards: false, maxSupportedTransactionVersion: 0, }, ], })); }); ws.on("message", (raw) => { const msg = JSON.parse(raw.toString()); if (msg.result !== undefined) { console.log(`Subscribed, ID: ${msg.result}`); return; } if (msg.method === "transactionNotification") { const { signature, slot } = msg.params.result; console.log(`tx ${signature} in slot ${slot}`); } }); // Always reconnect on close — see Production Patterns ws.on("close", (code) => { console.warn(`Disconnected (${code}), reconnecting...`); });
Filter Fields
| Field | Type | Description |
|---|---|---|
| bool | Include vote transactions |
| bool | Include failed transactions |
| string[] | Include txs involving ANY of these accounts |
| string[] | Exclude txs involving these accounts |
| string[] | Only include txs involving ALL of these accounts |
At least one of
accountInclude or accountRequired must contain values.
Subscription Options
| Field | Type | Values |
|---|---|---|
| string | / / |
| string | / / |
| string | / / |
| bool | Include reward information |
| number | for legacy + v0 |
Python
import asyncio, json, os import websockets PROGRAM_ID = "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P" async def subscribe(): uri = f"wss://grpc.carbium.io/?apiKey={os.environ['CARBIUM_RPC_KEY']}" async with websockets.connect(uri) as ws: await ws.send(json.dumps({ "jsonrpc": "2.0", "id": 1, "method": "transactionSubscribe", "params": [ { "vote": False, "failed": False, "accountInclude": [PROGRAM_ID], "accountExclude": [], "accountRequired": [], }, { "commitment": "confirmed", "encoding": "base64", "transactionDetails": "full", "showRewards": False, "maxSupportedTransactionVersion": 0, }, ], })) async for message in ws: data = json.loads(message) if "result" in data: print(f"Subscribed: {data['result']}") elif data.get("method") == "transactionNotification": print(f"tx: {data['params']['result']['signature'][:20]}...") asyncio.run(subscribe())
Rust (HTTP/2 gRPC)
use yellowstone_grpc_client::GeyserGrpcClient; #[tokio::main] async fn main() -> Result<(), Box<dyn std::error::Error>> { let mut client = GeyserGrpcClient::connect( "https://grpc.carbium.io", "YOUR_RPC_KEY", // passed as x-token header automatically None, )?; let (_subscribe_tx, mut stream) = client.subscribe().await?; // Define subscription filters and consume stream Ok(()) }
Full Blocks vs Shreds
| Metric | Value | Context |
|---|---|---|
| Solana Slot Resolution | ~400ms | The window in which a block is produced |
| Competitor "Shreds" | ~9ms | Fragmented data requiring client-side reassembly |
| Carbium Full Blocks | ~22ms | Atomic, complete data ready for use |
The 13ms difference is negligible within a 400ms slot. Full Blocks provide atomic integrity, zero-logic ingestion, and parsing efficiency.
Unsubscribe
{"jsonrpc": "2.0", "id": 2, "method": "transactionUnsubscribe", "params": [SUBSCRIPTION_ID]}
For complete gRPC reference with response shapes, see
resources/grpc-reference.md.
Swap API
Aggregated DEX quotes and execution powered by the CQ1 engine — sub-millisecond quotes, ~10ms chain-to-queryable latency, binary-native state.
Base URL:
https://api.carbium.io
Auth: X-API-KEY: YOUR_API_KEY header on all requests
Get your key: api.carbium.io/login (free account)
API Versions
| Version | Surface | Status |
|---|---|---|
| v2 (Q1) | | Current — use this for new integrations |
| v1 (legacy) | , , , | Legacy — still operational |
Important: v2 and v1 use different parameter names. Do not mix them. v2 (Q1) uses
/src_mint/dst_mint/amount_in. v1 usesslippage_bps/fromMint/toMint/amount.slippage
v2 / Q1 — Quote + Executable Transaction (Recommended)
The Q1 engine returns both the quote and an executable transaction in a single call when
user_account is included. No separate swap endpoint needed.
GET /api/v2/quote
| Param | Required | Description |
|---|---|---|
| Yes | Input token mint address |
| Yes | Output token mint address |
| Yes | Input amount in smallest unit (lamports) |
| Yes | Slippage tolerance in basis points |
| No | Wallet address — if included, response includes executable field |
Quote only (no transaction):
const quote = await fetch( "https://api.carbium.io/api/v2/quote" + "?src_mint=So11111111111111111111111111111111111111112" + "&dst_mint=EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v" + "&amount_in=1000000000" + "&slippage_bps=100", { headers: { "X-API-KEY": process.env.CARBIUM_API_KEY! } } ).then(r => r.json()); // Returns: { srcAmountIn, destAmountOut, destAmountOutMin, priceImpactPct, routePlan }
Quote + executable transaction (include
):user_account
const quote = await fetch( "https://api.carbium.io/api/v2/quote" + "?src_mint=So11111111111111111111111111111111111111112" + "&dst_mint=EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v" + "&amount_in=1000000000" + "&slippage_bps=100" + "&user_account=YOUR_WALLET_ADDRESS", { headers: { "X-API-KEY": process.env.CARBIUM_API_KEY! } } ).then(r => r.json()); // Returns: { srcAmountIn, destAmountOut, destAmountOutMin, priceImpactPct, routePlan, txn } // txn is base64-encoded, ready for deserialization and signing
import httpx, os resp = httpx.get( "https://api.carbium.io/api/v2/quote", params={ "src_mint": "So11111111111111111111111111111111111111112", "dst_mint": "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v", "amount_in": 1_000_000_000, "slippage_bps": 100, "user_account": "YOUR_WALLET_ADDRESS", # include for executable txn }, headers={"X-API-KEY": os.environ["CARBIUM_API_KEY"]}, ) print(resp.json())
v1 Legacy Endpoints
These endpoints are still operational but use the older parameter family. Do not mix v1 params with v2 URLs.
| Endpoint | Method | Params | Description |
|---|---|---|---|
| GET | , , , , | Provider-specific quote |
| GET | , , , | Compare quotes across all providers |
| GET | , , , , , + optional flags | Get serialized swap transaction |
| GET | | Submit via Jito bundle (MEV protection) |
| GET | , , | Generate custom fee transfer transaction |
v1
/swap supports additional execution flags: gasless, mevSafe, priorityMicroLamports, feeLamports, feeReceiver, pool.
Full Swap Execute Flow (TypeScript) — v2/Q1
import { Connection, VersionedTransaction, Keypair } from "@solana/web3.js"; const connection = new Connection( `https://rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}`, "confirmed" ); // 1. Get quote with executable transaction (single call) const url = new URL("https://api.carbium.io/api/v2/quote"); url.searchParams.set("src_mint", "So11111111111111111111111111111111111111112"); url.searchParams.set("dst_mint", "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"); url.searchParams.set("amount_in", "100000000"); url.searchParams.set("slippage_bps", "100"); url.searchParams.set("user_account", "YOUR_WALLET_ADDRESS"); const quote = await fetch(url, { headers: { "X-API-KEY": process.env.CARBIUM_API_KEY! }, }).then(r => r.json()); if (!quote.txn) throw new Error("No executable transaction — check user_account param"); // 2. Deserialize and sign const tx = VersionedTransaction.deserialize(Buffer.from(quote.txn, "base64")); // tx.sign([yourKeypair]); // 3. Submit via RPC const sig = await connection.sendRawTransaction(tx.serialize(), { maxRetries: 3 }); // 4. Confirm await connection.confirmTransaction(sig, "confirmed"); console.log("Swap confirmed:", sig);
Supported DEX Providers
| Provider | ID |
|---|---|
| Raydium | |
| Raydium CPMM | |
| Orca | |
| Meteora | |
| Meteora DLMM | |
| Pump.fun | |
| Moonshot | |
| Stabble | |
| PrintDEX | |
| GooseFX | |
Slippage Recommendations
| Pair type | Recommended BPS | Percentage |
|---|---|---|
| Stablecoin swaps | 5-10 | 0.05-0.1% |
| Major pairs (SOL/USDC) | 10-50 | 0.1-0.5% |
| Volatile tokens | 50-100 | 0.5-1% |
| Arbitrage | 10 | 0.1% (tight) |
For complete OpenAPI parameter specifications, see
resources/swap-api-reference.md.
Gasless Swaps
Gasless swaps let users execute on-chain transactions without holding SOL to pay fees.
How It Works
- User initiates a swap
- Carbium advances the SOL fee from an internal fee pool
- Transaction settles on-chain normally
- A micro-adjustment on the swap output rebalances the fee pool
Constraint
Gasless swaps require the output token to be SOL. Currently available on the v1 swap endpoint.
When to Use
- First-time users who received tokens but no SOL
- Embedded wallet experiences with low-friction onboarding
- Swap-first UX where gas funding hurts conversion
Integration
Add
gasless=true to a v1 swap request:
const res = await fetch( "https://api.carbium.io/api/v1/swap" + "?owner=WALLET&fromMint=USDC_MINT&toMint=SOL_MINT" + "&amount=1000000&slippage=100&provider=raydium&gasless=true", { headers: { "X-API-KEY": process.env.CARBIUM_API_KEY! } } );
Pump.fun Pre-Graduation Token Sniping
Carbium Swap API cannot route pump.fun tokens before graduation (returns 0 routes). Use: gRPC to detect launches → build raw bonding curve transactions → submit via RPC.
Requires Business tier RPC key (gRPC access).
Key Constants
const PUMP_PROGRAM = "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P"; const PUMP_GLOBAL = "4wTV1YmiEkRvAtNtsSGPtUrqRYQMe5SKy2uB4Jjaxnjf"; const PUMP_FEE_RECIPIENT = "CebN5WGQ4jvEPvsVU4EoHEpgzq1VV7AbicfhtW4xC9iM"; const PUMP_EVENT_AUTH = "Ce6TQqeHC9p8KetsN6JsjHK7UTZk7nasjjnr7XxXp9F1"; const GRADUATION_SOL = 85_000_000_000n; // 85 SOL in lamports const TOTAL_SUPPLY = 1_000_000_000_000_000n; // 1 quadrillion (6 decimals) const DISCRIMINATORS = { create: [0xe4, 0x45, 0xa5, 0x2e, 0x51, 0xcb, 0x9a, 0x1d], buy: [0x66, 0x06, 0x3d, 0x12, 0x01, 0xda, 0xeb, 0xea], sell: [0x33, 0xe6, 0x85, 0xa4, 0x01, 0x7f, 0x83, 0xad], };
Step 1 — Subscribe to Launches via gRPC
import WebSocket from "ws"; const ws = new WebSocket( `wss://grpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}` ); ws.on("open", () => { ws.send(JSON.stringify({ jsonrpc: "2.0", id: 1, method: "transactionSubscribe", params: [ { vote: false, failed: false, accountInclude: [PUMP_PROGRAM] }, { commitment: "confirmed", encoding: "jsonParsed", transactionDetails: "full", showRewards: false, maxSupportedTransactionVersion: 0 }, ], })); }); setInterval(() => ws.ping(), 30_000); // keepalive ws.on("message", (raw) => { const msg = JSON.parse(raw.toString()); if (msg.method !== "transactionNotification") return; const { signature, transaction } = msg.params.result; const logs = transaction.meta.logMessages || []; for (const log of logs) { if (log.includes("Instruction: Create")) { const mint = transaction.meta.postTokenBalances[0]?.mint; if (mint) handleNewToken(mint, signature); } } });
Step 2 — Derive Bonding Curve PDA
import { PublicKey } from "@solana/web3.js"; function deriveBondingCurve(mint: string): PublicKey { const [address] = PublicKey.findProgramAddressSync( [Buffer.from("bonding-curve"), new PublicKey(mint).toBuffer()], new PublicKey(PUMP_PROGRAM) ); return address; }
Step 3 — Fetch & Parse Bonding Curve State
// Bonding curve layout (81 bytes): // [0-7] discriminator // [8-15] virtualTokenReserves (u64 LE) // [16-23] virtualSolReserves (u64 LE) // [24-31] realTokenReserves (u64 LE) // [32-39] realSolReserves (u64 LE) // [40-47] tokenTotalSupply (u64 LE) // [72] complete (bool) async function fetchBondingCurve(address: PublicKey) { const res = await fetch(`https://rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}`, { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify({ jsonrpc: "2.0", id: 1, method: "getAccountInfo", params: [address.toBase58(), { encoding: "base64" }], }), }); const { result } = await res.json(); const data = Buffer.from(result.value.data[0], "base64"); return { virtualTokenReserves: data.readBigUInt64LE(8), virtualSolReserves: data.readBigUInt64LE(16), realTokenReserves: data.readBigUInt64LE(24), realSolReserves: data.readBigUInt64LE(32), complete: data.readUInt8(72) === 1, }; }
Step 4 — Quote (Constant Product AMM)
function quoteBuy(curve: any, solLamports: number): bigint { const num = curve.virtualTokenReserves * BigInt(solLamports); const den = curve.virtualSolReserves + BigInt(solLamports); return num / den; } function quoteSell(curve: any, tokens: bigint): bigint { const num = curve.virtualSolReserves * tokens; const den = curve.virtualTokenReserves + tokens; return num / den; }
Step 5 — Build & Submit Buy Transaction
Buy instruction accounts (order matters, 13 total):
| # | Account | Access |
|---|---|---|
| 0 | PUMP_GLOBAL | read |
| 1 | PUMP_FEE_RECIPIENT | write |
| 2 | mint | read |
| 3 | bondingCurve | write |
| 4 | bondingCurve ATA | write |
| 5 | user ATA | write |
| 6 | user/payer | write, signer |
| 7 | SystemProgram | - |
| 8 | TokenProgram | - |
| 9 | AssociatedTokenProgram | - |
| 10 | Rent sysvar | - |
| 11 | PUMP_EVENT_AUTH | read |
| 12 | PUMP_PROGRAM | read |
Submit with
skipPreflight: true to save ~200ms:
const sig = await connection.sendRawTransaction(signedTx.serialize(), { skipPreflight: true, preflightCommitment: "confirmed", maxRetries: 3, });
Sniping Flow Summary
gRPC "Create" event → extract mint → deriveBondingCurve(mint) → [optional] fetchBondingCurve() for price check → build buy instruction with desired SOL → sendTransaction(skipPreflight: true) → monitor bonding curve state for exit → sell when target % reached or graduation imminent (85 SOL)
Pump.fun Error Handling
| Error | Cause | Fix |
|---|---|---|
| Blockhash expired | Tx took too long | Fresher blockhash; reduce latency |
| Insufficient funds | Not enough SOL | Balance must cover amount + fees (~0.005 SOL) |
| Account not found | Token just created | Retry with small delay (50-100ms) |
| Slippage exceeded | Price moved | Increase or reduce size |
For the full sniping example, see
examples/pump-snipe/example.ts.
Migration
From Other RPC Providers (Helius, QuickNode, Triton, Alchemy)
Simple URL swap — all use standard JSON-RPC:
// Before const connection = new Connection("https://mainnet.helius-rpc.com/?api-key=..."); // After const connection = new Connection( `https://rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}` );
From Jupiter Swap API
Parameter mapping (v2/Q1):
| Jupiter | Carbium v2/Q1 () |
|---|---|
| |
| |
| |
| |
Key difference: Carbium Q1 returns the executable transaction in the quote response when
user_account is included. No separate swap call needed.
From Triton gRPC
Same Yellowstone protocol. Update endpoint only:
wss://grpc.carbium.io/?apiKey=YOUR_RPC_KEY
For detailed migration guides, see
docs/migration.md.
Production Patterns
Retry with Exponential Backoff
const delay = (ms: number) => new Promise(r => setTimeout(r, ms)); async function withRetry<T>(fn: () => Promise<T>, retries = 3, baseMs = 300): Promise<T> { for (let i = 0; i < retries; i++) { try { return await fn(); } catch (e) { if (i === retries - 1) throw e; await delay(baseMs * 2 ** i + Math.random() * 100); } } throw new Error("unreachable"); }
Do NOT blindly retry
— checksendTransactionfirst to confirm the tx did not already land.getSignatureStatus
WebSocket / gRPC Reconnect
async function connectWithReconnect(connectFn: () => Promise<void>) { let backoff = 1000; while (true) { try { await connectFn(); backoff = 1000; // reset on success } catch { await delay(backoff); backoff = Math.min(backoff * 2, 30_000); // cap at 30s } } }
Send ping every 30 seconds to prevent silent disconnects.
Timeout Recommendations
| Operation | Timeout |
|---|---|
| RPC read calls | 5-10s |
| Swap quote | 3-5s |
| Transaction confirmation | 30-60s (with polling) |
Failure Handling
| Failure | Action |
|---|---|
| Quote: no route found | Retry with wider slippage or different provider |
| Simulation failed | Do NOT send — inspect error, log, alert |
| sendTransaction failed | Check before retry |
| Transaction not confirmed | Poll with timeout; check blockhash expiry |
| Stream disconnected | Reconnect with exponential backoff |
| HTTP 429 rate limit | Back off immediately; treat as architecture signal |
Error Reference
HTTP Status Codes
| Code | Meaning | Action |
|---|---|---|
| 401 | Invalid / missing API key | Check key and auth format |
| 403 | Plan restriction (e.g. gRPC on free tier) | Upgrade at rpc.carbium.io |
| 429 | Rate limit exceeded | Back off + retry; review architecture |
| 400 | No route found / bad params | Check mint addresses, slippage, required params |
| 500 | Server error | Retry after 1s |
| 503 | Temporary unavailability | Retry with exponential backoff |
WebSocket Error Codes
| Code | Message | Cause |
|---|---|---|
| Parse error | Malformed JSON or missing required params |
| Method not found | Method name typo or unsupported method |
| Invalid params | Wrong param types or missing fields |
| Internal error | Server-side error — retry |
Common Token Mints
| Token | Mint Address |
|---|---|
| SOL (wrapped) | |
| USDC | |
| USDT | |
Best Practices
Security
- Keep API keys server-side only — never in frontend bundles or mobile clients
- Use environment variables (
,CARBIUM_RPC_KEY
)CARBIUM_API_KEY - Rotate keys immediately if exposed
- Restrict endpoints by domain/IP in the RPC dashboard where practical
Rate Limiting
- HTTP 429 is an architecture signal, not just a retry cue
- Separate dev/staging/prod keys
- Isolate retry paths from decision logic
- Do NOT retry
before checkingsendTransactiongetSignatureStatus
Transaction Submission
- Use
only after validating the quote — saves ~200msskipPreflight: true - Use
(V0) for Address Lookup Table (ALT) supportVersionedTransaction - Prefer HTTP polling for confirmations over WebSocket (more reliable)
- Keep blockhashes fresh — they expire after ~60 seconds
Commitment Levels
- Default to
for most operationsconfirmed - Use
only for price feeds or low-stakes readsprocessed - Use
for irreversible confirmations and high-value operationsfinalized
Skill Structure
skills/carbium/ ├── SKILL.md # This file ├── resources/ │ ├── endpoints-and-auth.md # All endpoints, auth patterns, pricing │ ├── swap-api-reference.md # Full Swap API parameter specs │ ├── grpc-reference.md # gRPC filter fields, response shapes │ └── websocket-reference.md # All WSS subscription methods and shapes ├── examples/ │ ├── rpc-basic/README.md # Balance check + send transaction │ ├── swap-quote/README.md # Quote → swap → sign → submit │ ├── swap-bundle/README.md # MEV-protected Jito bundle │ ├── grpc-stream/README.md # Program transaction subscription │ ├── websocket-monitor/README.md # Account + slot monitoring via WSS │ ├── pump-snipe/README.md # Full pump.fun sniping flow │ └── gasless-swap/README.md # Gasless swap execution ├── templates/ │ └── carbium-setup.ts # Connection setup + retry helper └── docs/ ├── troubleshooting.md # Error codes, 429 handling ├── migration.md # From Helius, QuickNode, Jupiter └── trading-bots.md # Bot architecture patterns
References
| Resource | URL |
|---|---|
| Ecosystem Overview | docs.carbium.io/docs/the-carbium-ecosystem |
| RPC Quick Start | docs.carbium.io/docs/quick-start-rpc |
| Swap API Quick Start | docs.carbium.io/docs/quick-start-dex-api |
| gRPC / Streaming | docs.carbium.io/docs/solana-grpc |
| CQ1 Engine | docs.carbium.io/docs/cq1-engine-overview |
| RPC Pricing | docs.carbium.io/docs/carbium-rpc-pricing |
| API Recipes | docs.carbium.io/recipes |
| FAQ | docs.carbium.io/docs/faq |
| Full AI Context | carbium.io/llms-ctx.txt |
| RPC Signup | rpc.carbium.io/signup |
| Swap API Signup | api.carbium.io/login |
| Discord | discord.gg/jW7BUkQS5U |
| Twitter/X | x.com/carbium |