dexparser

package module
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 22, 2026 License: MIT Imports: 22 Imported by: 0

README

Solana DEX Parser (Go)

Go Version License Docs

A high-performance Go library for parsing Solana DEX transactions.

Supports 23 full parsers + 55 routing detection (program IDs), including Jupiter, Raydium, Orca, Meteora, Pumpfun, Pumpswap, and 9 trading bots with fee detection + 6 bot programs.

Installation

go get github.com/DefaultPerson/solana-dex-parser-go

Quick Start

package main

import (
    "encoding/json"
    "fmt"

    dexparser "github.com/DefaultPerson/solana-dex-parser-go"
)

func main() {
    var tx dexparser.SolanaTransaction
    json.Unmarshal([]byte(txJSON), &tx)

    parser := dexparser.NewDexParser()
    result := parser.ParseAll(&tx, nil)

    fmt.Printf("Trades: %d\n", len(result.Trades))
    fmt.Printf("Liquidities: %d\n", len(result.Liquidities))
    fmt.Printf("MemeEvents: %d\n", len(result.MemeEvents))
}

Features

  • Multi-Protocol - Jupiter, Raydium, Orca, Meteora, Pumpfun, Moonit, etc.
  • Rich Data - Trades, liquidity events, transfers, meme events
  • High Performance - Optimized JSON parsing, memory pooling
  • gRPC Support - ShredParser for Helius/Triton streams

Documentation

Supported Protocols

Status Legend:

  • ✅ Parser — Full trade/liquidity parsing with instruction decoding
  • 🔗 Constants — Program ID defined for routing detection only
DEX Aggregators & Routers
Protocol Trades Liquidity Transfers Status
Jupiter (V6, DCA, Limit, VA) ✅ ❌ ✅ ✅ Parser
OKX DEX ✅ ❌ ✅ 🔗 Constants
DFlow ✅ ❌ ✅ ✅ Parser
Sanctum ✅ ❌ ✅ 🔗 Constants
Photon ✅ ❌ ✅ ✅ Parser
Raydium Route ✅ ❌ ✅ ✅ Parser
Major AMMs
Protocol Trades Liquidity Transfers Status
Raydium V4 ✅ ✅ ✅ ✅ Parser
Raydium CPMM ✅ ✅ ✅ ✅ Parser
Raydium CL ✅ ✅ ✅ ✅ Parser
Orca Whirlpool ✅ ✅ ✅ ✅ Parser
Meteora DLMM ✅ ✅ ✅ ✅ Parser
Meteora Pools ✅ ✅ ✅ ✅ Parser
Meteora DAMM ✅ ✅ ✅ ✅ Parser
PumpSwap ✅ ✅ ✅ ✅ Parser
Phoenix ✅ ❌ ✅ 🔗 Constants
Lifinity ✅ ❌ ✅ 🔗 Constants
Lifinity V2 ✅ ❌ ✅ 🔗 Constants
OpenBook ✅ ❌ ✅ 🔗 Constants
Prop AMM / Dark Pools
Protocol Trades Liquidity Transfers Status
SolFi ✅ ❌ ✅ ✅ Parser
GoonFi ✅ ❌ ✅ ✅ Parser
Obric V2 ✅ ❌ ✅ ✅ Parser
HumidiFi ✅ ❌ ✅ ✅ Parser
Meme & Launch Platforms
Protocol Trades Create Migrate Status
Pumpfun ✅ ✅ ✅ ✅ Parser
Raydium Launchpad ✅ ✅ ✅ ✅ Parser
Meteora DBC ✅ ✅ ✅ ✅ Parser
Moonit ✅ ✅ ✅ ✅ Parser
Heaven.xyz ✅ ✅ ✅ ✅ Parser
Sugar.money ✅ ✅ ✅ ✅ Parser
Bonk ✅ ✅ ✅ 🔗 Constants
BoopFun ✅ ✅ ✅ ✅ Parser
Trading Bots (Fee Account Detection)
Bot Detection Status
Trojan ✅ ✅ Parser
BONKbot ✅ ✅ Parser
Axiom ✅ ✅ Parser
GMGN ✅ ✅ Parser
BullX ✅ ✅ Parser
Maestro ✅ ✅ Parser
Bloom ✅ ✅ Parser
BananaGun ✅ ✅ Parser
Raybot ✅ ✅ Parser
Trading Bots (Program Detection)
Bot Detection Status
Mintech ✅ 🔗 Constants
Nova ✅ 🔗 Constants
Apepro ✅ 🔗 Constants
BananaGun ✅ 🔗 Constants
Bloom ✅ 🔗 Constants
Maestro ✅ 🔗 Constants
Additional AMMs
Protocol Trades Liquidity Transfers Status
GooseFX ✅ ❌ ✅ 🔗 Constants
Mercurial ✅ ❌ ✅ 🔗 Constants
Stabble ✅ ❌ ✅ 🔗 Constants
1Dex ✅ ❌ ✅ 🔗 Constants
ZeroFi ✅ ❌ ✅ 🔗 Constants
Legacy Protocols
Protocol Trades Liquidity Status
Serum V3 ✅ ❌ 🔗 Constants
Aldrin ✅ ❌ 🔗 Constants
Aldrin V2 ✅ ❌ 🔗 Constants
Crema ✅ ❌ 🔗 Constants
Saber ✅ ❌ 🔗 Constants
Saros ✅ ❌ 🔗 Constants

Total: 23 full parsers + 55 routing detection (program IDs)

Shred Parser Support

Real-time shred-stream processing for live blockchain data analysis via gRPC streams (Helius, Triton, etc.):

parser := dexparser.NewShredParser()
result := parser.ParseAll(&tx, nil)

// Access parsed instructions by program
for program, instructions := range result.Instructions {
    fmt.Printf("%s: %d instructions\n", program, len(instructions))
}
Key Differences: ShredParser vs DexParser
Feature DexParser ShredParser
Input Data Complete transaction Raw message only
Execution State Post-execution Pre-execution
Transfer Data ✅ Actual results ❌ No execution
Use Case Historical analysis Real-time monitoring
Shred Parser Protocol Support
Protocol Status Notes
Pumpfun ✅ Buy, Sell, Create, Migrate
PumpSwap ✅ Buy, Sell, Add/Remove Liquidity
Jupiter V6 ✅ Route, SharedAccountsRoute
Raydium V4 ✅ Swap instructions
Raydium Launchpad ✅ Buy, Sell, Create
Meteora DBC ✅ Dynamic bonding curve
DFlow ✅ Swap routing
Photon ✅ Multi-hop aggregation
System Program ✅ SOL transfers
Token Program ✅ SPL transfers
Token 2022 ✅ Token extensions

License

MIT License - see LICENSE

Acknowledgments

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertYellowstoneTransaction added in v1.2.0 

func ConvertYellowstoneTransaction(grpc *YellowstoneTransaction, slot uint64, blockTime int64) *adapter.SolanaTransaction

ConvertYellowstoneTransaction converts a Yellowstone gRPC transaction to SolanaTransaction format that can be used with DexParser.ParseAll() or ShredParser.ParseAll()

Types

type DexParser 

type DexParser struct {
	// contains filtered or unexported fields
}

DexParser is the main parser class for Solana DEX transactions

func NewDexParser 

func NewDexParser() *DexParser

NewDexParser creates a new DexParser instance

func (*DexParser) ParseAll 

func (dp *DexParser) ParseAll(tx *adapter.SolanaTransaction, config *types.ParseConfig) *types.ParseResult

ParseAll parses all data from a transaction

func (*DexParser) ParseBatch added in v1.2.0 

func (dp *DexParser) ParseBatch(txs []*adapter.SolanaTransaction, config *types.ParseConfig, maxWorkers int) []*types.ParseResult

ParseBatch parses multiple transactions concurrently maxWorkers: maximum number of concurrent workers, if <= 1, will use sequential processing

func (*DexParser) ParseBatchWithCallback added in v1.2.0 

func (dp *DexParser) ParseBatchWithCallback(
	txs []*adapter.SolanaTransaction,
	config *types.ParseConfig,
	maxWorkers int,
	callback ParseCallback,
) []*types.ParseResult

ParseBatchWithCallback parses multiple transactions with callback support maxWorkers: maximum number of concurrent workers, if <= 1, will use sequential processing callback: optional callback function called for each completed transaction

func (*DexParser) ParseLiquidity 

func (dp *DexParser) ParseLiquidity(tx *adapter.SolanaTransaction, config *types.ParseConfig) []types.PoolEvent

ParseLiquidity parses liquidity events from a transaction

func (*DexParser) ParseTrades 

func (dp *DexParser) ParseTrades(tx *adapter.SolanaTransaction, config *types.ParseConfig) []types.TradeInfo

ParseTrades parses trades from a transaction

func (*DexParser) ParseTransfers 

func (dp *DexParser) ParseTransfers(tx *adapter.SolanaTransaction, config *types.ParseConfig) []types.TransferData

ParseTransfers parses transfers from a transaction

func (*DexParser) RegisterLiquidityParser 

func (dp *DexParser) RegisterLiquidityParser(programId string, factory LiquidityParserFactory)

RegisterLiquidityParser registers a liquidity parser for a program ID

func (*DexParser) RegisterMemeEventParser 

func (dp *DexParser) RegisterMemeEventParser(programId string, factory MemeEventParserFactory)

RegisterMemeEventParser registers a meme event parser for a program ID

func (*DexParser) RegisterTradeParser 

func (dp *DexParser) RegisterTradeParser(programId string, factory TradeParserFactory)

RegisterTradeParser registers a trade parser for a program ID

func (*DexParser) RegisterTransferParser 

func (dp *DexParser) RegisterTransferParser(programId string, factory TransferParserFactory)

RegisterTransferParser registers a transfer parser for a program ID

type LiquidityParserFactory 

type LiquidityParserFactory func(
	adapter *adapter.TransactionAdapter,
	transferActions map[string][]types.TransferData,
	classifiedInstructions []types.ClassifiedInstruction,
) parsers.LiquidityParser

LiquidityParserFactory creates a liquidity parser

type MemeEventParserFactory 

type MemeEventParserFactory func(
	adapter *adapter.TransactionAdapter,
	transferActions map[string][]types.TransferData,
) parsers.EventParser

MemeEventParserFactory creates a meme event parser

type ParseCallback added in v1.2.0 

type ParseCallback func(index int, tx *adapter.SolanaTransaction, result *types.ParseResult, err error) bool

ParseCallback defines the callback function type for batch parsing index: the index of the transaction in the batch tx: the transaction being parsed (may be nil) result: the parse result err: any error that occurred during parsing returns: true to continue processing, false to stop early

type PumpfunBuyData 

type PumpfunBuyData struct {
	Mint         string `json:"mint"`
	BondingCurve string `json:"bondingCurve"`
	TokenAmount  uint64 `json:"tokenAmount"`
	SolAmount    uint64 `json:"solAmount"`
	User         string `json:"user"`
}

PumpfunBuyData contains buy instruction data

type PumpfunCreateData 

type PumpfunCreateData struct {
	Name         string `json:"name"`
	Symbol       string `json:"symbol"`
	URI          string `json:"uri"`
	Mint         string `json:"mint"`
	BondingCurve string `json:"bondingCurve"`
	User         string `json:"user"`
}

PumpfunCreateData contains create instruction data

type PumpfunInstruction 

type PumpfunInstruction struct {
	Type      string      `json:"type"`
	Data      interface{} `json:"data"`
	Slot      uint64      `json:"slot"`
	Timestamp int64       `json:"timestamp"`
	Signature string      `json:"signature"`
	Idx       string      `json:"idx"`
	Signer    []string    `json:"signer"`
}

PumpfunInstruction represents a parsed Pumpfun instruction

type PumpfunInstructionParser 

type PumpfunInstructionParser struct {
	// contains filtered or unexported fields
}

PumpfunInstructionParser parses Pumpfun instructions

func NewPumpfunInstructionParser 

func NewPumpfunInstructionParser(adapter *adapter.TransactionAdapter, classifier *classifier.InstructionClassifier) *PumpfunInstructionParser

NewPumpfunInstructionParser creates a new Pumpfun instruction parser

func (*PumpfunInstructionParser) ProcessInstructions 

func (p *PumpfunInstructionParser) ProcessInstructions() []interface{}

ProcessInstructions processes all Pumpfun instructions

type PumpfunMigrateData 

type PumpfunMigrateData struct {
	Mint                  string `json:"mint"`
	BondingCurve          string `json:"bondingCurve"`
	User                  string `json:"user"`
	PoolMint              string `json:"poolMint"`
	QuoteMint             string `json:"quoteMint"`
	LpMint                string `json:"lpMint"`
	UserPoolTokenAccount  string `json:"userPoolTokenAccount"`
	PoolBaseTokenAccount  string `json:"poolBaseTokenAccount"`
	PoolQuoteTokenAccount string `json:"poolQuoteTokenAccount"`
}

PumpfunMigrateData contains migrate instruction data

type PumpfunSellData 

type PumpfunSellData struct {
	Mint         string `json:"mint"`
	BondingCurve string `json:"bondingCurve"`
	TokenAmount  uint64 `json:"tokenAmount"`
	SolAmount    uint64 `json:"solAmount"`
	User         string `json:"user"`
}

PumpfunSellData contains sell instruction data

type PumpswapAddLiquidityData 

type PumpswapAddLiquidityData struct {
	PoolMint              string `json:"poolMint"`
	User                  string `json:"user"`
	BaseMint              string `json:"baseMint"`
	QuoteMint             string `json:"quoteMint"`
	LpMint                string `json:"lpMint"`
	UserBaseTokenAccount  string `json:"userBaseTokenAccount"`
	UserQuoteTokenAccount string `json:"userQuoteTokenAccount"`
	UserPoolTokenAccount  string `json:"userPoolTokenAccount"`
	PoolBaseTokenAccount  string `json:"poolBaseTokenAccount"`
	PoolQuoteTokenAccount string `json:"poolQuoteTokenAccount"`
	LpTokenAmountOut      uint64 `json:"lpTokenAmountOut"`
	MaxBaseAmountIn       uint64 `json:"maxBaseAmountIn"`
	MaxQuoteAmountIn      uint64 `json:"maxQuoteAmountIn"`
}

PumpswapAddLiquidityData contains add liquidity instruction data

type PumpswapBuyInstructionData 

type PumpswapBuyInstructionData struct {
	PoolMint              string `json:"poolMint"`
	User                  string `json:"user"`
	BaseMint              string `json:"baseMint"`
	QuoteMint             string `json:"quoteMint"`
	UserBaseTokenAccount  string `json:"userBaseTokenAccount"`
	UserQuoteTokenAccount string `json:"userQuoteTokenAccount"`
	PoolBaseTokenAccount  string `json:"poolBaseTokenAccount"`
	PoolQuoteTokenAccount string `json:"poolQuoteTokenAccount"`
	BaseAmountOut         uint64 `json:"baseAmountOut"`
	MaxQuoteAmountIn      uint64 `json:"maxQuoteAmountIn"`
}

PumpswapBuyInstructionData contains buy instruction data

type PumpswapCreatePoolInstructionData 

type PumpswapCreatePoolInstructionData struct {
	PoolMint              string `json:"poolMint"`
	User                  string `json:"user"`
	BaseMint              string `json:"baseMint"`
	QuoteMint             string `json:"quoteMint"`
	LpMint                string `json:"lpMint"`
	UserBaseTokenAccount  string `json:"userBaseTokenAccount"`
	UserQuoteTokenAccount string `json:"userQuoteTokenAccount"`
	UserPoolTokenAccount  string `json:"userPoolTokenAccount"`
	PoolBaseTokenAccount  string `json:"poolBaseTokenAccount"`
	PoolQuoteTokenAccount string `json:"poolQuoteTokenAccount"`
	BaseAmountIn          uint64 `json:"baseAmountIn"`
	QuoteAmountOut        uint64 `json:"quoteAmountOut"`
}

PumpswapCreatePoolInstructionData contains create pool instruction data

type PumpswapInstruction 

type PumpswapInstruction struct {
	Type      string      `json:"type"`
	Data      interface{} `json:"data"`
	Slot      uint64      `json:"slot"`
	Timestamp int64       `json:"timestamp"`
	Signature string      `json:"signature"`
	Idx       string      `json:"idx"`
	Signer    []string    `json:"signer"`
}

PumpswapInstruction represents a parsed Pumpswap instruction

type PumpswapInstructionParser 

type PumpswapInstructionParser struct {
	// contains filtered or unexported fields
}

PumpswapInstructionParser parses Pumpswap instructions

func NewPumpswapInstructionParser 

func NewPumpswapInstructionParser(adapter *adapter.TransactionAdapter, classifier *classifier.InstructionClassifier) *PumpswapInstructionParser

NewPumpswapInstructionParser creates a new Pumpswap instruction parser

func (*PumpswapInstructionParser) ProcessInstructions 

func (p *PumpswapInstructionParser) ProcessInstructions() []interface{}

ProcessInstructions processes all Pumpswap instructions

type PumpswapRemoveLiquidityData 

type PumpswapRemoveLiquidityData struct {
	PoolMint              string `json:"poolMint"`
	User                  string `json:"user"`
	BaseMint              string `json:"baseMint"`
	QuoteMint             string `json:"quoteMint"`
	LpMint                string `json:"lpMint"`
	UserBaseTokenAccount  string `json:"userBaseTokenAccount"`
	UserQuoteTokenAccount string `json:"userQuoteTokenAccount"`
	UserPoolTokenAccount  string `json:"userPoolTokenAccount"`
	PoolBaseTokenAccount  string `json:"poolBaseTokenAccount"`
	PoolQuoteTokenAccount string `json:"poolQuoteTokenAccount"`
	LpTokenAmountIn       uint64 `json:"lpTokenAmountIn"`
	MinBaseAmountOut      uint64 `json:"minBaseAmountOut"`
	MinQuoteAmountOut     uint64 `json:"minQuoteAmountOut"`
}

PumpswapRemoveLiquidityData contains remove liquidity instruction data

type PumpswapSellInstructionData 

type PumpswapSellInstructionData struct {
	PoolMint              string `json:"poolMint"`
	User                  string `json:"user"`
	BaseMint              string `json:"baseMint"`
	QuoteMint             string `json:"quoteMint"`
	UserBaseTokenAccount  string `json:"userBaseTokenAccount"`
	UserQuoteTokenAccount string `json:"userQuoteTokenAccount"`
	PoolBaseTokenAccount  string `json:"poolBaseTokenAccount"`
	PoolQuoteTokenAccount string `json:"poolQuoteTokenAccount"`
	BaseAmountIn          uint64 `json:"baseAmountIn"`
	MinQuoteAmountOut     uint64 `json:"minQuoteAmountOut"`
}

PumpswapSellInstructionData contains sell instruction data

type ShredInstructionParser 

type ShredInstructionParser interface {
	ProcessInstructions() []interface{}
}

ShredInstructionParser interface for instruction parsers

type ShredParser 

type ShredParser struct {
}

ShredParser parses Solana Shred transactions (pre-execution instruction analysis)

func NewShredParser 

func NewShredParser() *ShredParser

NewShredParser creates a new ShredParser

func (*ShredParser) ParseAll 

func (p *ShredParser) ParseAll(tx *adapter.SolanaTransaction, config *types.ParseConfig) *types.ParseShredResult

ParseAll parses both trades and liquidity events from transaction

type TradeParserFactory 

type TradeParserFactory func(
	adapter *adapter.TransactionAdapter,
	dexInfo types.DexInfo,
	transferActions map[string][]types.TransferData,
	classifiedInstructions []types.ClassifiedInstruction,
) parsers.TradeParser

TradeParserFactory creates a trade parser

type TransferParserFactory 

type TransferParserFactory func(
	adapter *adapter.TransactionAdapter,
	dexInfo types.DexInfo,
	transferActions map[string][]types.TransferData,
	classifiedInstructions []types.ClassifiedInstruction,
) parsers.TransferParser

TransferParserFactory creates a transfer parser

type YellowstoneAddressTableLookup added in v1.2.0 

type YellowstoneAddressTableLookup struct {
	AccountKey      []byte
	WritableIndexes []byte
	ReadonlyIndexes []byte
}

YellowstoneAddressTableLookup represents address table lookup from gRPC

type YellowstoneHeader added in v1.2.0 

type YellowstoneHeader struct {
	NumRequiredSignatures       int
	NumReadonlySignedAccounts   int
	NumReadonlyUnsignedAccounts int
}

YellowstoneHeader represents the message header from gRPC

type YellowstoneInnerInstructionSet added in v1.2.0 

type YellowstoneInnerInstructionSet struct {
	Index        int
	Instructions []YellowstoneInstruction
}

YellowstoneInnerInstructionSet represents inner instructions from gRPC

type YellowstoneInstruction added in v1.2.0 

type YellowstoneInstruction struct {
	ProgramIdIndex int
	Accounts       []byte
	Data           []byte
}

YellowstoneInstruction represents an instruction from gRPC

type YellowstoneLoadedAddresses added in v1.2.0 

type YellowstoneLoadedAddresses struct {
	Writable [][]byte
	Readonly [][]byte
}

YellowstoneLoadedAddresses represents loaded addresses from gRPC

type YellowstoneMessageData added in v1.2.0 

type YellowstoneMessageData struct {
	Header              YellowstoneHeader
	AccountKeys         [][]byte
	RecentBlockhash     []byte
	Instructions        []YellowstoneInstruction
	Versioned           bool
	AddressTableLookups []YellowstoneAddressTableLookup
}

YellowstoneMessageData represents the message data from gRPC

type YellowstoneReturnData added in v1.2.0 

type YellowstoneReturnData struct {
	ProgramId []byte
	Data      []byte
}

YellowstoneReturnData represents return data from gRPC

type YellowstoneTokenAmount added in v1.2.0 

type YellowstoneTokenAmount struct {
	Amount         string
	Decimals       int
	UiAmount       *float64
	UiAmountString string
}

YellowstoneTokenAmount represents token amount from gRPC

type YellowstoneTokenBalance added in v1.2.0 

type YellowstoneTokenBalance struct {
	AccountIndex  int
	Mint          string
	Owner         string
	UiTokenAmount YellowstoneTokenAmount
}

YellowstoneTokenBalance represents token balance from gRPC

type YellowstoneTransaction added in v1.2.0 

type YellowstoneTransaction struct {
	Signature   []byte
	IsVote      bool
	Transaction YellowstoneTransactionData
	Meta        YellowstoneTransactionMeta
}

YellowstoneTransaction represents a transaction from Yellowstone gRPC (Helius Laserstream/Triton)

type YellowstoneTransactionData added in v1.2.0 

type YellowstoneTransactionData struct {
	Signatures [][]byte
	Message    YellowstoneMessageData
}

YellowstoneTransactionData represents the transaction data from gRPC

type YellowstoneTransactionMeta added in v1.2.0 

type YellowstoneTransactionMeta struct {
	Err                  interface{}
	Fee                  uint64
	PreBalances          []uint64
	PostBalances         []uint64
	PreTokenBalances     []YellowstoneTokenBalance
	PostTokenBalances    []YellowstoneTokenBalance
	InnerInstructions    []YellowstoneInnerInstructionSet
	LogMessages          []string
	LoadedAddresses      YellowstoneLoadedAddresses
	ReturnData           *YellowstoneReturnData
	ComputeUnitsConsumed uint64
}

YellowstoneTransactionMeta represents the transaction metadata from gRPC

Source Files

View all Source files

Directories

Path Synopsis
alt
dflow
jupiter
meme
meteora
orca
photon
propamm
pumpfun
raydium
systoken

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.