nerve-ipc-core 0.1.1

Core IPC layer for the NERVE protocol: authentication, request lifecycle, transport-agnostic dispatch, Unix Domain Socket server, and WebSocket server.
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

use std::io::Write;
use std::os::unix::net::UnixStream;
use std::thread;

use nerve_protocol::codec::encode;
use nerve_protocol::types::{FrameFlags, MessageType, RequestId};

#[test]
fn socket_read_frame_roundtrip() {
    // Create a connected UnixStream pair
    let (mut client, mut server) = UnixStream::pair().expect("socket pair failed");

    // Prepare a real protocol frame
    let payload = b"hello nerve";
    let encoded = encode(
        MessageType::Ping,
        FrameFlags::empty(),
        RequestId(42),
        payload,
    )
    .expect("encode failed");

    // Write from client side in another thread
    let writer = thread::spawn(move || {
        client.write_all(&encoded).expect("write failed");
    });

    // Read on server side using core logic
    let owned = nerve_ipc_core::server::read_frame(&mut server).expect("read_frame failed");

    // Convert to borrowed frame
    let frame = owned.as_borrowed();

    // Assertions — this is the contract
    assert_eq!(frame.header.request_id, 42);
    assert_eq!(frame.header.payload_length as usize, payload.len());
    assert_eq!(frame.payload, payload);

    writer.join().unwrap();
}