Migrating to Carbium

import { Connection } from "@solana/web3.js";

// 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}`,
  "confirmed"
);

from solana.rpc.api import Client
import os

# Before
rpc = Client("https://solana-mainnet.quiknode.pro/YOUR_KEY/")

# After
rpc = Client(f"https://rpc.carbium.io/?apiKey={os.environ['CARBIUM_RPC_KEY']}")

import requests

RPC = "https://rpc.carbium.io"
headers = {"X-API-KEY": "YOUR_CARBIUM_RPC_KEY"}
payload = {"jsonrpc": "2.0", "id": 1, "method": "getBalance", "params": ["PUBKEY"]}
r = requests.post(RPC, json=payload, headers=headers, timeout=10)

use solana_client::rpc_client::RpcClient;

// Before
let client = RpcClient::new("https://mainnet.helius-rpc.com/?api-key=YOUR_KEY");

// After
let url = format!(
    "https://rpc.carbium.io/?apiKey={}",
    std::env::var("CARBIUM_RPC_KEY").unwrap()
);
let client = RpcClient::new(url);

# .env
CARBIUM_RPC_KEY=your_rpc_key_here   # covers RPC + gRPC
CARBIUM_API_KEY=your_api_key_here   # Swap API (separate key)

// Before
const connection = new Connection("https://mainnet.helius-rpc.com/?api-key=abc123");

// After
const connection = new Connection(
  `https://rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}`
);

// Before
const connection = new Connection("https://solana-mainnet.quiknode.pro/YOUR_TOKEN/");

// After
const connection = new Connection(
  `https://rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}`
);

// Before
const connection = new Connection("https://YOUR_ENDPOINT.mainnet.rpcpool.com/");

// After
const connection = new Connection(
  `https://rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}`
);

// Before (Triton gRPC)
// wss://your-endpoint.mainnet.rpcpool.com/

// After (Carbium gRPC — same Yellowstone format)
const ws = new WebSocket(
  `wss://grpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}`
);
// Your existing transactionSubscribe / accountSubscribe logic works as-is

const API_KEY = process.env.CARBIUM_API_KEY;

// Quote
const quote = await fetch(
  "https://api.carbium.io/api/v2/quote?" +
  "src_mint=So11111111111111111111111111111111111111112" +
  "&dst_mint=EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v" +
  "&amount_in=1000000000" +
  "&slippage_bps=50",
  { headers: { "X-API-KEY": API_KEY } }
).then(r => r.json());

// Swap (returns base64 serialized transaction)
const { transaction } = await fetch(
  "https://api.carbium.io/api/v2/swap?" +
  "fromMint=So11111111111111111111111111111111111111112" +
  "&toMint=EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v" +
  "&amount=1000000000&slippage=50",
  { headers: { "X-API-KEY": API_KEY } }
).then(r => r.json());

// Sign and send via RPC
import { Connection, VersionedTransaction } from "@solana/web3.js";
const connection = new Connection(`https://rpc.carbium.io/?apiKey=${process.env.CARBIUM_RPC_KEY}`);
const tx = VersionedTransaction.deserialize(Buffer.from(transaction, "base64"));
// tx.sign([yourKeypair]);
const sig = await connection.sendRawTransaction(tx.serialize(), { maxRetries: 3 });

// Standard swap
const swap = await fetch("https://api.carbium.io/api/v2/swap?...", { headers: { "X-API-KEY": API_KEY } });

// Jito-bundled swap — same params, different endpoint
const bundled = await fetch("https://api.carbium.io/api/v2/swap/bundle?...", { headers: { "X-API-KEY": API_KEY } });

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: ["YOUR_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.method === "transactionNotification") {
    const { signature, slot } = msg.params.result;
    console.log(`tx ${signature} in slot ${slot}`);
  }
});

// Always reconnect with exponential backoff
ws.on("close", (code) => {
  console.warn(`Disconnected (${code}), reconnecting...`);
  // implement exponential backoff here
});

// Keepalive — required every 30s
setInterval(() => ws.ping(), 30_000);

use yellowstone_grpc_client::GeyserGrpcClient;

let mut client = GeyserGrpcClient::connect(
    "https://grpc.carbium.io",
    Some("YOUR_RPC_KEY"), // passed as x-token header
    None
).await?;