add meteora dlmm account event

examples/meteora_dlmm_account_subscription.rs

@@ -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);
+            }
+        }
+    }
+}