plana 0.2.2

PLANA protocol foundation: the canonical JSON-RPC 2.0 wire layer (unix-socket / HTTP / WS bindings, typed method routing) merged with the generic protocol core (handshake, identity, RBAC, regions, health descriptors) — the base every plana-rpc-* and domain-profile crate builds on.
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
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

//! Base protocol messages — heartbeat, error, ack.

use serde::{Deserialize, Serialize};
use ts_rs::TS;

#[derive(Debug, Clone, Serialize, Deserialize, TS)]
#[ts(export, export_to = "ws/baseMessages.ts")]
pub struct BaseHeartbeatParams {
    pub timestamp: i64,
}

#[derive(Debug, Clone, Serialize, Deserialize, TS)]
#[ts(export, export_to = "ws/baseMessages.ts")]
pub struct BaseErrorParams {
    pub code: String,
    pub message: String,
}

#[derive(Debug, Clone, Serialize, Deserialize, TS)]
#[ts(export, export_to = "ws/baseMessages.ts")]
pub struct BaseAckParams {
    pub message_id: String,
}

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

    // ── BaseHeartbeatParams ─────────────────────────────────────────

    #[test]
    fn heartbeat_round_trip() {
        let h = BaseHeartbeatParams {
            timestamp: 1700000000,
        };
        let s = serde_json::to_string(&h).unwrap();
        assert_eq!(s, r#"{"timestamp":1700000000}"#);
        let back: BaseHeartbeatParams = serde_json::from_str(&s).unwrap();
        assert_eq!(back.timestamp, 1700000000);
    }

    #[test]
    fn heartbeat_negative_timestamp() {
        // Pre-epoch timestamps should round-trip without error.
        let h = BaseHeartbeatParams { timestamp: -1 };
        let v = serde_json::to_value(&h).unwrap();
        assert_eq!(v["timestamp"], -1);
        let back: BaseHeartbeatParams = serde_json::from_value(v).unwrap();
        assert_eq!(back.timestamp, -1);
    }

    #[test]
    fn heartbeat_no_extra_fields() {
        let h = BaseHeartbeatParams { timestamp: 0 };
        let v = serde_json::to_value(&h).unwrap();
        assert_eq!(
            v.as_object().unwrap().len(),
            1,
            "heartbeat must have exactly 1 field"
        );
    }

    // ── BaseErrorParams ─────────────────────────────────────────────

    #[test]
    fn error_params_round_trip() {
        let e = BaseErrorParams {
            code: "E_TIMEOUT".into(),
            message: "request timed out".into(),
        };
        let v = serde_json::to_value(&e).unwrap();
        assert_eq!(v["code"], "E_TIMEOUT");
        assert_eq!(v["message"], "request timed out");
        let back: BaseErrorParams = serde_json::from_value(v).unwrap();
        assert_eq!(back.code, "E_TIMEOUT");
        assert_eq!(back.message, "request timed out");
    }

    #[test]
    fn error_params_no_extra_fields() {
        let e = BaseErrorParams {
            code: "X".into(),
            message: "y".into(),
        };
        let v = serde_json::to_value(&e).unwrap();
        assert_eq!(v.as_object().unwrap().len(), 2);
    }

    #[test]
    fn error_params_missing_field_rejected() {
        let raw = serde_json::json!({"code": "X"});
        assert!(serde_json::from_value::<BaseErrorParams>(raw).is_err());
    }

    // ── BaseAckParams ───────────────────────────────────────────────

    #[test]
    fn ack_params_round_trip() {
        let a = BaseAckParams {
            message_id: "msg-001".into(),
        };
        let s = serde_json::to_string(&a).unwrap();
        assert_eq!(s, r#"{"message_id":"msg-001"}"#);
        let back: BaseAckParams = serde_json::from_str(&s).unwrap();
        assert_eq!(back.message_id, "msg-001");
    }

    #[test]
    fn ack_params_empty_message_id() {
        let a = BaseAckParams {
            message_id: String::new(),
        };
        let v = serde_json::to_value(&a).unwrap();
        assert_eq!(v["message_id"], "");
    }

    #[test]
    fn ack_params_no_extra_fields() {
        let a = BaseAckParams {
            message_id: "m".into(),
        };
        let v = serde_json::to_value(&a).unwrap();
        assert_eq!(v.as_object().unwrap().len(), 1);
    }
}