Revert "fix: correct CPI log merging for multiple swaps in single transaction"

2026-08-14 01:18:04 +00:00 · 2025-12-14 16:26:40 +08:00
parent cfc0d48b5c
commit c40a86a0aa
20 changed files with 1140 additions and 29 deletions
@@ -0,0 +1,117 @@
+use solana_streamer_sdk::streaming::{
+    event_parser::{
+        protocols::meteora_dlmm::parser::METEORA_DLMM_PROGRAM_ID, DexEvent, Protocol,
+    },
+    grpc::ClientConfig,
+    yellowstone_grpc::{AccountFilter, TransactionFilter},
+    YellowstoneGrpc,
+};
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    println!("开始 Meteora DLMM 账户数据订阅示例...");
+    subscribe_meteora_dlmm_accounts().await?;
+    Ok(())
+}
+
+async fn subscribe_meteora_dlmm_accounts() -> Result<(), Box<dyn std::error::Error>> {
+    println!("订阅 Meteora DLMM 账户数据...");
+
+    // 创建客户端配置
+    let mut config: ClientConfig = ClientConfig::default();
+    // 启用性能监控（可选，有性能开销）
+    config.enable_metrics = true;
+    let grpc = YellowstoneGrpc::new_with_config(
+        "https://solana-yellowstone-grpc.publicnode.com:443".to_string(),
+        None,
+        config,
+    )?;
+
+    println!("gRPC 客户端创建成功");
+
+    let callback = create_event_callback();
+
+    // 只订阅 Meteora DLMM 协议
+    let protocols = vec![Protocol::MeteoraDlmm];
+
+    println!("监控协议: {:?}", protocols);
+
+    // 账户过滤器 - 订阅 Meteora DLMM 程序拥有的账户
+    let account_filter = AccountFilter {
+        account: vec![],
+        owner: vec![METEORA_DLMM_PROGRAM_ID.to_string()],
+        filters: vec![],
+    };
+
+    // 交易过滤器（可选，如果只想订阅账户数据，可以留空）
+    let transaction_filter = TransactionFilter {
+        account_include: vec![METEORA_DLMM_PROGRAM_ID.to_string()],
+        account_exclude: vec![],
+        account_required: vec![],
+    };
+
+    // 事件类型过滤器 - 只订阅账户事件
+    use solana_streamer_sdk::streaming::event_parser::common::EventType;
+    use solana_streamer_sdk::streaming::event_parser::common::filter::EventTypeFilter;
+    let event_type_filter = Some(EventTypeFilter {
+        include: vec![EventType::AccountMeteoraDlmmLbPair],
+    });
+
+    println!("开始监听事件，按 Ctrl+C 停止...");
+    println!("监控程序: {}", METEORA_DLMM_PROGRAM_ID);
+
+    println!("开始订阅...");
+
+    grpc.subscribe_events_immediate(
+        protocols,
+        None,
+        vec![transaction_filter],
+        vec![account_filter],
+        event_type_filter,
+        None,
+        callback,
+    )
+    .await?;
+
+    // 支持 stop 方法，测试代码 - 异步1000秒之后停止
+    let grpc_clone = grpc.clone();
+    tokio::spawn(async move {
+        tokio::time::sleep(std::time::Duration::from_secs(1000)).await;
+        grpc_clone.stop().await;
+    });
+
+    println!("等待 Ctrl+C 停止...");
+    tokio::signal::ctrl_c().await?;
+
+    Ok(())
+}
+
+fn create_event_callback() -> impl Fn(DexEvent) {
+    |event: DexEvent| {
+        println!(
+            "🎉 事件接收! 类型: {:?}, slot: {:?}",
+            event.metadata().event_type,
+            event.metadata().slot
+        );
+        match event {
+            DexEvent::MeteoraDlmmLbPairAccountEvent(e) => {
+                println!("=== Meteora DLMM LbPair 账户更新 ===");
+                println!("账户地址: {}", e.pubkey);
+                println!("Token X Mint: {}", e.lb_pair.token_x_mint);
+                println!("Token Y Mint: {}", e.lb_pair.token_y_mint);
+                println!("Active ID: {}", e.lb_pair.active_id);
+                println!("Bin Step: {}", e.lb_pair.bin_step);
+                println!("Status: {}", e.lb_pair.status);
+                println!("Reserve X: {}", e.lb_pair.reserve_x);
+                println!("Reserve Y: {}", e.lb_pair.reserve_y);
+                println!("Protocol Fee X: {}", e.lb_pair.protocol_fee.amount_x);
+                println!("Protocol Fee Y: {}", e.lb_pair.protocol_fee.amount_y);
+                println!("Last Updated At: {}", e.lb_pair.last_updated_at);
+                println!("=====================================");
+            }
+            _ => {
+                println!("其他事件: {:?}", event);
+            }
+        }
+    }
+}
@@ -0,0 +1,158 @@
+use solana_streamer_sdk::streaming::{
+    event_parser::{
+        protocols::raydium_clmm::parser::RAYDIUM_CLMM_PROGRAM_ID, DexEvent, Protocol,
+    },
+    grpc::ClientConfig,
+    yellowstone_grpc::{AccountFilter, TransactionFilter},
+    YellowstoneGrpc,
+};
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    // 初始化日志系统（可选）
+    // env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("info")).init();
+    
+    println!("开始 Raydium CLMM TickArrayBitmapExtension 账户数据订阅示例...");
+    subscribe_raydium_clmm_bitmap_extension().await?;
+    Ok(())
+}
+
+async fn subscribe_raydium_clmm_bitmap_extension() -> Result<(), Box<dyn std::error::Error>> {
+    println!("订阅 Raydium CLMM TickArrayBitmapExtension 账户数据...");
+
+    // 创建客户端配置
+    let mut config: ClientConfig = ClientConfig::default();
+    // 启用性能监控（可选，有性能开销）
+    config.enable_metrics = true;
+    let grpc = YellowstoneGrpc::new_with_config(
+        "https://solana-yellowstone-grpc.publicnode.com:443".to_string(),
+        None,
+        config,
+    )?;
+
+    println!("gRPC 客户端创建成功");
+
+    let callback = create_event_callback();
+
+    // 只订阅 Raydium CLMM 协议
+    let protocols = vec![Protocol::RaydiumClmm];
+
+    println!("监控协议: {:?}", protocols);
+
+    // 账户过滤器 - 订阅 Raydium CLMM 程序拥有的账户
+    let account_filter = AccountFilter {
+        account: vec![],
+        owner: vec![RAYDIUM_CLMM_PROGRAM_ID.to_string()],
+        filters: vec![],
+    };
+
+    // 交易过滤器（可选，如果只想订阅账户数据，可以留空）
+    let transaction_filter = TransactionFilter {
+        account_include: vec![],
+        account_exclude: vec![],
+        account_required: vec![],
+    };
+
+    // 事件类型过滤器 - 只订阅 TickArrayBitmapExtension 账户事件
+    use solana_streamer_sdk::streaming::event_parser::common::EventType;
+    use solana_streamer_sdk::streaming::event_parser::common::filter::EventTypeFilter;
+    let event_type_filter = Some(EventTypeFilter {
+        include: vec![EventType::AccountRaydiumClmmTickArrayBitmapExtension],
+    });
+
+    println!("开始监听事件，按 Ctrl+C 停止...");
+    println!("监控程序: {}", RAYDIUM_CLMM_PROGRAM_ID);
+
+    println!("开始订阅...");
+
+    grpc.subscribe_events_immediate(
+        protocols,
+        None,
+        vec![transaction_filter],
+        vec![account_filter],
+        event_type_filter,
+        None,
+        callback,
+    )
+    .await?;
+
+    // 支持 stop 方法，测试代码 - 异步1000秒之后停止
+    let grpc_clone = grpc.clone();
+    tokio::spawn(async move {
+        tokio::time::sleep(std::time::Duration::from_secs(1000)).await;
+        grpc_clone.stop().await;
+    });
+
+    println!("等待 Ctrl+C 停止...");
+    tokio::signal::ctrl_c().await?;
+
+    Ok(())
+}
+
+fn create_event_callback() -> impl Fn(DexEvent) {
+    |event: DexEvent| {
+        match event {
+            DexEvent::RaydiumClmmTickArrayBitmapExtensionAccountEvent(e) => {
+                println!("=== Raydium CLMM TickArrayBitmapExtension 账户更新 ===");
+                println!("账户地址: {}", e.pubkey);
+                println!("Pool ID: {}", e.tick_array_bitmap_extension.pool_id);
+                println!("Executable: {}", e.executable);
+                println!("Lamports: {}", e.lamports);
+                println!("Owner: {}", e.owner);
+                println!("Rent Epoch: {}", e.rent_epoch);
+                println!("Slot: {}", e.metadata.slot);
+                println!("Signature: {}", e.metadata.signature);
+                
+                // 由于使用了 #[repr(C, packed)]，需要先复制数据到本地变量
+                let positive_bitmap = e.tick_array_bitmap_extension.positive_tick_array_bitmap;
+                let negative_bitmap = e.tick_array_bitmap_extension.negative_tick_array_bitmap;
+                
+                // 打印 positive_tick_array_bitmap 的统计信息
+                let positive_non_zero_count = positive_bitmap
+                    .iter()
+                    .flatten()
+                    .filter(|&&x| x != 0)
+                    .count();
+                println!("Positive Tick Array Bitmap: {} 个非零值", positive_non_zero_count);
+                
+                // 打印 negative_tick_array_bitmap 的统计信息
+                let negative_non_zero_count = negative_bitmap
+                    .iter()
+                    .flatten()
+                    .filter(|&&x| x != 0)
+                    .count();
+                println!("Negative Tick Array Bitmap: {} 个非零值", negative_non_zero_count);
+                
+                // 可选：打印前几个非零值作为示例
+                println!("\nPositive Bitmap 前 5 个非零值:");
+                let mut count = 0;
+                for (i, row) in positive_bitmap.iter().enumerate() {
+                    for (j, &value) in row.iter().enumerate() {
+                        if value != 0 && count < 5 {
+                            println!("  [{}][{}] = {}", i, j, value);
+                            count += 1;
+                        }
+                    }
+                }
+                
+                println!("\nNegative Bitmap 前 5 个非零值:");
+                let mut count = 0;
+                for (i, row) in negative_bitmap.iter().enumerate() {
+                    for (j, &value) in row.iter().enumerate() {
+                        if value != 0 && count < 5 {
+                            println!("  [{}][{}] = {}", i, j, value);
+                            count += 1;
+                        }
+                    }
+                }
+                
+                println!("=====================================\n");
+            }
+            _ => {
+                // 其他事件类型，可以忽略或记录
+                // println!("其他事件类型: {:?}", event.metadata().event_type);
+            }
+        }
+    }
+}
+
@@ -0,0 +1,134 @@
+use solana_streamer_sdk::streaming::{
+    event_parser::{
+        protocols::whirlpool::parser::WHIRLPOOL_PROGRAM_ID, DexEvent, Protocol,
+    },
+    grpc::ClientConfig,
+    yellowstone_grpc::{AccountFilter, TransactionFilter},
+    YellowstoneGrpc,
+};
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    // 初始化日志系统，设置日志级别为 debug 以便查看详细信息
+    //env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("debug")).init();
+    
+    println!("开始 Whirlpool 账户数据订阅示例...");
+    subscribe_whirlpool_accounts().await?;
+    Ok(())
+}
+
+async fn subscribe_whirlpool_accounts() -> Result<(), Box<dyn std::error::Error>> {
+    println!("订阅 Whirlpool 账户数据...");
+
+    // 创建客户端配置
+    let mut config: ClientConfig = ClientConfig::default();
+    // 启用性能监控（可选，有性能开销）
+    config.enable_metrics = true;
+    let grpc = YellowstoneGrpc::new_with_config(
+        "https://solana-yellowstone-grpc.publicnode.com:443".to_string(),
+        None,
+        config,
+    )?;
+
+    println!("gRPC 客户端创建成功");
+
+    let callback = create_event_callback();
+
+    // 只订阅 Whirlpool 协议
+    let protocols = vec![Protocol::Whirlpool];
+
+    println!("监控协议: {:?}", protocols);
+
+    // 账户过滤器 - 订阅 Whirlpool 程序拥有的账户
+    let account_filter = AccountFilter {
+        account: vec![],
+        owner: vec![WHIRLPOOL_PROGRAM_ID.to_string()],
+        filters: vec![],
+    };
+
+    // 交易过滤器（可选，如果只想订阅账户数据，可以留空）
+    let transaction_filter = TransactionFilter {
+        account_include: vec![WHIRLPOOL_PROGRAM_ID.to_string()],
+        account_exclude: vec![],
+        account_required: vec![],
+    };
+
+    // 事件类型过滤器 - 只订阅账户事件
+    use solana_streamer_sdk::streaming::event_parser::common::EventType;
+    use solana_streamer_sdk::streaming::event_parser::common::filter::EventTypeFilter;
+    let event_type_filter = Some(EventTypeFilter {
+        include: vec![EventType::AccountWhirlpool],
+    });
+
+    println!("开始监听事件，按 Ctrl+C 停止...");
+    println!("监控程序: {}", WHIRLPOOL_PROGRAM_ID);
+
+    println!("开始订阅...");
+
+    grpc.subscribe_events_immediate(
+        protocols,
+        None,
+        vec![transaction_filter],
+        vec![account_filter],
+        event_type_filter,
+        None,
+        callback,
+    )
+    .await?;
+
+    // 支持 stop 方法，测试代码 - 异步1000秒之后停止
+    let grpc_clone = grpc.clone();
+    tokio::spawn(async move {
+        tokio::time::sleep(std::time::Duration::from_secs(1000)).await;
+        grpc_clone.stop().await;
+    });
+
+    println!("等待 Ctrl+C 停止...");
+    tokio::signal::ctrl_c().await?;
+
+    Ok(())
+}
+
+fn create_event_callback() -> impl Fn(DexEvent) {
+    |event: DexEvent| {
+        // println!(
+        //     "🎉 事件接收! 类型: {:?}, slot: {:?}",
+        //     event.metadata().event_type,
+        //     event.metadata().slot
+        // );
+        match event {
+            DexEvent::WhirlpoolAccountEvent(e) => {
+                println!("=== Whirlpool 账户更新 ===");
+                println!("账户地址: {}", e.pubkey);
+                println!("Whirlpools Config: {}", e.whirlpool.whirlpools_config);
+                println!("Token Mint A: {}", e.whirlpool.token_mint_a);
+                println!("Token Mint B: {}", e.whirlpool.token_mint_b);
+                println!("Token Vault A: {}", e.whirlpool.token_vault_a);
+                println!("Token Vault B: {}", e.whirlpool.token_vault_b);
+                println!("Tick Spacing: {}", e.whirlpool.tick_spacing);
+                println!("Fee Rate: {}", e.whirlpool.fee_rate);
+                println!("Protocol Fee Rate: {}", e.whirlpool.protocol_fee_rate);
+                println!("Liquidity: {}", e.whirlpool.liquidity);
+                println!("Sqrt Price: {}", e.whirlpool.sqrt_price);
+                println!("Tick Current Index: {}", e.whirlpool.tick_current_index);
+                println!("Protocol Fee Owed A: {}", e.whirlpool.protocol_fee_owed_a);
+                println!("Protocol Fee Owed B: {}", e.whirlpool.protocol_fee_owed_b);
+                println!("Fee Growth Global A: {}", e.whirlpool.fee_growth_global_a);
+                println!("Fee Growth Global B: {}", e.whirlpool.fee_growth_global_b);
+                println!("Reward Last Updated Timestamp: {}", e.whirlpool.reward_last_updated_timestamp);
+                println!("奖励信息数量: {}", e.whirlpool.reward_infos.len());
+                for (i, reward_info) in e.whirlpool.reward_infos.iter().enumerate() {
+                    if reward_info.mint != solana_sdk::pubkey::Pubkey::default() {
+                        println!("  奖励 {}: Mint={}, Vault={}, Authority={}, Emissions={}, Growth={}",
+                            i, reward_info.mint, reward_info.vault, reward_info.authority,
+                            reward_info.emissions_per_second_x64, reward_info.growth_global_x64);
+                    }
+                }
+                println!("=====================================");
+            }
+            _ => {
+                //println!("其他事件: {:?}", event);
+            }
+        }
+    }
+}