sol-parser-sdk 0.9.0

A lightweight Rust library for real-time event streaming from Solana DEX trading programs. Supports PumpFun, PumpSwap, LaunchLab, and Raydium protocols with Yellowstone gRPC and ShredStream.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

//! Lossless outer instruction payload, without assumptions about program behavior.
use serde::{Deserialize, Serialize};
use solana_sdk::pubkey::Pubkey;

/// Original outer instruction associated with a DEX trade callback. Account
/// order and duplicates are preserved; unresolved ALT addresses remain None.
#[derive(Debug, Clone, Default, PartialEq, Eq, Serialize, Deserialize)]
pub struct RawInstructionPayload {
    pub program_id: Pubkey,
    pub instruction_index: usize,
    pub accounts: Vec<Option<Pubkey>>,
    pub account_indices: Vec<u8>,
    pub instruction_data: Vec<u8>,
}

/// Evidence available to the parser, not a guarantee that every amount is known.
#[derive(Debug, Clone, Copy, Default, PartialEq, Eq, Serialize, Deserialize)]
pub enum TradeParseStatus {
    /// Outer instruction references a DEX; no trade or direction is proven.
    Unresolved,
    /// Instruction inputs were decoded; execution amounts are not established.
    #[default]
    InstructionDecoded,
    /// Successful execution metadata/logs establish the DEX invocation.
    /// Executed amounts may still be unavailable when event logs are missing.
    ExecutionConfirmed,
}

/// Compatibility alias for the original Pump.fun-specific name.
pub type PumpFunParseStatus = TradeParseStatus;

/// Stable DEX identifiers retained for stock-price configuration compatibility.
/// These identifiers do not trigger raw-instruction parsing.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)]
pub enum RawInstructionDexType {
    #[serde(rename = "pumpfun")]
    PumpFun,
    #[serde(rename = "pumpswap")]
    PumpSwap,
    #[serde(rename = "raydium_launchlab")]
    RaydiumLaunchlab,
    #[serde(rename = "raydium_cpmm")]
    RaydiumCpmm,
    #[serde(rename = "raydium_clmm")]
    RaydiumClmm,
    #[serde(rename = "raydium_amm_v4")]
    RaydiumAmmV4,
    #[serde(rename = "orca_whirlpool")]
    OrcaWhirlpool,
    #[serde(rename = "meteora_pools")]
    MeteoraPools,
    #[serde(rename = "meteora_damm_v2")]
    MeteoraDammV2,
    #[serde(rename = "meteora_dlmm")]
    MeteoraDlmm,
    #[serde(rename = "meteora_dbc")]
    MeteoraDbc,
}

impl RawInstructionDexType {
    pub const fn as_str(self) -> &'static str {
        match self {
            Self::PumpFun => "pumpfun",
            Self::PumpSwap => "pumpswap",
            Self::RaydiumLaunchlab => "raydium_launchlab",
            Self::RaydiumCpmm => "raydium_cpmm",
            Self::RaydiumClmm => "raydium_clmm",
            Self::RaydiumAmmV4 => "raydium_amm_v4",
            Self::OrcaWhirlpool => "orca_whirlpool",
            Self::MeteoraPools => "meteora_pools",
            Self::MeteoraDammV2 => "meteora_damm_v2",
            Self::MeteoraDlmm => "meteora_dlmm",
            Self::MeteoraDbc => "meteora_dbc",
        }
    }
}