sol_parser_sdk/logs/
mod.rs

1//! Log parser module
2//!
3//! Contains log parsers for all DEX protocols
4
5// Allow dead code for fallback text parsers (kept for future use)
6#![allow(dead_code)]
7#![allow(unused_imports)]
8#![allow(unused_variables)]
9
10pub mod discriminator_lut;
11pub mod meteora_amm;
12pub mod meteora_damm;
13pub mod meteora_dlmm;
14pub mod optimized_matcher;
15pub mod orca_whirlpool;
16pub mod perf_hints;
17pub mod pump_amm;
18pub mod pump;
19pub mod raydium_amm;
20pub mod raydium_clmm;
21pub mod raydium_cpmm;
22pub mod raydium_launchpad;
23pub mod utils;
24pub mod zero_copy_parser;
25
26// 导出关键的 utils 函数
27pub use utils::extract_discriminator_fast;
28pub use zero_copy_parser::parse_pumpfun_trade;
29pub use discriminator_lut::{lookup_discriminator, discriminator_to_name, discriminator_to_protocol, parse_with_discriminator};
30
31// 重新导出主要解析函数
32pub use meteora_amm::parse_log as parse_meteora_amm_log;
33pub use meteora_damm::parse_log as parse_meteora_damm_log;
34pub use meteora_dlmm::parse_log as parse_meteora_dlmm_log;
35pub use orca_whirlpool::parse_log as parse_orca_whirlpool_log;
36pub use pump_amm::parse_log as parse_pump_amm_log;
37pub use pump::parse_log as parse_pumpfun_log;
38pub use raydium_amm::parse_log as parse_raydium_amm_log;
39pub use raydium_clmm::parse_log as parse_raydium_clmm_log;
40pub use raydium_cpmm::parse_log as parse_raydium_cpmm_log;
41pub use raydium_launchpad::parse_log as parse_raydium_launchpad_log;
42
43// 重新导出工具函数
44pub use utils::*;
45
46use crate::core::events::DexEvent;
47use solana_sdk::signature::Signature;
48use crate::core::clock::now_us;
49
50/// 主日志解析入口函数
51#[inline(always)]  // 零延迟优化：内联热路径
52pub fn parse_log(
53    log: &str,
54    signature: Signature,
55    slot: u64,
56    tx_index: u64,
57    block_time_us: Option<i64>,
58    grpc_recv_us: i64,
59    event_type_filter: Option<&crate::grpc::types::EventTypeFilter>,
60    is_created_buy: bool,
61) -> Option<DexEvent> {
62    optimized_matcher::parse_log_optimized(
63        log,
64        signature,
65        slot,
66        tx_index,
67        block_time_us,
68        grpc_recv_us,
69        event_type_filter,
70        is_created_buy,
71    )
72}
73
74/// 统一的日志解析入口函数（优化版本）
75#[inline(always)]  // 零延迟优化：内联热路径
76pub fn parse_log_unified(
77    log: &str,
78    signature: Signature,
79    slot: u64,
80    block_time_us: Option<i64>,
81) -> Option<DexEvent> {
82    let grpc_recv_us = now_us();
83    optimized_matcher::parse_log_optimized(
84        log,
85        signature,
86        slot,
87        0,
88        block_time_us,
89        grpc_recv_us,
90        None,
91        false,
92    )
93}
sol_parser_sdk/logs/mod.rs

sol_parser_sdk/logs/
mod.rs
