🐛 fix: correct message_read_v1 event data structure

Fix WebSocket message_read_v1 event deserialization error by updating
data structure to match actual Feishu API format:
- Replace sender/message fields with reader/message_id_list
- Add EventReader struct with read_time, reader_id, tenant_key
- Update websocket_client.rs example to use corrected field names
- Transform websocket_client.rs into echo server with enhanced logging

Resolves "missing field 'sender'" error in WebSocket event handling.

Author: foxzool

examples/basic/websocket_client.rs

@@ -5,12 +5,19 @@ use open_lark::prelude::*;
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
     // 初始化环境变量和日志
     dotenvy::dotenv().ok();
+
+    // 设置日志级别以获取更详细的调试信息
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "debug");
+    }
+
     env_logger::init();
 
     let app_id = std::env::var("APP_ID").expect("APP_ID environment variable not set");
     let app_secret = std::env::var("APP_SECRET").expect("APP_SECRET environment variable not set");
 
-    println!("🔌 WebSocket Client Example");
+    println!("🔌 WebSocket Echo Server Example");
+    println!("该示例演示一个简单的 Echo Server，将收到的消息原样返回给发送者");
     println!("Note: WebSocket features require the 'websocket' feature flag");
 
     #[cfg(not(feature = "websocket"))]
@@ -38,19 +45,79 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             .with_enable_token_cache(true)
             .build();
 
-        let config = Arc::new(client.config);
+        let client_for_echo = Arc::new(client);
+        let config = Arc::new(client_for_echo.config.clone());
 
-        // 创建事件处理器
+        // 创建事件处理器，实现 echo server 功能
+        let echo_client = client_for_echo.clone();
         let event_handler = match EventDispatcherHandler::builder()
-            .register_p2_im_message_receive_v1(|event| {
-                info!("📩 收到消息事件: {event:?}");
-                println!("📩 收到新消息:");
-                println!("  - 消息ID: {:?}", event.header.event_id);
-                println!("  - 消息类型: {:?}", event.event.message.message_type);
-                if !event.event.message.content.is_empty() {
-                    println!("  - 消息内容: {}", &event.event.message.content);
-                }
-                println!("  - 发送者: {:?}", event.event.sender);
+            .register_p2_im_message_receive_v1(move |event| {
+                let client = echo_client.clone();
+                tokio::spawn(async move {
+                    println!("📩 收到消息接收事件:");
+                    println!("  - 事件ID: {:?}", event.header.event_id);
+                    println!("  - 消息ID: {:?}", event.event.message.message_id);
+                    println!("  - 消息类型: {:?}", event.event.message.message_type);
+                    println!("  - 发送者: {:?}", event.event.sender.sender_id.open_id);
+
+                    if !event.event.message.content.is_empty() {
+                        println!("  - 消息内容: {}", &event.event.message.content);
+
+                        // Echo server 逻辑：解析消息内容并回显
+                        if let Ok(content_json) =
+                            serde_json::from_str::<serde_json::Value>(&event.event.message.content)
+                        {
+                            if let Some(text) = content_json.get("text").and_then(|v| v.as_str()) {
+                                let echo_content = format!("Echo: {text}");
+                                println!("🔄 正在发送回显消息: {echo_content}");
+
+                                // 构建回显消息
+                                let echo_request = CreateMessageRequest::builder()
+                                    .receive_id_type("open_id")
+                                    .request_body(
+                                        CreateMessageRequestBody::builder()
+                                            .receive_id(&event.event.sender.sender_id.open_id)
+                                            .msg_type("text")
+                                            .content(format!("{{\"text\":\"{echo_content}\"}}"))
+                                            .build(),
+                                    )
+                                    .build();
+
+                                // 发送回显消息
+                                match client.im.v1.message.create(echo_request, None).await {
+                                    Ok(_) => {
+                                        println!("✅ Echo 消息发送成功: {echo_content}");
+                                    }
+                                    Err(e) => {
+                                        eprintln!("❌ Echo 消息发送失败: {e:?}");
+                                    }
+                                }
+                            } else {
+                                println!("  - 非文本消息，跳过回显");
+                            }
+                        } else {
+                            println!("  - 无法解析消息内容");
+                        }
+                    } else {
+                        println!("  - 空消息内容");
+                    }
+
+                    info!("📩 消息接收事件处理完成");
+                });
+            })
+            .and_then(|builder| {
+                builder.register_p2_im_message_read_v1(|event| {
+                    tokio::spawn(async move {
+                        println!("👁️ 收到消息已读事件:");
+                        println!("  - 事件ID: {:?}", event.header.event_id);
+                        println!("  - 阅读者: {:?}", event.event.reader.reader_id.open_id);
+                        println!("  - 阅读时间: {}", event.event.reader.read_time);
+                        println!("  - 已读消息ID列表: {:?}", event.event.message_id_list);
+                        println!("  - 租户: {}", event.event.reader.tenant_key);
+
+                        info!("👁️ 消息已读事件处理完成");
+                    });
+                })
             }) {
             Ok(builder) => builder.build(),
             Err(e) => {
@@ -60,8 +127,13 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         };
 
         println!("📡 事件处理器已注册，支持的事件类型:");
-        println!("  - 消息接收事件 (im.message.receive_v1)");
-        println!("  - 消息已读事件 (im.message.message_read_v1)");
+        println!("  - 消息接收事件 (im.message.receive_v1) - 支持文本消息回显");
+        println!("  - 消息已读事件 (im.message.message_read_v1) - 显示消息阅读状态");
+
+        println!("\n💡 使用提示:");
+        println!("  - 向机器人发送文本消息将收到 'Echo: [消息内容]' 的回复");
+        println!("  - 消息阅读状态会实时显示在控制台");
+        println!("  - 如果遇到解析错误，请检查事件数据结构是否匹配");
 
         println!("\n🚀 启动 WebSocket 连接...");
 
@@ -71,7 +143,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             return Err(format!("WebSocket connection failed: {e:?}").into());
         }
 
-        println!("✅ WebSocket 连接已建立并正常运行");
+        println!("✅ Echo Server 已启动并正常运行，等待接收消息...");
     }
 
     Ok(())

src/service/im/v1/p2_im_message_read_v1.rs

@@ -2,7 +2,7 @@ use serde::{Deserialize, Serialize};
 
 use crate::{
     event::{context::EventHeader, dispatcher::EventHandler},
-    service::im::v1::p2_im_message_receive_v1::{EventMessage, EventSender},
+    service::im::v1::p2_im_message_receive_v1::UserId,
 };
 
 #[derive(Debug, Serialize, Deserialize)]
@@ -12,11 +12,24 @@ pub struct P2ImMessageReadV1 {
     pub event: P2ImMessageMessageReadV1Data,
 }
 
-/// 事件
+/// 消息已读事件数据
 #[derive(Debug, Serialize, Deserialize)]
 pub struct P2ImMessageMessageReadV1Data {
-    pub sender: EventSender,
-    pub message: EventMessage,
+    /// 消息阅读者信息
+    pub reader: EventReader,
+    /// 已读消息ID列表
+    pub message_id_list: Vec<String>,
+}
+
+/// 消息阅读者信息
+#[derive(Debug, Serialize, Deserialize)]
+pub struct EventReader {
+    /// 阅读时间戳（毫秒）
+    pub read_time: String,
+    /// 阅读者ID信息
+    pub reader_id: UserId,
+    /// tenant key，为租户在飞书上的唯一标识
+    pub tenant_key: String,
 }
 
 pub struct P2ImMessageReadV1ProcessorImpl<F>