refactor(health): 更新 message.sent 消费者注释 — last_message_at 已在 CAS 中处理
Some checks failed
CI / rust-check (push) Has been cancelled
CI / rust-test (push) Has been cancelled
CI / frontend-build (push) Has been cancelled
CI / security-audit (push) Has been cancelled

This commit is contained in:
iven
2026-04-30 08:32:29 +08:00
parent 1925568c13
commit c0e3d26b71

View File

@@ -110,7 +110,7 @@ pub fn register_handlers_with_state(state: crate::state::HealthState) {
} }
}); });
// message.sent → 通用消息事件消费者(预留咨询联动 // message.sent → 通用消息事件消费者(预留扩展
let (mut msg_rx, _msg_handle) = state.event_bus.subscribe_filtered("message.".to_string()); let (mut msg_rx, _msg_handle) = state.event_bus.subscribe_filtered("message.".to_string());
let _msg_db = state.db.clone(); let _msg_db = state.db.clone();
tokio::spawn(async move { tokio::spawn(async move {
@@ -125,8 +125,9 @@ pub fn register_handlers_with_state(state: crate::state::HealthState) {
recipient_id = ?recipient_id, recipient_id = ?recipient_id,
"message.sent 消费者收到事件" "message.sent 消费者收到事件"
); );
// TODO: 若 message 关联了 consultation session(通过 metadata 或 reference // 注:consultation_session.last_message_at 已在
// 可在此更新 consultation_session.last_message_at // consultation_service::create_message() 的 CAS 操作中直接更新,
// 无需通过此消费者重复处理
} }
Some(_) => {} Some(_) => {}
None => break, None => break,