solana-streamer-sdk 1.3.0

A lightweight Rust library for real-time event streaming from Solana DEX trading programs. Supports PumpFun, PumpSwap, Bonk, 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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211

use crate::streaming::event_parser::common::EventMetadata;
use crate::streaming::event_parser::core::account_event_parser::{
    NonceAccountEvent, TokenAccountEvent, TokenInfoEvent,
};
use crate::streaming::event_parser::core::common_event_parser::{
    SetComputeUnitLimitEvent, SetComputeUnitPriceEvent,
};
use crate::streaming::event_parser::protocols::block::block_meta_event::BlockMetaEvent;
use crate::streaming::event_parser::protocols::bonk::events::*;
use crate::streaming::event_parser::protocols::meteora_damm_v2::events::*;
use crate::streaming::event_parser::protocols::pumpfun::events::*;
use crate::streaming::event_parser::protocols::pumpswap::events::*;
use crate::streaming::event_parser::protocols::raydium_amm_v4::events::*;
use crate::streaming::event_parser::protocols::raydium_clmm::events::*;
use crate::streaming::event_parser::protocols::raydium_cpmm::events::*;
use serde::{Deserialize, Serialize};
use std::fmt::Debug;

/// Unified Event Enum - Replaces the trait-based approach with a type-safe enum
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum DexEvent {
    // Bonk events
    BonkTradeEvent(BonkTradeEvent),
    BonkPoolCreateEvent(BonkPoolCreateEvent),
    BonkMigrateToAmmEvent(BonkMigrateToAmmEvent),
    BonkMigrateToCpswapEvent(BonkMigrateToCpswapEvent),
    BonkPoolStateAccountEvent(BonkPoolStateAccountEvent),
    BonkGlobalConfigAccountEvent(BonkGlobalConfigAccountEvent),
    BonkPlatformConfigAccountEvent(BonkPlatformConfigAccountEvent),

    // PumpFun events
    PumpFunCreateTokenEvent(PumpFunCreateTokenEvent),
    PumpFunCreateV2TokenEvent(PumpFunCreateV2TokenEvent),
    PumpFunTradeEvent(PumpFunTradeEvent),
    PumpFunMigrateEvent(PumpFunMigrateEvent),
    PumpFunBondingCurveAccountEvent(PumpFunBondingCurveAccountEvent),
    PumpFunGlobalAccountEvent(PumpFunGlobalAccountEvent),

    // PumpSwap events
    PumpSwapBuyEvent(PumpSwapBuyEvent),
    PumpSwapSellEvent(PumpSwapSellEvent),
    PumpSwapCreatePoolEvent(PumpSwapCreatePoolEvent),
    PumpSwapDepositEvent(PumpSwapDepositEvent),
    PumpSwapWithdrawEvent(PumpSwapWithdrawEvent),
    PumpSwapGlobalConfigAccountEvent(PumpSwapGlobalConfigAccountEvent),
    PumpSwapPoolAccountEvent(PumpSwapPoolAccountEvent),

    // Raydium AMM V4 events
    RaydiumAmmV4SwapEvent(RaydiumAmmV4SwapEvent),
    RaydiumAmmV4DepositEvent(RaydiumAmmV4DepositEvent),
    RaydiumAmmV4WithdrawEvent(RaydiumAmmV4WithdrawEvent),
    RaydiumAmmV4WithdrawPnlEvent(RaydiumAmmV4WithdrawPnlEvent),
    RaydiumAmmV4Initialize2Event(RaydiumAmmV4Initialize2Event),
    RaydiumAmmV4AmmInfoAccountEvent(RaydiumAmmV4AmmInfoAccountEvent),

    // Raydium CLMM events
    RaydiumClmmSwapEvent(RaydiumClmmSwapEvent),
    RaydiumClmmSwapV2Event(RaydiumClmmSwapV2Event),
    RaydiumClmmClosePositionEvent(RaydiumClmmClosePositionEvent),
    RaydiumClmmIncreaseLiquidityV2Event(RaydiumClmmIncreaseLiquidityV2Event),
    RaydiumClmmDecreaseLiquidityV2Event(RaydiumClmmDecreaseLiquidityV2Event),
    RaydiumClmmCreatePoolEvent(RaydiumClmmCreatePoolEvent),
    RaydiumClmmOpenPositionWithToken22NftEvent(RaydiumClmmOpenPositionWithToken22NftEvent),
    RaydiumClmmOpenPositionV2Event(RaydiumClmmOpenPositionV2Event),
    RaydiumClmmAmmConfigAccountEvent(RaydiumClmmAmmConfigAccountEvent),
    RaydiumClmmPoolStateAccountEvent(RaydiumClmmPoolStateAccountEvent),
    RaydiumClmmTickArrayStateAccountEvent(RaydiumClmmTickArrayStateAccountEvent),

    // Raydium CPMM events
    RaydiumCpmmSwapEvent(RaydiumCpmmSwapEvent),
    RaydiumCpmmDepositEvent(RaydiumCpmmDepositEvent),
    RaydiumCpmmWithdrawEvent(RaydiumCpmmWithdrawEvent),
    RaydiumCpmmInitializeEvent(RaydiumCpmmInitializeEvent),
    RaydiumCpmmAmmConfigAccountEvent(RaydiumCpmmAmmConfigAccountEvent),
    RaydiumCpmmPoolStateAccountEvent(RaydiumCpmmPoolStateAccountEvent),

    // Meteora DAMM v2 events
    MeteoraDammV2SwapEvent(MeteoraDammV2SwapEvent),
    MeteoraDammV2Swap2Event(MeteoraDammV2Swap2Event),
    MeteoraDammV2InitializePoolEvent(MeteoraDammV2InitializePoolEvent),
    MeteoraDammV2InitializeCustomizablePoolEvent(MeteoraDammV2InitializeCustomizablePoolEvent),
    MeteoraDammV2InitializePoolWithDynamicConfigEvent(MeteoraDammV2InitializePoolWithDynamicConfigEvent),

    // Common events
    TokenAccountEvent(TokenAccountEvent),
    NonceAccountEvent(NonceAccountEvent),
    TokenInfoEvent(TokenInfoEvent),
    BlockMetaEvent(BlockMetaEvent),
    SetComputeUnitLimitEvent(SetComputeUnitLimitEvent),
    SetComputeUnitPriceEvent(SetComputeUnitPriceEvent),
}

impl DexEvent {
    pub fn metadata(&self) -> &EventMetadata {
        match self {
            DexEvent::BonkTradeEvent(e) => &e.metadata,
            DexEvent::BonkPoolCreateEvent(e) => &e.metadata,
            DexEvent::BonkMigrateToAmmEvent(e) => &e.metadata,
            DexEvent::BonkMigrateToCpswapEvent(e) => &e.metadata,
            DexEvent::BonkPoolStateAccountEvent(e) => &e.metadata,
            DexEvent::BonkGlobalConfigAccountEvent(e) => &e.metadata,
            DexEvent::BonkPlatformConfigAccountEvent(e) => &e.metadata,
            DexEvent::PumpFunCreateTokenEvent(e) => &e.metadata,
            DexEvent::PumpFunCreateV2TokenEvent(e) => &e.metadata,
            DexEvent::PumpFunTradeEvent(e) => &e.metadata,
            DexEvent::PumpFunMigrateEvent(e) => &e.metadata,
            DexEvent::PumpFunBondingCurveAccountEvent(e) => &e.metadata,
            DexEvent::PumpFunGlobalAccountEvent(e) => &e.metadata,
            DexEvent::PumpSwapBuyEvent(e) => &e.metadata,
            DexEvent::PumpSwapSellEvent(e) => &e.metadata,
            DexEvent::PumpSwapCreatePoolEvent(e) => &e.metadata,
            DexEvent::PumpSwapDepositEvent(e) => &e.metadata,
            DexEvent::PumpSwapWithdrawEvent(e) => &e.metadata,
            DexEvent::PumpSwapGlobalConfigAccountEvent(e) => &e.metadata,
            DexEvent::PumpSwapPoolAccountEvent(e) => &e.metadata,
            DexEvent::RaydiumAmmV4SwapEvent(e) => &e.metadata,
            DexEvent::RaydiumAmmV4DepositEvent(e) => &e.metadata,
            DexEvent::RaydiumAmmV4WithdrawEvent(e) => &e.metadata,
            DexEvent::RaydiumAmmV4WithdrawPnlEvent(e) => &e.metadata,
            DexEvent::RaydiumAmmV4Initialize2Event(e) => &e.metadata,
            DexEvent::RaydiumAmmV4AmmInfoAccountEvent(e) => &e.metadata,
            DexEvent::RaydiumClmmSwapEvent(e) => &e.metadata,
            DexEvent::RaydiumClmmSwapV2Event(e) => &e.metadata,
            DexEvent::RaydiumClmmClosePositionEvent(e) => &e.metadata,
            DexEvent::RaydiumClmmIncreaseLiquidityV2Event(e) => &e.metadata,
            DexEvent::RaydiumClmmDecreaseLiquidityV2Event(e) => &e.metadata,
            DexEvent::RaydiumClmmCreatePoolEvent(e) => &e.metadata,
            DexEvent::RaydiumClmmOpenPositionWithToken22NftEvent(e) => &e.metadata,
            DexEvent::RaydiumClmmOpenPositionV2Event(e) => &e.metadata,
            DexEvent::RaydiumClmmAmmConfigAccountEvent(e) => &e.metadata,
            DexEvent::RaydiumClmmPoolStateAccountEvent(e) => &e.metadata,
            DexEvent::RaydiumClmmTickArrayStateAccountEvent(e) => &e.metadata,
            DexEvent::RaydiumCpmmSwapEvent(e) => &e.metadata,
            DexEvent::RaydiumCpmmDepositEvent(e) => &e.metadata,
            DexEvent::RaydiumCpmmWithdrawEvent(e) => &e.metadata,
            DexEvent::RaydiumCpmmInitializeEvent(e) => &e.metadata,
            DexEvent::RaydiumCpmmAmmConfigAccountEvent(e) => &e.metadata,
            DexEvent::RaydiumCpmmPoolStateAccountEvent(e) => &e.metadata,
            DexEvent::MeteoraDammV2SwapEvent(e) => &e.metadata,
            DexEvent::MeteoraDammV2Swap2Event(e) => &e.metadata,
            DexEvent::MeteoraDammV2InitializePoolEvent(e) => &e.metadata,
            DexEvent::MeteoraDammV2InitializeCustomizablePoolEvent(e) => &e.metadata,
            DexEvent::MeteoraDammV2InitializePoolWithDynamicConfigEvent(e) => &e.metadata,
            DexEvent::TokenAccountEvent(e) => &e.metadata,
            DexEvent::NonceAccountEvent(e) => &e.metadata,
            DexEvent::TokenInfoEvent(e) => &e.metadata,
            DexEvent::BlockMetaEvent(e) => &e.metadata,
            DexEvent::SetComputeUnitLimitEvent(e) => &e.metadata,
            DexEvent::SetComputeUnitPriceEvent(e) => &e.metadata,
        }
    }

    pub fn metadata_mut(&mut self) -> &mut EventMetadata {
        match self {
            DexEvent::BonkTradeEvent(e) => &mut e.metadata,
            DexEvent::BonkPoolCreateEvent(e) => &mut e.metadata,
            DexEvent::BonkMigrateToAmmEvent(e) => &mut e.metadata,
            DexEvent::BonkMigrateToCpswapEvent(e) => &mut e.metadata,
            DexEvent::BonkPoolStateAccountEvent(e) => &mut e.metadata,
            DexEvent::BonkGlobalConfigAccountEvent(e) => &mut e.metadata,
            DexEvent::BonkPlatformConfigAccountEvent(e) => &mut e.metadata,
            DexEvent::PumpFunCreateTokenEvent(e) => &mut e.metadata,
            DexEvent::PumpFunCreateV2TokenEvent(e) => &mut e.metadata,
            DexEvent::PumpFunTradeEvent(e) => &mut e.metadata,
            DexEvent::PumpFunMigrateEvent(e) => &mut e.metadata,
            DexEvent::PumpFunBondingCurveAccountEvent(e) => &mut e.metadata,
            DexEvent::PumpFunGlobalAccountEvent(e) => &mut e.metadata,
            DexEvent::PumpSwapBuyEvent(e) => &mut e.metadata,
            DexEvent::PumpSwapSellEvent(e) => &mut e.metadata,
            DexEvent::PumpSwapCreatePoolEvent(e) => &mut e.metadata,
            DexEvent::PumpSwapDepositEvent(e) => &mut e.metadata,
            DexEvent::PumpSwapWithdrawEvent(e) => &mut e.metadata,
            DexEvent::PumpSwapGlobalConfigAccountEvent(e) => &mut e.metadata,
            DexEvent::PumpSwapPoolAccountEvent(e) => &mut e.metadata,
            DexEvent::RaydiumAmmV4SwapEvent(e) => &mut e.metadata,
            DexEvent::RaydiumAmmV4DepositEvent(e) => &mut e.metadata,
            DexEvent::RaydiumAmmV4WithdrawEvent(e) => &mut e.metadata,
            DexEvent::RaydiumAmmV4WithdrawPnlEvent(e) => &mut e.metadata,
            DexEvent::RaydiumAmmV4Initialize2Event(e) => &mut e.metadata,
            DexEvent::RaydiumAmmV4AmmInfoAccountEvent(e) => &mut e.metadata,
            DexEvent::RaydiumClmmSwapEvent(e) => &mut e.metadata,
            DexEvent::RaydiumClmmSwapV2Event(e) => &mut e.metadata,
            DexEvent::RaydiumClmmClosePositionEvent(e) => &mut e.metadata,
            DexEvent::RaydiumClmmIncreaseLiquidityV2Event(e) => &mut e.metadata,
            DexEvent::RaydiumClmmDecreaseLiquidityV2Event(e) => &mut e.metadata,
            DexEvent::RaydiumClmmCreatePoolEvent(e) => &mut e.metadata,
            DexEvent::RaydiumClmmOpenPositionWithToken22NftEvent(e) => &mut e.metadata,
            DexEvent::RaydiumClmmOpenPositionV2Event(e) => &mut e.metadata,
            DexEvent::RaydiumClmmAmmConfigAccountEvent(e) => &mut e.metadata,
            DexEvent::RaydiumClmmPoolStateAccountEvent(e) => &mut e.metadata,
            DexEvent::RaydiumClmmTickArrayStateAccountEvent(e) => &mut e.metadata,
            DexEvent::RaydiumCpmmSwapEvent(e) => &mut e.metadata,
            DexEvent::RaydiumCpmmDepositEvent(e) => &mut e.metadata,
            DexEvent::RaydiumCpmmWithdrawEvent(e) => &mut e.metadata,
            DexEvent::RaydiumCpmmInitializeEvent(e) => &mut e.metadata,
            DexEvent::RaydiumCpmmAmmConfigAccountEvent(e) => &mut e.metadata,
            DexEvent::RaydiumCpmmPoolStateAccountEvent(e) => &mut e.metadata,
            DexEvent::MeteoraDammV2SwapEvent(e) => &mut e.metadata,
            DexEvent::MeteoraDammV2Swap2Event(e) => &mut e.metadata,
            DexEvent::MeteoraDammV2InitializePoolEvent(e) => &mut e.metadata,
            DexEvent::MeteoraDammV2InitializeCustomizablePoolEvent(e) => &mut e.metadata,
            DexEvent::MeteoraDammV2InitializePoolWithDynamicConfigEvent(e) => &mut e.metadata,
            DexEvent::TokenAccountEvent(e) => &mut e.metadata,
            DexEvent::NonceAccountEvent(e) => &mut e.metadata,
            DexEvent::TokenInfoEvent(e) => &mut e.metadata,
            DexEvent::BlockMetaEvent(e) => &mut e.metadata,
            DexEvent::SetComputeUnitLimitEvent(e) => &mut e.metadata,
            DexEvent::SetComputeUnitPriceEvent(e) => &mut e.metadata,
        }
    }
}