gsm-core 0.4.32

Core types and platform abstractions for the Greentic messaging runtime.
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

//! NATS subject helpers (multi-tenant/topic-safe)

use std::borrow::Cow;

/// Normalizes identifiers to be subject-safe (replace spaces, trim).
fn norm<S: AsRef<str>>(s: S) -> Cow<'static, str> {
    let mut t = s
        .as_ref()
        .trim()
        .replace([' ', '\t', '\n', '\r', '*', '>', '/'], "-");
    if t.is_empty() {
        t = "unknown".into();
    }
    Cow::Owned(t)
}

/// Inbound messages from ingress webhooks (normalized envelopes).
///
/// ```
/// use gsm_core::in_subject;
///
/// assert_eq!(
///     in_subject("acme", "teams", "room/42"),
///     "greentic.msg.in.acme.teams.room-42"
/// );
/// ```
pub fn in_subject(tenant: &str, platform: &str, chat_id: &str) -> String {
    format!(
        "greentic.msg.in.{}.{}.{}",
        norm(tenant),
        norm(platform),
        norm(chat_id)
    )
}

/// Outbound messages from runner to egress adapters.
///
/// ```
/// use gsm_core::out_subject;
///
/// assert_eq!(
///     out_subject("acme", "telegram", "chat 1"),
///     "greentic.msg.out.acme.telegram.chat-1"
/// );
/// ```
pub fn out_subject(tenant: &str, platform: &str, chat_id: &str) -> String {
    format!(
        "greentic.msg.out.{}.{}.{}",
        norm(tenant),
        norm(platform),
        norm(chat_id)
    )
}

/// Dead-letter queue subjects (direction = `"in"` or `"out"`).
///
/// ```
/// use gsm_core::dlq_subject;
///
/// assert_eq!(
///     dlq_subject("unknown", "acme", "slack"),
///     "greentic.msg.dlq.in.acme.slack"
/// );
/// ```
pub fn dlq_subject(direction: &str, tenant: &str, platform: &str) -> String {
    let dir = match direction {
        "in" | "out" => direction,
        _ => "in",
    };
    format!(
        "greentic.msg.dlq.{}.{}.{}",
        dir,
        norm(tenant),
        norm(platform)
    )
}

/// Subscriptions control channels (`"events"` or `"admin"`).
///
/// ```
/// use gsm_core::subs_subject;
///
/// assert_eq!(
///     subs_subject("admin", "acme", "whatsapp"),
///     "greentic.subs.admin.acme.whatsapp"
/// );
/// ```
pub fn subs_subject(kind: &str, tenant: &str, platform: &str) -> String {
    let k = match kind {
        "events" | "admin" => kind,
        _ => "events",
    };
    format!("greentic.subs.{}.{}.{}", k, norm(tenant), norm(platform))
}

#[cfg(test)]
mod tests {
    use super::*;
    #[test]
    fn subjects_format() {
        assert_eq!(
            in_subject("acme", "teams", "chat/42"),
            "greentic.msg.in.acme.teams.chat-42"
        );
        assert_eq!(
            out_subject(" acme ", "tele gram", "room 7"),
            "greentic.msg.out.acme.tele-gram.room-7"
        );
        assert_eq!(
            dlq_subject("weird", "acme", "slack"),
            "greentic.msg.dlq.in.acme.slack"
        );
        assert_eq!(
            subs_subject("admin", "acme", "whatsapp"),
            "greentic.subs.admin.acme.whatsapp"
        );
    }
}