Struct McpSubstrate 

pub struct McpSubstrate { /* private fields */ }

Implementations

impl McpSubstrate

pub fn new(session: Arc<Mutex<dyn McpSession>>, name: impl Into<String>) -> Self

Wrap an MCP session as a substrate. name is the environment label (e.g. "vm"); it is not required to match the session’s server name.

Trait Implementations

impl Substrate for McpSubstrate

fn name(&self) -> &str

Environment name: "local", "vm", "docker:...", etc.

fn run_command<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 str, timeout_s: Option<f64>, ) -> Pin<Box<dyn Future<Output = Result<CommandOutput, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Run a one-shot command, returning stdout/stderr/exit_code.

fn read_text<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read a UTF-8 text file in full.

fn write_text<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 str, content: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Write (truncate) a UTF-8 text file.

fn path_state<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = PathState> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Determine whether path exists without requiring it to be valid UTF-8. The default is intentionally unknown: custom substrates can retain their existing trait implementation, while guarded writes fail closed until the adapter supplies a trustworthy presence check.

fn read_bytes<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, offset: Option<u64>, len: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read raw bytes, optionally a window [offset, offset+len).

fn write_bytes<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 str, bytes: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Write (truncate) raw bytes.

fn pty_start<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn pty_input<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 str, data: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn pty_read<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn pty_resize<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, rows: u16, cols: u16, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn pty_kill<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn is_local(&self) -> bool

Whether this substrate is the host process itself. Convenience tools (list_dir/find_files/grep_files) that walk a directory tree use this to keep their byte-identical host-fs implementation on the local path; non-local environments fall back to composing on run_command.

fn display_path(&self, path: &str) -> String

How a path should appear in tool-result metadata for this environment. Pure/synchronous; no I/O. The default echoes the input unchanged. The local environment overrides this to reproduce the historic behavior of reporting the resolved absolute path (relative paths joined to the host CWD). Not a capability — just display canonicalization.