ockam_api 0.93.0

Ockam's request-response API
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

use opentelemetry::Key;
use std::fmt::{Display, Formatter};

// List of attribute keys for journey event creation

pub const TCP_OUTLET_AT: &Key = &Key::from_static_str("app.tcp_outlet.at");
pub const TCP_OUTLET_FROM: &Key = &Key::from_static_str("app.tcp_outlet.from");
pub const TCP_OUTLET_TO: &Key = &Key::from_static_str("app.tcp_outlet.to");
pub const TCP_OUTLET_ALIAS: &Key = &Key::from_static_str("app.tcp_outlet.alias");

pub const TCP_INLET_AT: &Key = &Key::from_static_str("app.tcp_inlet.at");
pub const TCP_INLET_FROM: &Key = &Key::from_static_str("app.tcp_inlet.from");
pub const TCP_INLET_TO: &Key = &Key::from_static_str("app.tcp_inlet.to");
pub const TCP_INLET_ALIAS: &Key = &Key::from_static_str("app.tcp_inlet.alias");
pub const TCP_INLET_CONNECTION_STATUS: &Key =
    &Key::from_static_str("app.tcp_inlet.connection_status");

/// List of all the journey events that we want to track
#[derive(Clone, Debug, PartialEq, Eq)]
pub enum JourneyEvent {
    Enrolled,
    IdentityCreated,
    IdentityImported,
    NodeCreated,
    TcpInletCreated,
    TcpOutletCreated,
    RelayCreated,
    PortalCreated,
    Ok {
        command_name: String,
    },
    Error {
        command_name: String,
        message: String,
    },
}

impl JourneyEvent {
    pub fn ok(command_name: String) -> JourneyEvent {
        JourneyEvent::Ok { command_name }
    }

    pub fn error(command_name: String, message: String) -> JourneyEvent {
        JourneyEvent::Error {
            command_name,
            message,
        }
    }
}

impl Display for JourneyEvent {
    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
        match self {
            JourneyEvent::Enrolled => f.write_str("✅ enrolled"),
            JourneyEvent::IdentityCreated => f.write_str("✅ identity created"),
            JourneyEvent::IdentityImported => f.write_str("✅ identity imported"),
            JourneyEvent::NodeCreated => f.write_str("✅ node created"),
            JourneyEvent::TcpInletCreated => f.write_str("✅ tcp inlet created"),
            JourneyEvent::TcpOutletCreated => f.write_str("✅ tcp outlet created"),
            JourneyEvent::RelayCreated => f.write_str("✅ relay created"),
            JourneyEvent::PortalCreated => f.write_str("✅ portal created"),
            JourneyEvent::Ok { command_name } => f.write_fmt(format_args!("🔨 {command_name}")),
            JourneyEvent::Error { command_name, .. } => {
                f.write_fmt(format_args!("❌ {} error", command_name))
            }
        }
    }
}