gsm-telemetry 0.4.2

Tracing and OpenTelemetry configuration helpers for Greentic messaging services.
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

use crate::{MessageContext, TelemetryLabels, record_counter};
use url::Url;

const AUTH_CARD_RENDERED_COUNTER: &str = "auth_card_rendered";
const AUTH_CARD_CLICKED_COUNTER: &str = "auth_card_clicked";

#[derive(Debug, Clone, Copy)]
pub enum AuthRenderMode {
    Pending,
    Native,
    Downgrade,
}

impl AuthRenderMode {
    pub fn as_str(&self) -> &'static str {
        match self {
            AuthRenderMode::Pending => "pending",
            AuthRenderMode::Native => "native",
            AuthRenderMode::Downgrade => "downgrade",
        }
    }
}

pub fn record_auth_card_render(
    ctx: &MessageContext,
    provider: &str,
    mode: AuthRenderMode,
    connection_name: Option<&str>,
    start_url: Option<&str>,
    team: Option<&str>,
) {
    record_auth_card_render_with_labels(
        &ctx.labels,
        provider,
        mode,
        connection_name,
        start_url,
        team,
    );
}

pub fn record_auth_card_render_with_labels(
    labels: &TelemetryLabels,
    provider: &str,
    mode: AuthRenderMode,
    connection_name: Option<&str>,
    start_url: Option<&str>,
    team: Option<&str>,
) {
    let mut enriched = labels.clone();
    enriched
        .extra
        .push(("event".into(), "auth.card.rendered".into()));
    enriched
        .extra
        .push(("provider".into(), provider.to_string()));
    enriched
        .extra
        .push(("mode".into(), mode.as_str().to_string()));
    if let Some(team) = team {
        enriched.extra.push(("team".into(), team.to_string()));
    }
    if let Some(connection) = connection_name.filter(|value| !value.is_empty()) {
        enriched
            .extra
            .push(("connection_name".into(), connection.to_string()));
    }
    if let Some(url) = start_url
        && let Some(domain) = start_url_domain(url)
    {
        enriched.extra.push(("start_url_domain".into(), domain));
    }
    record_counter(AUTH_CARD_RENDERED_COUNTER, 1, &enriched);
}

fn start_url_domain(raw: &str) -> Option<String> {
    Url::parse(raw)
        .ok()
        .and_then(|parsed| parsed.host_str().map(|host| host.to_string()))
}

pub fn record_auth_card_clicked(
    ctx: &MessageContext,
    provider: &str,
    platform: &str,
    message_id: Option<&str>,
    team: Option<&str>,
) {
    let mut labels = ctx.labels.clone();
    labels
        .extra
        .push(("event".into(), "auth.card.clicked".into()));
    labels.extra.push(("provider".into(), provider.to_string()));
    labels.platform = Some(platform.to_string());
    if let Some(message_id) = message_id {
        labels
            .extra
            .push(("message_id".into(), message_id.to_string()));
    }
    if let Some(team) = team {
        labels.extra.push(("team".into(), team.to_string()));
    }
    record_counter(AUTH_CARD_CLICKED_COUNTER, 1, &labels);
}