helix-im 0.1.21

基于 Helix Core 的确定性 MessageV3 IM 业务模块
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

//! G-07 expedite_map 的单列确定性写模型。

use helix_core::effect::{BatchUpdateSpec, SqlValue, StorageOp};

/// 只覆盖服务端权威加急列与其版本时间，避免改写普通消息内容或 viewer 本地列。
pub fn message_v3_urgent_op(
    message_id: &str,
    expedite_map: String,
    event_seq: u64,
    update_at: i64,
) -> StorageOp {
    StorageOp::BatchUpdate(BatchUpdateSpec {
        table: "message",
        key_col: "id",
        key_vals: vec![SqlValue::Text(message_id.to_string())],
        patch: vec![
            ("expedite_map".to_string(), SqlValue::Text(expedite_map)),
            (
                "event_seq".to_string(),
                SqlValue::Integer(event_seq.min(i64::MAX as u64) as i64),
            ),
            ("update_at".to_string(), SqlValue::Integer(update_at)),
        ],
    })
}