emperor-mcp 0.2.0

Opinionated MCP server framework: stateless Streamable HTTP transport, output framing, credential forwarding, rmcp bootstrap
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

//! Opinionated framework for building MCP servers: stateless Streamable HTTP,
//! content-aware output framing, and per-request credential forwarding.
//!
//! Hatched from the [kowalski](https://github.com/yarenty/kowalski) workspace;
//! servers built there (`kowalski-mcp-rookery`, `kowalski-mcp-datafusion`) are the
//! reference consumers.
//!
//! Two server styles share the same conventions (stateless HTTP, output framing, no auth shortcuts):
//!
//! 1. **[`transport::McpHandler`]** — hand-rolled JSON-RPC dispatch; use [`transport::run_stdio`]
//!    (local/dev) or [`transport::serve_http`].
//! 2. **[`serve::serve`]** — rmcp `ServerHandler` + `#[tool_router]` bootstrap at `/mcp` + `/health`,
//!    with credential-forwarding middleware for multi-tenant deployments.
//!
//! Every server binary also ships a `doctor` subcommand built from [`doctor`] checks.
//!
//! See `MCP_REQUIREMENTS.md` and `MANIFEST_SPEC.md` in the repository root.

#![warn(missing_docs)]

pub mod doctor;
pub mod framing;
pub mod headers;
pub mod serve;
pub mod transport;

pub use framing::{FrameKind, frame, structured_framed};
pub use headers::{ForwardConfig, ForwardedHeaders, forward_headers_middleware};
pub use serve::{ServeOptions, serve};
pub use transport::{ACCEPT_STREAMABLE, McpHandler, http_router, run_stdio, serve_http, wants_sse};

/// Initialise tracing/logging to stderr (stdout stays clean for the stdio transport) with an
/// `RUST_LOG`-configurable filter, defaulting to `info`.
pub fn init_tracing() {
    use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
    let _ = tracing_subscriber::registry()
        .with(
            tracing_subscriber::EnvFilter::try_from_default_env().unwrap_or_else(|_| "info".into()),
        )
        .with(tracing_subscriber::fmt::layer().with_writer(std::io::stderr))
        .try_init();
}