myko 6.5.1

myko in rust
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

//! Round-trip regression tests for the wire protocol.
//!
//! These tests exist because `rmp_serde` was found to silently corrupt
//! `MykoMessage::ReportResponse` on round-trip (see commit history). They
//! must pass for ciborium and serve as the gate for the binary path.

#[cfg(test)]
mod tests {
    use serde_json::json;

    use crate::wire::{MykoMessage, ReportResponse};

    fn sample_report_response() -> MykoMessage {
        MykoMessage::ReportResponse(ReportResponse {
            response: json!({
                "rows": [
                    { "id": "row-1", "value": 42, "label": "alpha" },
                    { "id": "row-2", "value": -17, "label": "beta" },
                ],
                "total": 2,
                "metadata": {
                    "duration_ms": 12.5,
                    "cached": false,
                }
            }),
            tx: "tx-abc-123".to_string(),
        })
    }

    /// Gate test: ciborium must round-trip `MykoMessage::ReportResponse` cleanly.
    /// If this fails, the CBOR migration halts and the spec is reopened.
    #[test]
    fn report_response_roundtrip_cbor() {
        let original = sample_report_response();

        let mut bytes = Vec::new();
        assert!(ciborium::ser::into_writer(&original, &mut bytes).is_ok());
        let roundtripped = ciborium::de::from_reader::<MykoMessage, _>(bytes.as_slice());
        assert!(roundtripped.is_ok(), "ciborium decode");
        let Ok(roundtripped) = roundtripped else {
            return;
        };
        let original_json = serde_json::to_value(&original);
        assert!(original_json.is_ok(), "serialize original");
        let Ok(original_json) = original_json else {
            return;
        };
        let roundtripped_json = serde_json::to_value(&roundtripped);
        assert!(roundtripped_json.is_ok(), "serialize round-tripped value");
        let Ok(roundtripped_json) = roundtripped_json else {
            return;
        };
        assert_eq!(
            original_json, roundtripped_json,
            "ciborium roundtrip should preserve ReportResponse"
        );
    }

    fn assert_roundtrip(msg: MykoMessage) {
        let mut bytes = Vec::new();
        assert!(ciborium::ser::into_writer(&msg, &mut bytes).is_ok());
        let roundtripped = ciborium::de::from_reader::<MykoMessage, _>(bytes.as_slice());
        assert!(roundtripped.is_ok(), "ciborium decode");
        let Ok(roundtripped) = roundtripped else {
            return;
        };
        let original_json = serde_json::to_value(&msg);
        assert!(original_json.is_ok(), "serialize original");
        let Ok(original_json) = original_json else {
            return;
        };
        let roundtripped_json = serde_json::to_value(&roundtripped);
        assert!(roundtripped_json.is_ok(), "serialize round-tripped value");
        let Ok(roundtripped_json) = roundtripped_json else {
            return;
        };
        assert_eq!(
            original_json, roundtripped_json,
            "roundtrip mismatch for {msg:?}",
        );
        drop(msg);
    }

    #[test]
    fn ping_roundtrip_cbor() {
        assert_roundtrip(MykoMessage::Ping(crate::wire::PingData {
            id: "ping-1".into(),
            timestamp: 1_700_000_000_000,
        }));
    }

    #[test]
    fn query_cancel_roundtrip_cbor() {
        assert_roundtrip(MykoMessage::QueryCancel(crate::wire::CancelSubscription {
            tx: "tx-cancel-1".into(),
        }));
    }

    #[test]
    fn command_error_roundtrip_cbor() {
        assert_roundtrip(MykoMessage::CommandError(crate::wire::CommandError::new(
            "tx-cmd-1",
            "MyCommand",
            "validation failed: name is required",
        )));
    }
}