astrid-kernel 0.8.0

Astrid micro-kernel, the core of the Astrid OS
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

//! Unit tests for [`super::connection_signal`] — the classifier that lets the
//! connection tracker recognise both typed `IpcPayload::Connect`/`Disconnect`
//! (native producers) and the `client.v1.connect`/`client.v1.disconnect`
//! topics (uplink capsules, which can only publish JSON via the SDK).

use astrid_events::ipc::IpcPayload;

use super::{ConnectionSignal, connection_signal};

#[test]
fn typed_connect_payload_opens() {
    assert_eq!(
        connection_signal("client.v1.connect", &IpcPayload::Connect),
        Some(ConnectionSignal::Opened)
    );
}

#[test]
fn typed_disconnect_payload_closes() {
    let payload = IpcPayload::Disconnect {
        reason: Some("quit".to_string()),
    };
    assert_eq!(
        connection_signal("client.v1.disconnect", &payload),
        Some(ConnectionSignal::Closed {
            reason: Some("quit".to_string())
        })
    );
}

#[test]
fn typed_disconnect_without_reason_closes() {
    let payload = IpcPayload::Disconnect { reason: None };
    assert_eq!(
        connection_signal("client.v1.disconnect", &payload),
        Some(ConnectionSignal::Closed { reason: None })
    );
}

#[test]
fn connected_topic_with_json_payload_opens() {
    // The capsule path: the CLI proxy can only publish JSON, so the typed
    // variant is never present — the topic is the sole signal.
    let payload = IpcPayload::RawJson(serde_json::json!({ "principal": "alice" }));
    assert_eq!(
        connection_signal("client.v1.connect", &payload),
        Some(ConnectionSignal::Opened)
    );
}

#[test]
fn disconnect_topic_with_json_payload_closes_and_extracts_reason() {
    let payload = IpcPayload::RawJson(serde_json::json!({ "reason": "quit" }));
    assert_eq!(
        connection_signal("client.v1.disconnect", &payload),
        Some(ConnectionSignal::Closed {
            reason: Some("quit".to_string())
        })
    );
}

#[test]
fn disconnect_topic_with_json_payload_without_reason_closes() {
    // Reason is optional — a JSON disconnect with no `reason` key still closes.
    let payload = IpcPayload::RawJson(serde_json::json!({ "principal": "alice" }));
    assert_eq!(
        connection_signal("client.v1.disconnect", &payload),
        Some(ConnectionSignal::Closed { reason: None })
    );
}

#[test]
fn unrelated_client_topic_is_ignored() {
    // Other `client.v1.*` traffic (the tracker subscribes to the whole prefix)
    // must not move the connection counter.
    let payload = IpcPayload::RawJson(serde_json::json!({ "hello": "world" }));
    assert_eq!(connection_signal("client.v1.heartbeat", &payload), None);
    assert_eq!(connection_signal("client.v1.prompt", &payload), None);
}

#[test]
fn typed_payload_wins_even_on_an_unrelated_topic() {
    // A native producer's typed payload is honoured regardless of topic, so a
    // mismatched topic never suppresses a real connection event.
    assert_eq!(
        connection_signal("some.other.topic", &IpcPayload::Connect),
        Some(ConnectionSignal::Opened)
    );
    assert_eq!(
        connection_signal("some.other.topic", &IpcPayload::Disconnect { reason: None }),
        Some(ConnectionSignal::Closed { reason: None })
    );
}