Struct McpManager 

pub struct McpManager { /* private fields */ }

Central manager for all MCP server connections.

Created via McpManager::spawn() which returns an Arc<Self>. Use McpManager::new_no_spawn() only in tests where the lifecycle task is not needed.

Implementations

impl McpManager

pub fn spawn() -> Arc<Self>

Spawns the background lifecycle task using the oxicode-default config and disk paths (~/.config/oxicode/), and eagerly connects to any Eager / KeepAlive servers.

Returns Arc<Self> so it can be shared freely across the agent loop, the TUI dashboard, and the lifecycle task (via Weak).

pub fn spawn_with_config(mcp_config: McpConfig) -> Arc<Self>

Spawn with a programmatically-supplied config (used by the SDK OxicodeBuilder::with_mcp_config). Disk paths default to the oxicode standard locations (~/.config/oxicode/).

pub fn spawn_with_paths( mcp_config: McpConfig, cache_path: Option<PathBuf>, consent_path: Option<PathBuf>, ) -> Arc<Self>

Primary constructor. Spawn with a programmatically-supplied config and optional custom disk paths for the metadata cache and consent store.

Pass None for either path to use the oxicode default (~/.config/oxicode/mcp-cache.json / mcp-consent.json).

This is the constructor SDK consumers (e.g. oxios) should use when they self-host MCP state under their own config directory. It spawns the background lifecycle task and eagerly connects to any Eager / KeepAlive servers.

Returns Arc<Self> so it can be shared freely across the agent loop, the TUI dashboard, and the lifecycle task (via Weak).

pub fn new_no_spawn() -> Self

Construct a manager without spawning the lifecycle task. Intended for tests that don’t need timer/disconnect behaviour.

pub fn config(&self) -> RwLockReadGuard<'_, McpConfig>

Get a snapshot of the current config.

pub fn replace_config(&self, new_config: McpConfig)

Hot-replace the in-memory MCP configuration.

Used by the /mcp management overlay after it writes a new config to disk: the updated server map becomes visible to connect(), status(), and the proxy tool without a full process restart. Existing live connections are left untouched; newly added servers connect lazily on first use (or eagerly if their LifecycleMode is eager/keep-alive).

Direct-tool registration happens once at boot from the cache, so newly-added directTools servers still require a restart to surface as first-class agent tools — but the mcp proxy tool can reach them immediately.

pub fn set_credential_provider(&self, provider: Arc<dyn McpCredentialProvider>)

Inject a credential provider. Replaces the noop default. Called by oxicode-cli bootstrap (or any host product) to enable authenticated MCP servers.

Existing transports retain the provider they were constructed with; new transports created after this call pick up the new one at their next construction.

pub fn consent(&self) -> &ConsentManager

Get the consent manager.

pub fn cache(&self) -> &MetadataCache

Get the metadata cache.

pub async fn status(self: &Arc<Self>) -> String

Get a formatted status summary (legacy mcp({}) interface).

pub fn dashboard_data(self: &Arc<Self>) -> McpDashboardData

Snapshot of dashboard data (Phase 2). Synchronous — only reads parking_lot-guarded state and in-memory copies of cached tool lists, so it is safe to call from render().

pub async fn connect(self: &Arc<Self>, server_name: &str) -> Result<String>

Connect to a specific MCP server by name. Selects the transport from the entry: command → stdio (spawn), url → Streamable HTTP. Stores the connected client and updates the metadata cache.

pub fn trust_server(&self, server_name: &str) -> Result<()>

Trust an MCP server for spawn consent (persist Allow to disk). Used by oxicode mcp trust <server>. After this, the server’s next connect() proceeds past the consent gate.

pub fn untrust_server(&self, server_name: &str) -> Result<()>

Revoke spawn trust for an MCP server (persist Deny to disk). Used by oxicode mcp untrust <server>. After this, the server’s next connect() is denied with McpError::ConsentDenied.

pub async fn ensure_connected(self: &Arc<Self>, server_name: &str) -> bool

Lazily connect (or return true if already connected).

pub async fn disconnect(self: &Arc<Self>, server_name: &str) -> Result<bool>

Manually disconnect a single server. Exposed for the MCP dashboard’s D key. Idempotent — returns Ok(true) if a live connection was actually closed, Ok(false) if the server was already disconnected.

pub async fn reauth_server(self: &Arc<Self>, server_name: &str) -> Result<()>

Force-refresh the OAuth credential for server_name (v2.2). Used by /mcp reauth <server> to rotate credentials without restarting the process. Returns an error if no credential provider is configured, the server has no url, or the refresh fails.

pub async fn call_tool( self: &Arc<Self>, tool_name: &str, args: Value, server_override: Option<&str>, ) -> Result<McpCallResult>

Call an MCP tool by name, optionally targeting a specific server.

pub async fn list_resources( self: &Arc<Self>, server_name: &str, ) -> Result<Vec<Value>>

List resources from a connected MCP server (v2.3 G5).

pub async fn read_resource( self: &Arc<Self>, server_name: &str, uri: &str, ) -> Result<Vec<McpContent>>

Read a resource URI from a connected MCP server (v2.3 G5).

pub async fn list_prompts( self: &Arc<Self>, server_name: &str, ) -> Result<Vec<McpPrompt>>

List prompt templates from a connected MCP server (v2.3 G5).

pub async fn get_prompt( self: &Arc<Self>, server_name: &str, name: &str, arguments: HashMap<String, String>, ) -> Result<Vec<Value>>

Get a prompt template with arguments (v2.3 G5).

pub fn reset_idle_timer(self: &Arc<Self>, server_name: &str)

Reset (or start) the idle-disconnect timer for a server. Called after every successful tool use.

pub async fn describe(self: &Arc<Self>, tool_name: &str) -> Result<String>

Describe a tool by name.

pub async fn search( self: &Arc<Self>, query: &str, regex: bool, server_filter: Option<&str>, ) -> Result<String>

Search tools by name or description.

pub async fn list_tools(self: &Arc<Self>, server_name: &str) -> Result<String>

List tools for a specific server.

pub fn direct_tools_from_cache(self: &Arc<Self>) -> Vec<DirectToolDef>

Direct tool definitions for ToolRegistry registration (Phase 3). Reads from the metadata cache, applies direct_tools / exclude_tools filters, and returns the precomputed prefixed names.

pub fn should_disable_proxy(self: &Arc<Self>) -> bool

Whether the mcp proxy tool should be hidden in the tool registry (Phase 3 — settings.disable_proxy_tool: true).

Trait Implementations

impl Debug for McpManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for McpManager

fn default() -> Self

Returns the “default value” for a type.