Build a Solana Arbitrage Quote Engine

{
  "inAmount": "1000000000",
  "outAmount": "1005000000",
  "priceImpact": 0.01,
  "routePlan": [
    {
      "swap": "Raydium",
      "percent": 100
    }
  ]
}

import fetch from 'node-fetch';
import dotenv from 'dotenv';

dotenv.config();

const API_KEY = process.env.CARBIUM_API_KEY;

// Token Mints
const SOL_MINT = 'So11111111111111111111111111111111111111112';
const USDC_MINT = 'EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v';

/**
 * Check for arbitrage opportunity
 * Route: SOL -> USDC -> SOL
 */
async function checkArbitrage(amountIn) {
  try {
    console.log(`Checking arb for ${amountIn} lamports...`);

    // Leg 1: SOL -> USDC
    const leg1 = await getQuote(SOL_MINT, USDC_MINT, amountIn);
    if (!leg1) return;
    const usdcAmount = leg1.outAmount;

    // Leg 2: USDC -> SOL
    const leg2 = await getQuote(USDC_MINT, SOL_MINT, usdcAmount);
    if (!leg2) return;
    const finalSolAmount = leg2.outAmount;

    // Calculate Profit
    const profit = finalSolAmount - amountIn;
    const isProfitable = profit > 0;

    console.log(`
    --- ARBITRAGE CHECK ---
    Input:  ${amountIn / 1e9} SOL
    Output: ${finalSolAmount / 1e9} SOL
    Profit: ${profit / 1e9} SOL
    Profitable: ${isProfitable ? '✅ YES' : '❌ NO'}
    `);

  } catch (error) {
    console.error('Arb check failed:', error.message);
  }
}

async function getQuote(src, dst, amount) {
  const params = new URLSearchParams({
    src_mint: src,
    dst_mint: dst,
    amount_in: amount
  });

  const response = await fetch(
    `https://api.carbium.io/api/v2/quote?${params}`,
    { headers: { 'X-API-KEY': API_KEY } }
  );

  if (!response.ok) return null;
  return await response.json();
}

// Run check for 1 SOL
checkArbitrage(1000000000);

import os
import requests
from dotenv import load_dotenv

load_dotenv()

API_KEY = os.getenv('CARBIUM_API_KEY')
BASE_URL = "[https://api.carbium.io/api/v2/quote](https://api.carbium.io/api/v2/quote)"

SOL_MINT = "So11111111111111111111111111111111111111112"
USDC_MINT = "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"

def get_quote(src_mint, dst_mint, amount_in):
    params = {
        "src_mint": src_mint,
        "dst_mint": dst_mint,
        "amount_in": amount_in
    }
    headers = {"X-API-KEY": API_KEY}
    
    try:
        response = requests.get(BASE_URL, params=params, headers=headers)
        response.raise_for_status()
        return response.json()
    except requests.exceptions.RequestException as e:
        print(f"Quote failed: {e}")
        return None

def check_arbitrage(amount_sol_lamports):
    print(f"Checking arb for {amount_sol_lamports / 1e9} SOL...")

    # Leg 1: SOL -> USDC
    leg1 = get_quote(SOL_MINT, USDC_MINT, amount_sol_lamports)
    if not leg1: return
    
    usdc_amount = leg1['outAmount']
    
    # Leg 2: USDC -> SOL
    leg2 = get_quote(USDC_MINT, SOL_MINT, usdc_amount)
    if not leg2: return
    
    final_sol = int(leg2['outAmount'])
    start_sol = int(amount_sol_lamports)
    
    profit = final_sol - start_sol
    
    print(f"""
    --- ARBITRAGE RESULT ---
    Start: {start_sol / 1e9} SOL
    End:   {final_sol / 1e9} SOL
    Profit: {profit / 1e9} SOL
    Result: {'✅ PROFIT' if profit > 0 else '❌ LOSS'}
    """)

if __name__ == "__main__":
    # Check 1 SOL
    check_arbitrage(1000000000)