gsm-core 0.4.40

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

//! Canonical NATS subject helpers for messaging ingress/egress.

use std::borrow::Cow;

pub const INGRESS_SUBJECT_PREFIX: &str = "greentic.messaging.ingress";
pub const EGRESS_SUBJECT_PREFIX: &str = "greentic.messaging.egress";

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

pub fn ingress_subject(env: &str, tenant: &str, team: &str, platform: &str) -> String {
    ingress_subject_with_prefix(INGRESS_SUBJECT_PREFIX, env, tenant, team, platform)
}

pub fn ingress_subject_with_prefix(
    prefix: &str,
    env: &str,
    tenant: &str,
    team: &str,
    platform: &str,
) -> String {
    format!(
        "{prefix}.{}.{}.{}.{}",
        norm(env),
        norm(tenant),
        norm(team),
        norm(platform)
    )
}

pub fn egress_subject(env: &str, tenant: &str, team: &str, platform: &str) -> String {
    egress_subject_with_prefix(EGRESS_SUBJECT_PREFIX, env, tenant, team, platform)
}

pub fn egress_subject_with_prefix(
    prefix: &str,
    env: &str,
    tenant: &str,
    team: &str,
    platform: &str,
) -> String {
    format!(
        "{prefix}.{}.{}.{}.{}",
        norm(env),
        norm(tenant),
        norm(team),
        norm(platform)
    )
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn subjects_are_deterministic_and_sanitized() {
        assert_eq!(
            ingress_subject("dev", "acme", "team", "slack"),
            "greentic.messaging.ingress.dev.acme.team.slack"
        );
        assert_eq!(
            egress_subject(" dev ", "acme", "team a", "web chat"),
            "greentic.messaging.egress.dev.acme.team-a.web-chat"
        );
    }
}