bote 0.91.0

MCP core service — JSON-RPC 2.0 protocol, tool registry, audit integration, and TypeScript bridge
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
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

//! # Bote — MCP Core Service
//!
//! Bote (German: messenger) provides the shared MCP (Model Context Protocol)
//! implementation for the AGNOS ecosystem. JSON-RPC 2.0 protocol, tool registry,
//! schema validation, and dispatch — so individual apps don't each reimplement
//! the protocol.
//!
//! ## Feature Flags
//!
//! | Flag | Description |
//! |------|-------------|
//! | `http` | HTTP transport via axum (POST + SSE streaming) |
//! | `ws` | WebSocket transport via tokio-tungstenite |
//! | `unix` | Unix domain socket transport |
//! | `all-transports` | Enables `http`, `ws`, and `unix` |
//! | `audit` | Audit logging via libro hash-linked chain |
//! | `events` | Event publishing via majra pub/sub |
//! | `bridge` | TypeScript bridge with CORS and MCP result formatting |
//! | `discovery` | Cross-node tool discovery via majra pub/sub |
//! | `sandbox` | Tool sandboxing via kavach isolation backends |
//! | `full` | All transports + audit + events + bridge + discovery + sandbox |
//!
//! None are enabled by default — enable only what you need.
//!
//! ## Modules
//!
//! - [`protocol`] — JSON-RPC 2.0 types (Request, Response, Error)
//! - [`registry`] — Tool registry with schema validation, versioning, and discovery
//! - [`schema`] — JSON Schema compilation and typed validation
//! - [`dispatch`] — Route tool calls to registered handlers (with dynamic registration)
//! - [`stream`] — Streaming primitives (progress, cancellation)
//! - [`transport`] — Transport layer (stdio, HTTP, WebSocket, Unix socket)
//! - [`audit`] — Audit logging trait and libro integration
//! - [`events`] — Event publishing trait and majra integration
//! - [`bridge`] — TypeScript bridge with CORS and MCP result formatting
//! - [`discovery`] — Cross-node tool discovery via majra pub/sub
//! - [`sandbox`] — Tool sandboxing via kavach isolation backends

pub mod audit;
pub mod dispatch;
pub mod events;
pub mod protocol;
pub mod registry;
pub mod schema;
pub mod session;
pub mod stream;
pub mod transport;

#[cfg(feature = "auth")]
pub mod auth;

#[cfg(feature = "bridge")]
pub mod bridge;

#[cfg(feature = "host")]
pub mod host;

#[cfg(feature = "audit")]
pub mod libro_tools;

#[cfg(feature = "discovery")]
pub mod discovery;

#[cfg(feature = "sandbox")]
pub mod sandbox;

mod error;
pub use error::BoteError;

pub use audit::{AuditSink, ToolCallEvent};
pub use dispatch::{DispatchOutcome, Dispatcher};
pub use events::EventSink;
pub use protocol::{JsonRpcError, JsonRpcRequest, JsonRpcResponse};
pub use registry::{ToolAnnotations, ToolDef, ToolRegistry, ToolSchema};
pub use schema::{CompiledSchema, PropertyDef, SchemaType};
pub use stream::{
    CancellationToken, ProgressSender, ProgressUpdate, StreamContext, StreamingToolHandler,
};

pub type Result<T> = std::result::Result<T, BoteError>;

#[cfg(test)]
mod tests;

/// Compile-time assertions that public types are Send + Sync.
#[cfg(test)]
mod send_sync_assertions {
    fn assert_send<T: Send>() {}
    fn assert_sync<T: Sync>() {}

    #[test]
    fn public_types_are_send_sync() {
        assert_send::<super::BoteError>();
        assert_sync::<super::BoteError>();
        assert_send::<super::Dispatcher>();
        assert_sync::<super::Dispatcher>();
        assert_send::<super::ToolRegistry>();
        assert_sync::<super::ToolRegistry>();
        assert_send::<super::ToolDef>();
        assert_sync::<super::ToolDef>();
        assert_send::<super::ToolSchema>();
        assert_sync::<super::ToolSchema>();
        assert_send::<super::JsonRpcRequest>();
        assert_sync::<super::JsonRpcRequest>();
        assert_send::<super::JsonRpcResponse>();
        assert_sync::<super::JsonRpcResponse>();
        assert_send::<super::JsonRpcError>();
        assert_sync::<super::JsonRpcError>();
        assert_send::<super::CancellationToken>();
        assert_sync::<super::CancellationToken>();
        assert_send::<super::ProgressUpdate>();
        assert_sync::<super::ProgressUpdate>();
        assert_send::<super::ProgressSender>();
        assert_sync::<super::ProgressSender>();
        assert_send::<super::StreamContext>();
        assert_sync::<super::StreamContext>();
        assert_send::<super::ToolCallEvent>();
        assert_sync::<super::ToolCallEvent>();
    }
}