Skip to content

0xfnzero/sol-trade-sdk-golang

Folders and files

NameName
Last commit message
Last commit date

Latest commit

Β 

History

16 Commits
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 

Repository files navigation

πŸš€ Sol Trade SDK for Go

A comprehensive Go SDK for seamless Solana DEX trading

A high-performance Go SDK for low-latency Solana DEX trading bots. Built for speed and efficiency, it enables seamless, high-throughput interaction with PumpFun, Pump AMM (PumpSwap), Bonk, Meteora DAMM v2, Raydium AMM v4, and Raydium CPMM for latency-critical trading strategies.

Go Reference License

Go Solana DEX Trading

δΈ­ζ–‡ | English | Website | Telegram | Discord

πŸ“‹ Table of Contents


πŸ“¦ SDK Versions

This SDK is available in multiple languages:

Language Repository Description
Rust sol-trade-sdk Ultra-low latency with zero-copy optimization
Node.js sol-trade-sdk-nodejs TypeScript/JavaScript for Node.js
Python sol-trade-sdk-python Async/await native support
Go sol-trade-sdk-golang Concurrent-safe with goroutine support

✨ Features

  1. PumpFun Trading: Support for buy and sell operations
  2. PumpSwap Trading: Support for PumpSwap pool trading operations
  3. Bonk Trading: Support for Bonk trading operations
  4. Raydium CPMM Trading: Support for Raydium CPMM (Concentrated Pool Market Maker) trading operations
  5. Raydium AMM V4 Trading: Support for Raydium AMM V4 (Automated Market Maker) trading operations
  6. Meteora DAMM V2 Trading: Support for Meteora DAMM V2 (Dynamic AMM) trading operations
  7. Multiple MEV Protection: Support for Jito, Nextblock, ZeroSlot, Temporal, Bloxroute, FlashBlock, BlockRazor, Node1, Astralane and other services
  8. Concurrent Trading: Send transactions using multiple MEV services simultaneously; the fastest succeeds while others fail
  9. Unified Trading Interface: Use unified trading protocol types for trading operations
  10. Middleware System: Support for custom instruction middleware to modify, add, or remove instructions before transaction execution
  11. Shared Infrastructure: Share expensive RPC and SWQoS clients across multiple wallets for reduced resource usage

πŸ“¦ Installation

Direct Clone (Recommended)

Clone this project to your project directory:

cd your_project_root_directory
git clone https://github.com/0xfnzero/sol-trade-sdk-golang

Add the dependency to your go.mod:

// Add to your go.mod
require github.com/0xfnzero/sol-trade-sdk-golang v0.0.0

replace github.com/0xfnzero/sol-trade-sdk-golang => ./sol-trade-sdk-golang

Then run:

go mod tidy

Use Go Modules

go get github.com/0xfnzero/sol-trade-sdk-golang

πŸ› οΈ Usage Examples

πŸ“‹ Example Usage

1. Create TradingClient Instance

You can refer to Example: Create TradingClient Instance.

Method 1: Simple (single wallet)

package main

import (
    "context"
    "fmt"
    "log"

    soltradesdk "github.com/0xfnzero/sol-trade-sdk-golang"
    "github.com/0xfnzero/sol-trade-sdk-golang/pkg/common"
    "github.com/0xfnzero/sol-trade-sdk-golang/pkg/trading"
)

func main() {
    ctx := context.Background()

    // Wallet
    payer := /* your keypair */

    // RPC URL
    rpcURL := "https://mainnet.helius-rpc.com/?api-key=xxxxxx"

    // Multiple SWQoS services can be configured
    swqosConfigs := []soltradesdk.SwqosConfig{
        {Type: soltradesdk.SwqosTypeDefault, RPCUrl: rpcURL},
        {Type: soltradesdk.SwqosTypeJito, UUID: "your_uuid", Region: soltradesdk.SwqosRegionFrankfurt},
        {Type: soltradesdk.SwqosTypeBloxroute, APIToken: "your_api_token", Region: soltradesdk.SwqosRegionFrankfurt},
        {Type: soltradesdk.SwqosTypeAstralane, APIKey: "your_api_key", Region: soltradesdk.SwqosRegionFrankfurt},
    }

    // Create TradeConfig instance
    config := &soltradesdk.TradeConfig{
        RPCUrl:      rpcURL,
        SwqosConfigs: swqosConfigs,
    }

    // Create TradingClient
    client := trading.NewTradingClient(payer, config)
}

Method 2: Shared infrastructure (multiple wallets)

For multi-wallet scenarios, create the infrastructure once and share it across wallets. See Example: Shared Infrastructure.

// Create infrastructure once (expensive)
infraConfig := &common.InfrastructureConfig{
    RPCUrl:      rpcURL,
    SwqosConfigs: swqosConfigs,
}
infrastructure := trading.NewTradingInfrastructure(infraConfig)

// Create multiple clients sharing the same infrastructure (fast)
client1 := trading.NewTradingClientFromInfrastructure(payer1, infrastructure)
client2 := trading.NewTradingClientFromInfrastructure(payer2, infrastructure)

2. Configure Gas Fee Strategy

// Create GasFeeStrategy instance
gasStrategy := common.NewGasFeeStrategy()
// Set global strategy
gasStrategy.SetGlobalFeeStrategy(150000, 150000, 500000, 500000, 0.001, 0.001)

3. Build Trading Parameters

buyParams := &soltradesdk.TradeBuyParams{
    DexType:              soltradesdk.DexTypePumpSwap,
    InputTokenType:       soltradesdk.TradeTokenTypeWSOL,
    Mint:                 mintPubkey,
    InputTokenAmount:     buySolAmount,
    SlippageBasisPoints:  500,
    RecentBlockhash:      &recentBlockhash,
    ExtensionParams:      &soltradesdk.DexParamEnum{Type: "PumpSwap", Params: pumpSwapParams},
    WaitTransactionConfirmed: true,
    CreateInputTokenAta:  true,
    CloseInputTokenAta:   true,
    CreateMintAta:        true,
    GasFeeStrategy:       gasStrategy,
    Simulate:             false,
}

4. Execute Trading

result, err := client.Buy(ctx, buyParams)
if err != nil {
    log.Fatal(err)
}
fmt.Printf("Transaction signature: %s\n", result.Signature)

⚑ Trading Parameters

For comprehensive information about all trading parameters including TradeBuyParams and TradeSellParams, see the Trading Parameters documentation.

About ShredStream

When using shred to subscribe to events, due to the nature of shreds, you cannot get complete information about transaction events. Please ensure that the parameters your trading logic depends on are available in shreds when using them.

πŸ“Š Usage Examples Summary Table

Description Run Command Source Code
Create and configure TradingClient instance go run ./examples/trading_client examples/trading_client
Share infrastructure across multiple wallets go run ./examples/shared_infrastructure examples/shared_infrastructure
PumpFun token sniping trading go run ./examples/pumpfun_sniper_trading examples/pumpfun_sniper_trading
PumpFun token copy trading go run ./examples/pumpfun_copy_trading examples/pumpfun_copy_trading
PumpSwap trading operations go run ./examples/pumpswap_trading examples/pumpswap_trading
PumpSwap direct trading (via RPC) go run ./examples/pumpswap_direct_trading examples/pumpswap_direct_trading
Raydium CPMM trading operations go run ./examples/raydium_cpmm_trading examples/raydium_cpmm_trading
Raydium AMM V4 trading operations go run ./examples/raydium_amm_v4_trading examples/raydium_amm_v4_trading
Meteora DAMM V2 trading operations go run ./examples/meteora_damm_v2_trading examples/meteora_damm_v2_trading
Bonk token sniping trading go run ./examples/bonk_sniper_trading examples/bonk_sniper_trading
Bonk token copy trading go run ./examples/bonk_copy_trading examples/bonk_copy_trading
Custom instruction middleware example go run ./examples/middleware_system examples/middleware_system
Address lookup table example go run ./examples/address_lookup examples/address_lookup
Nonce cache (durable nonce) example go run ./examples/nonce_cache examples/nonce_cache
Wrap/unwrap SOL to/from WSOL example go run ./examples/wsol_wrapper examples/wsol_wrapper
Seed trading example go run ./examples/seed_trading examples/seed_trading
Gas fee strategy example go run ./examples/gas_fee_strategy examples/gas_fee_strategy
Hot path trading (zero-RPC) go run ./examples/hot_path_trading examples/hot_path_trading

βš™οΈ SWQoS Service Configuration

When configuring SWQoS services, note the different parameter requirements for each service:

  • Jito: The first parameter is UUID (if no UUID, pass an empty string "")
  • Other MEV services: The first parameter is the API Token

Custom URL Support

Each SWQoS service supports an optional custom URL parameter:

// Using custom URL
jitoConfig := soltradesdk.SwqosConfig{
    Type:      soltradesdk.SwqosTypeJito,
    UUID:      "your_uuid",
    Region:    soltradesdk.SwqosRegionFrankfurt,
    CustomURL: "https://custom-jito-endpoint.com",
}

// Using default regional endpoint
bloxrouteConfig := soltradesdk.SwqosConfig{
    Type:     soltradesdk.SwqosTypeBloxroute,
    APIToken: "your_api_token",
    Region:   soltradesdk.SwqosRegionNewYork,
}

URL Priority Logic:

  • If a custom URL is provided, it will be used instead of the regional endpoint
  • If no custom URL is provided, the system will use the default endpoint for the specified region
  • This allows for maximum flexibility while maintaining backward compatibility

When using multiple MEV services, you need to use Durable Nonce. You need to use the FetchNonceInfo function to get the latest nonce value, and use it as the DurableNonce when trading.


πŸ”§ Middleware System

The SDK provides a powerful middleware system that allows you to modify, add, or remove instructions before transaction execution. Middleware executes in the order they are added:

import "github.com/0xfnzero/sol-trade-sdk-golang/pkg/middleware"

manager := middleware.NewManager()
manager.Add(FirstMiddleware{})   // Executes first
manager.Add(SecondMiddleware{})  // Executes second
manager.Add(ThirdMiddleware{})   // Executes last

πŸ” Address Lookup Tables

Address Lookup Tables (ALT) allow you to optimize transaction size and reduce fees by storing frequently used addresses in a compact table format.

import "github.com/0xfnzero/sol-trade-sdk-golang/pkg/addresslookup"

// Fetch ALT from chain
alt, err := addresslookup.FetchAddressLookupTableAccount(ctx, rpcClient, altAddress)
if err != nil {
    log.Fatal(err)
}
fmt.Printf("ALT contains %d addresses\n", len(alt.Addresses))

πŸ” Durable Nonce

Use Durable Nonce to implement transaction replay protection and optimize transaction processing.

import "github.com/0xfnzero/sol-trade-sdk-golang/pkg/nonce"

// Fetch nonce info
nonceInfo, err := nonce.FetchNonceInfo(ctx, rpcClient, nonceAccount)
if err != nil {
    log.Fatal(err)
}

πŸ’° Cashback Support (PumpFun / PumpSwap)

PumpFun and PumpSwap support cashback for eligible tokens: part of the trading fee can be returned to the user. The SDK must know whether the token has cashback enabled so that buy/sell instructions include the correct accounts.

  • When params come from RPC: If you use PumpFunParams.FromMintByRPC or PumpSwapParams.FromPoolAddressByRPC, the SDK reads IsCashbackCoin from chainβ€”no extra step.
  • When params come from event/parser: If you build params from trade events (e.g. sol-parser-sdk), you must pass the cashback flag into the SDK:
    • PumpFun: Set IsCashbackCoin when building params from parsed events.
    • PumpSwap: Set IsCashbackCoin field when constructing params manually.

πŸ›‘οΈ MEV Protection Services

You can apply for a key through the official website: Community Website

  • Jito: High-performance block space
  • ZeroSlot: Zero-latency transactions
  • Temporal: Time-sensitive transactions
  • Bloxroute: Blockchain network acceleration
  • FlashBlock: High-speed transaction execution with API key authentication
  • BlockRazor: High-speed transaction execution with API key authentication
  • Node1: High-speed transaction execution with API key authentication
  • Astralane: Blockchain network acceleration

πŸ“ Project Structure

pkg/
β”œβ”€β”€ addresslookup/    # Address Lookup Table support
β”œβ”€β”€ cache/            # LRU, TTL, and sharded caches
β”œβ”€β”€ calc/             # AMM calculations with overflow detection
β”œβ”€β”€ common/           # Core types, gas strategies, errors
β”œβ”€β”€ execution/        # Branch optimization, prefetching
β”œβ”€β”€ hotpath/          # Zero-RPC hot path execution
β”œβ”€β”€ instruction/      # Instruction builders for all DEXes
β”œβ”€β”€ middleware/       # Instruction middleware system
β”œβ”€β”€ perf/             # Performance optimizations
β”œβ”€β”€ pool/             # Connection and worker pools
β”œβ”€β”€ rpc/              # High-performance RPC clients
β”œβ”€β”€ seed/             # PDA derivation for all protocols
β”œβ”€β”€ security/         # Secure key storage, validators
β”œβ”€β”€ swqos/            # MEV provider clients
└── trading/          # High-performance trade executor

πŸ“„ License

MIT License

πŸ’¬ Contact

⚠️ Important Notes

  1. Test thoroughly before using on mainnet
  2. Properly configure private keys and API tokens
  3. Pay attention to slippage settings to avoid transaction failures
  4. Monitor balances and transaction fees
  5. Comply with relevant laws and regulations

Releases

No releases published

Packages

 
 
 

Contributors

Languages