1use super::types::*;
2use once_cell::sync::Lazy;
3use serde::{Deserialize, Serialize};
4use solana_sdk::signature::Signature;
5
6#[derive(Debug, Clone, Serialize, Deserialize)]
10pub enum DexEvent {
11 PumpFunCreate(PumpFunCreateTokenEvent), PumpFunCreateV2(PumpFunCreateV2TokenEvent), PumpFunTrade(PumpFunTradeEvent), PumpFunBuy(PumpFunTradeEvent), PumpFunSell(PumpFunTradeEvent), PumpFunBuyExactSolIn(PumpFunTradeEvent), PumpFunMigrate(PumpFunMigrateEvent), PumpFeesCreateFeeSharingConfig(PumpFeesCreateFeeSharingConfigEvent),
21 PumpFeesInitializeFeeConfig(PumpFeesInitializeFeeConfigEvent),
22 PumpFeesResetFeeSharingConfig(PumpFeesResetFeeSharingConfigEvent),
23 PumpFeesRevokeFeeSharingAuthority(PumpFeesRevokeFeeSharingAuthorityEvent),
24 PumpFeesTransferFeeSharingAuthority(PumpFeesTransferFeeSharingAuthorityEvent),
25 PumpFeesUpdateAdmin(PumpFeesUpdateAdminEvent),
26 PumpFeesUpdateFeeConfig(PumpFeesUpdateFeeConfigEvent),
27 PumpFeesUpdateFeeShares(PumpFeesUpdateFeeSharesEvent),
28 PumpFeesUpsertFeeTiers(PumpFeesUpsertFeeTiersEvent),
29 PumpFunMigrateBondingCurveCreator(PumpFunMigrateBondingCurveCreatorEvent),
31 PumpFunGlobalAccount(PumpFunGlobalAccountEvent), PumpFunBondingCurveAccount(PumpFunBondingCurveAccountEvent),
33 PumpFunFeeConfigAccount(PumpFunFeeConfigAccountEvent),
34 PumpFunSharingConfigAccount(PumpFunSharingConfigAccountEvent),
35 PumpFunGlobalVolumeAccumulatorAccount(PumpFunGlobalVolumeAccumulatorAccountEvent),
36 PumpFunUserVolumeAccumulatorAccount(PumpFunUserVolumeAccumulatorAccountEvent),
37 PumpSwapTrade(PumpSwapTradeEvent), PumpSwapBuy(PumpSwapBuyEvent), PumpSwapSell(PumpSwapSellEvent), PumpSwapCreatePool(PumpSwapCreatePoolEvent), PumpSwapLiquidityAdded(PumpSwapLiquidityAdded), PumpSwapLiquidityRemoved(PumpSwapLiquidityRemoved), MeteoraDammV2Swap(MeteoraDammV2SwapEvent), MeteoraDammV2CreatePosition(MeteoraDammV2CreatePositionEvent), MeteoraDammV2ClosePosition(MeteoraDammV2ClosePositionEvent), MeteoraDammV2AddLiquidity(MeteoraDammV2AddLiquidityEvent), MeteoraDammV2RemoveLiquidity(MeteoraDammV2RemoveLiquidityEvent), BonkTrade(BonkTradeEvent),
53 BonkPoolCreate(BonkPoolCreateEvent),
54 BonkMigrateAmm(BonkMigrateAmmEvent),
55
56 RaydiumClmmSwap(RaydiumClmmSwapEvent),
58 RaydiumClmmCreatePool(RaydiumClmmCreatePoolEvent),
59 RaydiumClmmOpenPosition(RaydiumClmmOpenPositionEvent),
60 RaydiumClmmOpenPositionWithTokenExtNft(RaydiumClmmOpenPositionWithTokenExtNftEvent),
61 RaydiumClmmClosePosition(RaydiumClmmClosePositionEvent),
62 RaydiumClmmIncreaseLiquidity(RaydiumClmmIncreaseLiquidityEvent),
63 RaydiumClmmDecreaseLiquidity(RaydiumClmmDecreaseLiquidityEvent),
64 RaydiumClmmLiquidityChange(RaydiumClmmLiquidityChangeEvent),
65 RaydiumClmmConfigChange(RaydiumClmmConfigChangeEvent),
66 RaydiumClmmCreatePersonalPosition(RaydiumClmmCreatePersonalPositionEvent),
67 RaydiumClmmLiquidityCalculate(RaydiumClmmLiquidityCalculateEvent),
68 RaydiumClmmOpenLimitOrder(RaydiumClmmOpenLimitOrderEvent),
69 RaydiumClmmIncreaseLimitOrder(RaydiumClmmIncreaseLimitOrderEvent),
70 RaydiumClmmDecreaseLimitOrder(RaydiumClmmDecreaseLimitOrderEvent),
71 RaydiumClmmSettleLimitOrder(RaydiumClmmSettleLimitOrderEvent),
72 RaydiumClmmUpdateRewardInfos(RaydiumClmmUpdateRewardInfosEvent),
73 RaydiumClmmCollectFee(RaydiumClmmCollectFeeEvent),
74
75 RaydiumCpmmSwap(RaydiumCpmmSwapEvent),
77 RaydiumCpmmDeposit(RaydiumCpmmDepositEvent),
78 RaydiumCpmmWithdraw(RaydiumCpmmWithdrawEvent),
79 RaydiumCpmmInitialize(RaydiumCpmmInitializeEvent),
80
81 RaydiumAmmV4Swap(RaydiumAmmV4SwapEvent),
83 RaydiumAmmV4Deposit(RaydiumAmmV4DepositEvent),
84 RaydiumAmmV4Initialize2(RaydiumAmmV4Initialize2Event),
85 RaydiumAmmV4Withdraw(RaydiumAmmV4WithdrawEvent),
86 RaydiumAmmV4WithdrawPnl(RaydiumAmmV4WithdrawPnlEvent),
87
88 OrcaWhirlpoolSwap(OrcaWhirlpoolSwapEvent),
90 OrcaWhirlpoolLiquidityIncreased(OrcaWhirlpoolLiquidityIncreasedEvent),
91 OrcaWhirlpoolLiquidityDecreased(OrcaWhirlpoolLiquidityDecreasedEvent),
92 OrcaWhirlpoolPoolInitialized(OrcaWhirlpoolPoolInitializedEvent),
93
94 MeteoraPoolsSwap(MeteoraPoolsSwapEvent),
96 MeteoraPoolsAddLiquidity(MeteoraPoolsAddLiquidityEvent),
97 MeteoraPoolsRemoveLiquidity(MeteoraPoolsRemoveLiquidityEvent),
98 MeteoraPoolsBootstrapLiquidity(MeteoraPoolsBootstrapLiquidityEvent),
99 MeteoraPoolsPoolCreated(MeteoraPoolsPoolCreatedEvent),
100 MeteoraPoolsSetPoolFees(MeteoraPoolsSetPoolFeesEvent),
101
102 MeteoraDlmmSwap(MeteoraDlmmSwapEvent),
104 MeteoraDlmmAddLiquidity(MeteoraDlmmAddLiquidityEvent),
105 MeteoraDlmmRemoveLiquidity(MeteoraDlmmRemoveLiquidityEvent),
106 MeteoraDlmmInitializePool(MeteoraDlmmInitializePoolEvent),
107 MeteoraDlmmInitializeBinArray(MeteoraDlmmInitializeBinArrayEvent),
108 MeteoraDlmmCreatePosition(MeteoraDlmmCreatePositionEvent),
109 MeteoraDlmmClosePosition(MeteoraDlmmClosePositionEvent),
110 MeteoraDlmmClaimFee(MeteoraDlmmClaimFeeEvent),
111
112 TokenInfo(TokenInfoEvent), TokenAccount(TokenAccountEvent), NonceAccount(NonceAccountEvent), PumpSwapGlobalConfigAccount(PumpSwapGlobalConfigAccountEvent), PumpSwapPoolAccount(PumpSwapPoolAccountEvent), BlockMeta(BlockMetaEvent),
121
122 Error(String),
124}
125
126static DEFAULT_METADATA: Lazy<EventMetadata> = Lazy::new(|| EventMetadata {
128 signature: Signature::from([0u8; 64]),
129 slot: 0,
130 tx_index: 0,
131 block_time_us: 0,
132 grpc_recv_us: 0,
133 recent_blockhash: None,
134});
135
136impl DexEvent {
137 pub fn metadata(&self) -> &EventMetadata {
139 match self {
140 DexEvent::PumpFunCreate(e) => &e.metadata,
142 DexEvent::PumpFunCreateV2(e) => &e.metadata,
143 DexEvent::PumpFunTrade(e) => &e.metadata,
144 DexEvent::PumpFunBuy(e) => &e.metadata,
145 DexEvent::PumpFunSell(e) => &e.metadata,
146 DexEvent::PumpFunBuyExactSolIn(e) => &e.metadata,
147 DexEvent::PumpFunMigrate(e) => &e.metadata,
148 DexEvent::PumpFeesCreateFeeSharingConfig(e) => &e.metadata,
149 DexEvent::PumpFeesInitializeFeeConfig(e) => &e.metadata,
150 DexEvent::PumpFeesResetFeeSharingConfig(e) => &e.metadata,
151 DexEvent::PumpFeesRevokeFeeSharingAuthority(e) => &e.metadata,
152 DexEvent::PumpFeesTransferFeeSharingAuthority(e) => &e.metadata,
153 DexEvent::PumpFeesUpdateAdmin(e) => &e.metadata,
154 DexEvent::PumpFeesUpdateFeeConfig(e) => &e.metadata,
155 DexEvent::PumpFeesUpdateFeeShares(e) => &e.metadata,
156 DexEvent::PumpFeesUpsertFeeTiers(e) => &e.metadata,
157 DexEvent::PumpFunMigrateBondingCurveCreator(e) => &e.metadata,
158 DexEvent::PumpFunGlobalAccount(e) => &e.metadata,
159 DexEvent::PumpFunBondingCurveAccount(e) => &e.metadata,
160 DexEvent::PumpFunFeeConfigAccount(e) => &e.metadata,
161 DexEvent::PumpFunSharingConfigAccount(e) => &e.metadata,
162 DexEvent::PumpFunGlobalVolumeAccumulatorAccount(e) => &e.metadata,
163 DexEvent::PumpFunUserVolumeAccumulatorAccount(e) => &e.metadata,
164
165 DexEvent::PumpSwapTrade(e) => &e.metadata,
167 DexEvent::PumpSwapBuy(e) => &e.metadata,
168 DexEvent::PumpSwapSell(e) => &e.metadata,
169 DexEvent::PumpSwapCreatePool(e) => &e.metadata,
170 DexEvent::PumpSwapLiquidityAdded(e) => &e.metadata,
171 DexEvent::PumpSwapLiquidityRemoved(e) => &e.metadata,
172
173 DexEvent::MeteoraDammV2Swap(e) => &e.metadata,
175 DexEvent::MeteoraDammV2CreatePosition(e) => &e.metadata,
176 DexEvent::MeteoraDammV2ClosePosition(e) => &e.metadata,
177 DexEvent::MeteoraDammV2AddLiquidity(e) => &e.metadata,
178 DexEvent::MeteoraDammV2RemoveLiquidity(e) => &e.metadata,
179
180 DexEvent::BonkTrade(e) => &e.metadata,
182 DexEvent::BonkPoolCreate(e) => &e.metadata,
183 DexEvent::BonkMigrateAmm(e) => &e.metadata,
184
185 DexEvent::RaydiumClmmSwap(e) => &e.metadata,
187 DexEvent::RaydiumClmmCreatePool(e) => &e.metadata,
188 DexEvent::RaydiumClmmOpenPosition(e) => &e.metadata,
189 DexEvent::RaydiumClmmOpenPositionWithTokenExtNft(e) => &e.metadata,
190 DexEvent::RaydiumClmmClosePosition(e) => &e.metadata,
191 DexEvent::RaydiumClmmIncreaseLiquidity(e) => &e.metadata,
192 DexEvent::RaydiumClmmDecreaseLiquidity(e) => &e.metadata,
193 DexEvent::RaydiumClmmLiquidityChange(e) => &e.metadata,
194 DexEvent::RaydiumClmmConfigChange(e) => &e.metadata,
195 DexEvent::RaydiumClmmCreatePersonalPosition(e) => &e.metadata,
196 DexEvent::RaydiumClmmLiquidityCalculate(e) => &e.metadata,
197 DexEvent::RaydiumClmmOpenLimitOrder(e) => &e.metadata,
198 DexEvent::RaydiumClmmIncreaseLimitOrder(e) => &e.metadata,
199 DexEvent::RaydiumClmmDecreaseLimitOrder(e) => &e.metadata,
200 DexEvent::RaydiumClmmSettleLimitOrder(e) => &e.metadata,
201 DexEvent::RaydiumClmmUpdateRewardInfos(e) => &e.metadata,
202 DexEvent::RaydiumClmmCollectFee(e) => &e.metadata,
203
204 DexEvent::RaydiumCpmmSwap(e) => &e.metadata,
206 DexEvent::RaydiumCpmmDeposit(e) => &e.metadata,
207 DexEvent::RaydiumCpmmWithdraw(e) => &e.metadata,
208 DexEvent::RaydiumCpmmInitialize(e) => &e.metadata,
209
210 DexEvent::RaydiumAmmV4Swap(e) => &e.metadata,
212 DexEvent::RaydiumAmmV4Deposit(e) => &e.metadata,
213 DexEvent::RaydiumAmmV4Initialize2(e) => &e.metadata,
214 DexEvent::RaydiumAmmV4Withdraw(e) => &e.metadata,
215 DexEvent::RaydiumAmmV4WithdrawPnl(e) => &e.metadata,
216
217 DexEvent::OrcaWhirlpoolSwap(e) => &e.metadata,
219 DexEvent::OrcaWhirlpoolLiquidityIncreased(e) => &e.metadata,
220 DexEvent::OrcaWhirlpoolLiquidityDecreased(e) => &e.metadata,
221 DexEvent::OrcaWhirlpoolPoolInitialized(e) => &e.metadata,
222
223 DexEvent::MeteoraPoolsSwap(e) => &e.metadata,
225 DexEvent::MeteoraPoolsAddLiquidity(e) => &e.metadata,
226 DexEvent::MeteoraPoolsRemoveLiquidity(e) => &e.metadata,
227 DexEvent::MeteoraPoolsBootstrapLiquidity(e) => &e.metadata,
228 DexEvent::MeteoraPoolsPoolCreated(e) => &e.metadata,
229 DexEvent::MeteoraPoolsSetPoolFees(e) => &e.metadata,
230
231 DexEvent::MeteoraDlmmSwap(e) => &e.metadata,
233 DexEvent::MeteoraDlmmAddLiquidity(e) => &e.metadata,
234 DexEvent::MeteoraDlmmRemoveLiquidity(e) => &e.metadata,
235 DexEvent::MeteoraDlmmInitializePool(e) => &e.metadata,
236 DexEvent::MeteoraDlmmInitializeBinArray(e) => &e.metadata,
237 DexEvent::MeteoraDlmmCreatePosition(e) => &e.metadata,
238 DexEvent::MeteoraDlmmClosePosition(e) => &e.metadata,
239 DexEvent::MeteoraDlmmClaimFee(e) => &e.metadata,
240
241 DexEvent::TokenInfo(e) => &e.metadata,
243 DexEvent::TokenAccount(e) => &e.metadata,
244 DexEvent::NonceAccount(e) => &e.metadata,
245 DexEvent::PumpSwapGlobalConfigAccount(e) => &e.metadata,
246 DexEvent::PumpSwapPoolAccount(e) => &e.metadata,
247
248 DexEvent::BlockMeta(e) => &e.metadata,
250
251 DexEvent::Error(_) => &DEFAULT_METADATA,
253 }
254 }
255
256 pub fn metadata_mut(&mut self) -> Option<&mut EventMetadata> {
258 match self {
259 DexEvent::PumpFunCreate(e) => Some(&mut e.metadata),
260 DexEvent::PumpFunCreateV2(e) => Some(&mut e.metadata),
261 DexEvent::PumpFunTrade(e) => Some(&mut e.metadata),
262 DexEvent::PumpFunBuy(e) => Some(&mut e.metadata),
263 DexEvent::PumpFunSell(e) => Some(&mut e.metadata),
264 DexEvent::PumpFunBuyExactSolIn(e) => Some(&mut e.metadata),
265 DexEvent::PumpFunMigrate(e) => Some(&mut e.metadata),
266 DexEvent::PumpFeesCreateFeeSharingConfig(e) => Some(&mut e.metadata),
267 DexEvent::PumpFeesInitializeFeeConfig(e) => Some(&mut e.metadata),
268 DexEvent::PumpFeesResetFeeSharingConfig(e) => Some(&mut e.metadata),
269 DexEvent::PumpFeesRevokeFeeSharingAuthority(e) => Some(&mut e.metadata),
270 DexEvent::PumpFeesTransferFeeSharingAuthority(e) => Some(&mut e.metadata),
271 DexEvent::PumpFeesUpdateAdmin(e) => Some(&mut e.metadata),
272 DexEvent::PumpFeesUpdateFeeConfig(e) => Some(&mut e.metadata),
273 DexEvent::PumpFeesUpdateFeeShares(e) => Some(&mut e.metadata),
274 DexEvent::PumpFeesUpsertFeeTiers(e) => Some(&mut e.metadata),
275 DexEvent::PumpFunMigrateBondingCurveCreator(e) => Some(&mut e.metadata),
276 DexEvent::PumpFunGlobalAccount(e) => Some(&mut e.metadata),
277 DexEvent::PumpFunBondingCurveAccount(e) => Some(&mut e.metadata),
278 DexEvent::PumpFunFeeConfigAccount(e) => Some(&mut e.metadata),
279 DexEvent::PumpFunSharingConfigAccount(e) => Some(&mut e.metadata),
280 DexEvent::PumpFunGlobalVolumeAccumulatorAccount(e) => Some(&mut e.metadata),
281 DexEvent::PumpFunUserVolumeAccumulatorAccount(e) => Some(&mut e.metadata),
282 DexEvent::PumpSwapTrade(e) => Some(&mut e.metadata),
283 DexEvent::PumpSwapBuy(e) => Some(&mut e.metadata),
284 DexEvent::PumpSwapSell(e) => Some(&mut e.metadata),
285 DexEvent::PumpSwapCreatePool(e) => Some(&mut e.metadata),
286 DexEvent::PumpSwapLiquidityAdded(e) => Some(&mut e.metadata),
287 DexEvent::PumpSwapLiquidityRemoved(e) => Some(&mut e.metadata),
288 DexEvent::MeteoraDammV2Swap(e) => Some(&mut e.metadata),
289 DexEvent::MeteoraDammV2CreatePosition(e) => Some(&mut e.metadata),
290 DexEvent::MeteoraDammV2ClosePosition(e) => Some(&mut e.metadata),
291 DexEvent::MeteoraDammV2AddLiquidity(e) => Some(&mut e.metadata),
292 DexEvent::MeteoraDammV2RemoveLiquidity(e) => Some(&mut e.metadata),
293 DexEvent::BonkTrade(e) => Some(&mut e.metadata),
294 DexEvent::BonkPoolCreate(e) => Some(&mut e.metadata),
295 DexEvent::BonkMigrateAmm(e) => Some(&mut e.metadata),
296 DexEvent::RaydiumClmmSwap(e) => Some(&mut e.metadata),
297 DexEvent::RaydiumClmmCreatePool(e) => Some(&mut e.metadata),
298 DexEvent::RaydiumClmmOpenPosition(e) => Some(&mut e.metadata),
299 DexEvent::RaydiumClmmOpenPositionWithTokenExtNft(e) => Some(&mut e.metadata),
300 DexEvent::RaydiumClmmClosePosition(e) => Some(&mut e.metadata),
301 DexEvent::RaydiumClmmIncreaseLiquidity(e) => Some(&mut e.metadata),
302 DexEvent::RaydiumClmmDecreaseLiquidity(e) => Some(&mut e.metadata),
303 DexEvent::RaydiumClmmLiquidityChange(e) => Some(&mut e.metadata),
304 DexEvent::RaydiumClmmConfigChange(e) => Some(&mut e.metadata),
305 DexEvent::RaydiumClmmCreatePersonalPosition(e) => Some(&mut e.metadata),
306 DexEvent::RaydiumClmmLiquidityCalculate(e) => Some(&mut e.metadata),
307 DexEvent::RaydiumClmmOpenLimitOrder(e) => Some(&mut e.metadata),
308 DexEvent::RaydiumClmmIncreaseLimitOrder(e) => Some(&mut e.metadata),
309 DexEvent::RaydiumClmmDecreaseLimitOrder(e) => Some(&mut e.metadata),
310 DexEvent::RaydiumClmmSettleLimitOrder(e) => Some(&mut e.metadata),
311 DexEvent::RaydiumClmmUpdateRewardInfos(e) => Some(&mut e.metadata),
312 DexEvent::RaydiumClmmCollectFee(e) => Some(&mut e.metadata),
313 DexEvent::RaydiumCpmmSwap(e) => Some(&mut e.metadata),
314 DexEvent::RaydiumCpmmDeposit(e) => Some(&mut e.metadata),
315 DexEvent::RaydiumCpmmWithdraw(e) => Some(&mut e.metadata),
316 DexEvent::RaydiumCpmmInitialize(e) => Some(&mut e.metadata),
317 DexEvent::RaydiumAmmV4Swap(e) => Some(&mut e.metadata),
318 DexEvent::RaydiumAmmV4Deposit(e) => Some(&mut e.metadata),
319 DexEvent::RaydiumAmmV4Initialize2(e) => Some(&mut e.metadata),
320 DexEvent::RaydiumAmmV4Withdraw(e) => Some(&mut e.metadata),
321 DexEvent::RaydiumAmmV4WithdrawPnl(e) => Some(&mut e.metadata),
322 DexEvent::OrcaWhirlpoolSwap(e) => Some(&mut e.metadata),
323 DexEvent::OrcaWhirlpoolLiquidityIncreased(e) => Some(&mut e.metadata),
324 DexEvent::OrcaWhirlpoolLiquidityDecreased(e) => Some(&mut e.metadata),
325 DexEvent::OrcaWhirlpoolPoolInitialized(e) => Some(&mut e.metadata),
326 DexEvent::MeteoraPoolsSwap(e) => Some(&mut e.metadata),
327 DexEvent::MeteoraPoolsAddLiquidity(e) => Some(&mut e.metadata),
328 DexEvent::MeteoraPoolsRemoveLiquidity(e) => Some(&mut e.metadata),
329 DexEvent::MeteoraPoolsBootstrapLiquidity(e) => Some(&mut e.metadata),
330 DexEvent::MeteoraPoolsPoolCreated(e) => Some(&mut e.metadata),
331 DexEvent::MeteoraPoolsSetPoolFees(e) => Some(&mut e.metadata),
332 DexEvent::MeteoraDlmmSwap(e) => Some(&mut e.metadata),
333 DexEvent::MeteoraDlmmAddLiquidity(e) => Some(&mut e.metadata),
334 DexEvent::MeteoraDlmmRemoveLiquidity(e) => Some(&mut e.metadata),
335 DexEvent::MeteoraDlmmInitializePool(e) => Some(&mut e.metadata),
336 DexEvent::MeteoraDlmmInitializeBinArray(e) => Some(&mut e.metadata),
337 DexEvent::MeteoraDlmmCreatePosition(e) => Some(&mut e.metadata),
338 DexEvent::MeteoraDlmmClosePosition(e) => Some(&mut e.metadata),
339 DexEvent::MeteoraDlmmClaimFee(e) => Some(&mut e.metadata),
340 DexEvent::TokenInfo(e) => Some(&mut e.metadata),
341 DexEvent::TokenAccount(e) => Some(&mut e.metadata),
342 DexEvent::NonceAccount(e) => Some(&mut e.metadata),
343 DexEvent::PumpSwapGlobalConfigAccount(e) => Some(&mut e.metadata),
344 DexEvent::PumpSwapPoolAccount(e) => Some(&mut e.metadata),
345 DexEvent::BlockMeta(e) => Some(&mut e.metadata),
346 DexEvent::Error(_) => None,
347 }
348 }
349}