Struct McpServer 

pub struct McpServer { /* private fields */ }

MCP Server implementation

Implementations

impl McpServer

pub fn new_stdio() -> Self

Create a new MCP server over stdio

pub fn new_local() -> Self

Create a new MCP server for in-process/local usage.

Unlike Self::new_stdio, this does not spawn any stdio reader/writer threads and will not lock stdout. This is intended for CLI flows that need to query tool metadata or invoke tools directly without running a long-lived stdio server.

pub fn new(transport: Arc<dyn Transport>) -> Self

Create a new MCP server with custom transport

pub fn with_tool_registry(self, registry: Arc<ToolRegistry>) -> Self

Attach the full CodeTether tool registry to the MCP server.

All tools from the registry will be exposed as MCP tools, replacing the hardcoded basic tool set. Call before Self::run.

pub fn with_agent_bus(self, bus: Arc<AgentBus>) -> Self

Attach a local agent bus for publishing tool calls to the S3 sink.

Call this before Self::run so every tool invocation gets recorded as a ToolRequest + ToolResponse on the bus.

pub async fn with_bus(self, bus_url: String) -> Self

Attach a bus bridge and register bus-aware tools + resources.

Call this before Self::run to enable live bus monitoring.

pub async fn register_tool( &self, name: &str, description: &str, input_schema: Value, handler: Arc<dyn Fn(Value) -> Result<CallToolResult> + Send + Sync>, )

Register a tool

pub async fn register_resource( &self, uri: &str, name: &str, description: &str, mime_type: Option<&str>, handler: Arc<dyn Fn(String) -> Result<ReadResourceResult> + Send + Sync>, )

Register a resource

pub async fn get_tool_metadata(&self, name: &str) -> Option<ToolMetadata>

Get tool metadata by name

pub async fn get_all_tool_metadata(&self) -> Vec<ToolMetadata>

Get all tool metadata

pub async fn get_resource_metadata(&self, uri: &str) -> Option<ResourceMetadata>

Get resource metadata by URI

pub async fn get_all_resource_metadata(&self) -> Vec<ResourceMetadata>

Get all resource metadata

pub async fn register_prompt( &self, name: &str, handler: Arc<dyn Fn(Value) -> Result<GetPromptResult> + Send + Sync>, )

Register a prompt handler

pub async fn get_prompt_handler( &self, name: &str, ) -> Option<Arc<dyn Fn(Value) -> Result<GetPromptResult> + Send + Sync>>

Get a prompt handler by name

pub async fn list_prompts(&self) -> Vec<String>

List all registered prompt names

pub async fn run(&self) -> Result<()>

Run the MCP server (main loop)

pub async fn setup_tools_public(&self)

Setup default tools (public, for CLI use)

pub async fn call_tool_direct( &self, name: &str, arguments: Value, ) -> Result<CallToolResult>

Call a tool directly without going through the transport