Struct MessageService 

pub struct MessageService { /* private fields */ }

消息服务

Implementations

impl MessageService

pub fn new(http: Arc<HttpClient>) -> Self

创建新的消息服务

pub fn with_mqtt(http: Arc<HttpClient>, mqtt: Arc<RwLock<MqttClient>>) -> Self

使用 MQTT 客户端创建消息服务

pub async fn get_conversation_messages( &self, conversation_id: &str, cursor: Option<&str>, limit: Option<i32>, ) -> SdkResult<MessagesResponse>

获取会话消息列表（需要认证）

Arguments

• conversation_id - 会话 ID
• cursor - 分页游标（可选）
• limit - 每页数量（可选，默认 20）

Returns

• MessagesResponse - 消息列表

pub async fn send_message( &self, conversation_id: &str, content: &str, message_type: Option<&str>, reply_to_id: Option<&str>, data: Option<Value>, ) -> SdkResult<Message>

发送消息（需要认证）

Arguments

• conversation_id - 会话 ID
• content - 消息内容
• message_type - 消息类型（默认 “text”）
• reply_to_id - 回复的消息 ID（可选）
• data - 附加数据（可选）

Returns

• Message - 发送的消息

pub async fn delete_message( &self, conversation_id: &str, message_id: &str, ) -> SdkResult<()>

删除消息（需要认证）

Arguments

• conversation_id - 会话 ID
• message_id - 消息 ID

pub async fn mark_message_as_read( &self, conversation_id: &str, message_id: &str, ) -> SdkResult<()>

标记消息为已读（需要认证）

Arguments

• conversation_id - 会话 ID
• message_id - 消息 ID

pub async fn trigger_sync(&self, conversation_id: Option<&str>) -> SdkResult<()>

触发消息历史同步（需要认证）

调用此接口后，服务端会通过 MQTT 推送消息历史数据

Arguments

• conversation_id - 会话 ID（可选，不提供则同步所有会话）

pub async fn publish_message( &self, conversation_id: &str, payload: &[u8], ) -> SdkResult<()>

通过 MQTT 发送消息（需要 MQTT 连接）

Arguments

• conversation_id - 会话 ID
• payload - 消息 payload