Learn-skills.dev raptor-dex

Self-hosted Solana DEX aggregator by SolanaTracker — multi-hop routing across 25+ DEXes, WebSocket streaming, Yellowstone Jet TPU submission, no rate limits

install
source · Clone the upstream repo
git clone https://github.com/NeverSight/learn-skills.dev
Claude Code · Install into ~/.claude/skills/
T=$(mktemp -d) && git clone --depth=1 https://github.com/NeverSight/learn-skills.dev "$T" && mkdir -p ~/.claude/skills && cp -r "$T/data/skills-md/agiprolabs/claude-trading-skills/raptor-dex" ~/.claude/skills/neversight-learn-skills-dev-raptor-dex && rm -rf "$T"
manifest: data/skills-md/agiprolabs/claude-trading-skills/raptor-dex/SKILL.md
source content

Raptor — Self-Hosted Solana DEX Aggregator

Raptor is a self-hosted Rust binary that aggregates swap quotes across 25+ Solana DEXes. Unlike Jupiter, Raptor runs on your own infrastructure with no rate limits, no API key, and no dependency on external API availability. Free during public beta.

Quick Start

# Clone the binary repo (includes required signature file)
git clone https://github.com/solanatracker/raptor-binary
cd raptor-binary

# Run with required environment variables
export RPC_URL="https://your-solana-rpc.com"
export YELLOWSTONE_ENDPOINT="https://your-yellowstone-grpc.com"
export YELLOWSTONE_TOKEN="your-token"  # if required by provider
./raptor
# Listens on 0.0.0.0:8080 by default

Requirements: Solana RPC endpoint + Yellowstone gRPC endpoint (for pool indexing). Raptor uses very few RPC calls during normal operation since pool state is streamed via Yellowstone.

Signature file: The

signature
file must be in the same directory as the Raptor binary. It authenticates your instance and is included in the repo clone. If you move the binary, copy the signature file with it.

Execution Flow

1. GET  /quote              → Best route across 25+ DEXes
2. POST /swap               → Unsigned versioned transaction
3. Sign locally              → Your private key never leaves your machine
4. POST /send-transaction   → Submit via Yellowstone Jet TPU
5. GET  /transaction/{sig}  → Confirm status (pending/confirmed/failed/expired)

API Endpoints

MethodEndpointDescription
GET
/quote
Get swap quote with multi-hop routing
POST
/swap
Build swap transaction from quote
POST
/swap-instructions
Get swap instructions only (no tx wrapper)
POST
/quote-and-swap
Quote + transaction in one request
POST
/send-transaction
Submit via Yellowstone Jet TPU with auto-retry
GET
/transaction/:signature
Track transaction status and parsed events
GET
/health
Health check (pools, cache, Yellowstone connection)

Get a Quote

import httpx

RAPTOR = "http://localhost:8080"

resp = httpx.get(f"{RAPTOR}/quote", params={
    "inputMint": "So11111111111111111111111111111111111111112",   # SOL
    "outputMint": "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v",  # USDC
    "amount": 1_000_000_000,  # 1 SOL in lamports
    "slippageBps": 50,
})
quote = resp.json()
print(f"Output: {quote['amountOut']} lamports")
print(f"Price impact: {quote['priceImpact']}%")
print(f"Route: {len(quote['routePlan'])} hops")

Quote Parameters

ParameterTypeRequiredDescription
inputMint
stringYesInput token mint address
outputMint
stringYesOutput token mint address
amount
integerYesAmount in smallest unit (lamports)
slippageBps
stringNoBasis points or
"dynamic"
(default: 50)
dexes
stringNoComma-separated DEX filter
excludeDexes
stringNoDEXes to exclude
maxHops
integerNo1-4 hops (default: 4)
directRouteOnly
booleanNoOnly single-hop routes
pools
stringNoComma-separated pool address filter
feeBps
integerNoPlatform fee 0-1000 bps
feeAccount
stringNoFee recipient wallet

Build and Sign a Swap

import base64
import os

# Step 2: Build transaction from quote
resp = httpx.post(f"{RAPTOR}/swap", json={
    "quoteResponse": quote,
    "userPublicKey": "YOUR_WALLET_PUBKEY",
    "wrapUnwrapSol": True,
    "txVersion": "v0",
    "priorityFee": "auto",       # min|low|auto|medium|high|veryHigh|turbo|unsafeMax
    "maxPriorityFee": 100_000,    # cap in lamports
})
swap = resp.json()
# swap["swapTransaction"] is base64-encoded unsigned transaction

# Step 3: Sign locally (private key never sent to Raptor)
from solders.transaction import VersionedTransaction
from solders.keypair import Keypair

tx_bytes = base64.b64decode(swap["swapTransaction"])
tx = VersionedTransaction.from_bytes(tx_bytes)
keypair = Keypair.from_base58_string(os.getenv("PRIVATE_KEY"))
signed_tx = VersionedTransaction(tx.message, [keypair])
signed_b64 = base64.b64encode(bytes(signed_tx)).decode()

# Step 4: Submit via Yellowstone Jet TPU
resp = httpx.post(f"{RAPTOR}/send-transaction", json={
    "transaction": signed_b64,
})
result = resp.json()
print(f"Signature: {result['signature']}")

# Step 5: Track status
resp = httpx.get(f"{RAPTOR}/transaction/{result['signature']}")
status = resp.json()
# status: pending | confirmed | failed | expired
print(f"Status: {status['status']}, Latency: {status.get('latency_ms')}ms")

WebSocket Streaming

Real-time quote streaming with slot-based updates when pool state changes:

import asyncio, websockets, json

async def stream_quotes():
    async with websockets.connect("ws://localhost:8080/stream") as ws:
        await ws.send(json.dumps({
            "type": "subscribe",
            "inputMint": "So11111111111111111111111111111111111111112",
            "outputMint": "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v",
            "amount": 1_000_000_000,
            "slippageBps": "50",
        }))
        async for msg in ws:
            data = json.loads(msg)
            if data.get("type") == "quote":
                print(f"Out: {data['data']['amountOut']} (slot {data['data']['contextSlot']})")

/stream/swap
variant pre-builds transactions ready for signing, with automatic resend every 10 slots to prevent expiry.

Supported DEXes (25+)

Raydium: AMM, CLMM, CPMM, LaunchLab | Meteora: DLMM, Dynamic AMM, DAMM V2, Curve, DBC | Orca: Whirlpool v1/v2 | Bonding Curves: Pump.fun, Pumpswap, Heaven, MoonIt, Boopfun | PropAMM: Humidifi, Tessera, Solfi V1/V2, AlphaQ, ZeroFi, BisonFi, GoonFi V2 | Other: FluxBeam, PancakeSwap V3

Configuration

Environment Variables

VariableRequiredDefaultDescription
RPC_URL
YesSolana RPC endpoint
YELLOWSTONE_ENDPOINT
YesYellowstone gRPC endpoint
YELLOWSTONE_TOKEN
NoAuth token (if provider requires)
BIND_ADDR
No
0.0.0.0:8080
Listen address
INCLUDE_DEXES
NoallComma-separated DEX filter
EXCLUDE_DEXES
NononeDEXes to exclude
WORKER_THREADS
NoCPU coresWorker thread count
ENABLE_WEBSOCKET
NofalseEnable
/stream
endpoints
ENABLE_YELLOWSTONE_JET
NofalseEnable Jet TPU for
/send-transaction
ENABLE_ARBITRAGE
NofalseEnable circular arbitrage routes

CLI Flags

./raptor --include-dexes raydium,orca,meteora \
         --enable-websocket \
         --enable-yellowstone-jet \
         --workers 4

DEX Filtering Examples

# Only bonding curve DEXes (for PumpFun sniping)
INCLUDE_DEXES="pumpfun,pumpswap,heaven,moonit,boopfun" ./raptor

# Only major AMMs
INCLUDE_DEXES="raydium,orca,meteora" ./raptor

Priority Fee Levels

LevelUse Case
min
/
low
Cost-saving, non-urgent
auto
/
medium
Recommended default
high
/
veryHigh
Faster confirmation
turbo
/
unsafeMax
Maximum speed, competitive scenarios

Raptor vs Jupiter

FeatureRaptorJupiter
Self-hostedYesNo
Rate limitsNone (your hardware)API rate limits
DEX coverage25+30+
LatencyNetwork-localRemote API
CostFree (beta)Free (hosted)
Tx submissionYellowstone Jet TPUStandard RPC
On-chain program
RaptorD5o...
JUP...
API key requiredNoNo

Deployment

See

references/deployment.md
for Docker, Fly.io, and bare metal setup.

Files

References

Scripts

  • scripts/raptor_quote.py
    — Get and compare swap quotes with --demo mode
  • scripts/raptor_swap.py
    — Full swap flow: quote → build → sign → submit → confirm (simulation only in --demo)