nerve-ipc 0.2.0

Binary framing protocol for local IPC over Unix Domain Sockets
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

use nerve_ipc::types::{MessageType, ProtocolErrorKind};

// ── V1 message types ──────────────────────────────────────────────────────────

#[test]
fn ping_decodes() {
    assert_eq!(MessageType::try_from(0x01), Ok(MessageType::Ping));
}

#[test]
fn search_query_decodes() {
    assert_eq!(MessageType::try_from(0x02), Ok(MessageType::SearchQuery));
}

#[test]
fn search_result_decodes() {
    assert_eq!(MessageType::try_from(0x03), Ok(MessageType::SearchResult));
}

#[test]
fn ai_token_decodes() {
    assert_eq!(MessageType::try_from(0x04), Ok(MessageType::AiToken));
}

#[test]
fn cancel_decodes() {
    assert_eq!(MessageType::try_from(0x05), Ok(MessageType::Cancel));
}

// ── Agentic scaffolding types (0x10–0x12) ────────────────────────────────────

#[test]
fn agent_task_start_decodes() {
    assert_eq!(MessageType::try_from(0x10), Ok(MessageType::AgentTaskStart));
}

#[test]
fn agent_task_event_decodes() {
    assert_eq!(MessageType::try_from(0x11), Ok(MessageType::AgentTaskEvent));
}

#[test]
fn agent_task_done_decodes() {
    assert_eq!(MessageType::try_from(0x12), Ok(MessageType::AgentTaskDone));
}

// ── Unknown types must be rejected ───────────────────────────────────────────
//
// Per protocol.md: unknown message types cause connection termination
// (ProtocolErrorKind::UnknownMessageType).  TryFrom returning Err(()) is the
// codec-level signal for that outcome.

#[test]
fn unknown_type_0x00_rejected() {
    assert!(MessageType::try_from(0x00).is_err());
}

#[test]
fn unknown_type_0x06_rejected() {
    assert!(MessageType::try_from(0x06).is_err());
}

#[test]
fn unknown_type_0x0f_rejected() {
    assert!(MessageType::try_from(0x0F).is_err());
}

#[test]
fn unknown_type_0x13_rejected() {
    assert!(MessageType::try_from(0x13).is_err());
}

#[test]
fn unknown_type_0xff_rejected() {
    assert!(MessageType::try_from(0xFF).is_err());
}

// ── Codec rejects unknown message type in a wire frame ────────────────────────

#[test]
fn decode_rejects_unknown_message_type() {
    use nerve_ipc::codec::{decode, encode};
    use nerve_ipc::types::{FrameFlags, RequestId};

    let mut buf = encode(MessageType::Ping, FrameFlags::empty(), RequestId(1), &[]).unwrap();
    buf[6] = 0xFF; // corrupt msg_type to an unknown value

    let err = decode(&buf).unwrap_err();
    assert_eq!(err.kind(), ProtocolErrorKind::UnknownMessageType);
}