wcode-protocol 0.8.0

Wire transport for wcode sessions: NDJSON frames, a socket server and client, a backend-agnostic handle
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

//! Wire transport for wcode sessions — the socket behind the protocol.
//!
//! The kernel defines the *interface* ([`wcode_harness::protocol::Frame`] of
//! [`Request`]/[`AgentEvent`]) and the in-process actor that speaks it. This
//! crate adds the *transport*:
//!
//! - NDJSON framing ([`read_frame`]/[`write_frame`]),
//! - a [`serve`] function that re-exposes a session [`SessionHandle`] to remote
//!   clients over a Unix socket,
//! - a [`Client`] that mirrors the handle's `send`/`ask`/`subscribe` API,
//! - a [`Backend`] that makes the local and remote paths interchangeable,
//! - a [`Registry`] — the in-process A2A bus (§8 #3, §10.1): an address book
//!   plus the permitted-set routing that scopes who may message whom.
//!
//! The point (design: `docs/interface-protocol-brainstorm.md`, §8): a caller —
//! the REPL today, the TUI next, another session later — talks to a [`Backend`]
//! and never knows whether the session is in this process or across a socket.
//!
//! [`Request`]: wcode_harness::protocol::Request
//! [`AgentEvent`]: wcode_harness::event::AgentEvent
//! [`SessionHandle`]: wcode_harness::actor::SessionHandle

mod backend;
mod frame;
mod registry;

pub use backend::{AskError, Backend, Closed};
pub use frame::{read_frame, write_frame};
pub use registry::{Registry, RouteError};

#[cfg(unix)]
mod client;
mod server;
#[cfg(unix)]
mod socket;

#[cfg(unix)]
pub use client::{Client, FLUSH_TIMEOUT, flush_all};
pub use server::{DefineArgs, DefineHandler, Root, Roster, serve_stream, serve_stdio};
#[cfg(unix)]
pub use server::{serve, serve_at};
#[cfg(unix)]
pub use socket::{bind, connect};