Skip to main content

server/
lib.rs

1#![deny(clippy::await_holding_lock)]
2
3mod http;
4mod json;
5mod mcp;
6mod subscribe;
7mod ws;
8
9use core_api::{MutationEvent, SharedDb};
10
11pub use mcp::run_mcp_stdio;
12
13/// Router state: the database plus the watch broadcast fan-out.
14#[derive(Clone)]
15struct AppState {
16    db: SharedDb,
17    watch: tokio::sync::broadcast::Sender<MutationEvent>,
18    token: Option<String>,
19    /// Bind address advertised in `GET /health`.
20    addr: std::net::SocketAddr,
21}
22
23pub use http::{router, router_with_auth, router_with_ui, serve, serve_with_ui};
24#[cfg(feature = "embed-ui")]
25pub use http::{router_with_embedded_ui, serve_with_embedded_ui};