lash_remote_protocol/
lib.rs

1//! Wire DTOs for driving a lash runtime across a process boundary.
2//!
3//! Each domain module carries one slice of the protocol vocabulary
4//! ([`llm`], [`turn_input`], [`turn_result`], [`processes`], [`triggers`],
5//! [`prompt`], [`tools`], [`observations`], [`usage_activity`],
6//! [`registry_errors`]); the crate root re-exports all of them, which is the
7//! established public API for direct consumers of this crate. The
8//! cross-cutting protocol handshake ([`REMOTE_PROTOCOL_VERSION`],
9//! [`ensure_protocol_version`]) lives at the root itself.
10
11pub mod llm;
12pub mod observations;
13pub mod processes;
14pub mod prompt;
15pub mod registry_errors;
16pub mod tools;
17pub mod triggers;
18pub mod turn_control;
19pub mod turn_input;
20pub mod turn_result;
21pub mod usage_activity;
22
23pub use llm::*;
24pub use observations::*;
25pub use processes::*;
26pub use prompt::*;
27pub use registry_errors::*;
28pub use tools::*;
29pub use triggers::*;
30pub use turn_control::*;
31pub use turn_input::*;
32pub use turn_result::*;
33pub use usage_activity::*;
34
35// Bumped to 16: queued turn-input application is a typed observation with
36// stable admission, turn, and committed-message identity.
37pub const REMOTE_PROTOCOL_VERSION: u32 = 16;
38
39pub fn ensure_protocol_version(actual: u32) -> Result<(), RemoteProtocolError> {
40    if actual == REMOTE_PROTOCOL_VERSION {
41        Ok(())
42    } else {
43        Err(RemoteProtocolError::UnsupportedProtocolVersion {
44            actual,
45            expected: REMOTE_PROTOCOL_VERSION,
46        })
47    }
48}
49
50#[cfg(feature = "core-conversions")]
51mod core_conversions;
52
53#[cfg(feature = "core-conversions")]
54pub use core_conversions::{RemoteTurnActivitySink, replay_collected_activities};
55
56#[cfg(test)]
57mod tests;
lash_remote_protocol/lib.rs

lash_remote_protocol/
lib.rs
