Struct FilesystemMessageHandler 

pub struct FilesystemMessageHandler<F, D>
where
    F: FileOperations,
    D: DirectoryOperations,
{ /* private fields */ }

MCP Message Handler for airsprotocols-mcpserver-filesystem STDIO Transport

This handler wraps the existing FilesystemMcpServer (ToolProvider) and provides the MessageHandler<()> interface required by the new airsprotocols-mcp architecture. It preserves all existing business logic while enabling proper transport integration.

Implementations

impl<F, D> FilesystemMessageHandler<F, D>

where F: FileOperations, D: DirectoryOperations,

pub fn new(server: Arc<FilesystemMcpServer<F, D>>) -> Self

Create a new message handler wrapping the existing server

Trait Implementations

impl<F, D> Debug for FilesystemMessageHandler<F, D>

where F: FileOperations + Debug, D: DirectoryOperations + Debug,

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

Formats the value using the given formatter.

impl<F, D> MessageHandler for FilesystemMessageHandler<F, D>

where F: FileOperations, D: DirectoryOperations,

fn handle_message<'life0, 'async_trait>( &'life0 self, message: JsonRpcMessage, _context: MessageContext<()>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Handle incoming JSON-RPC messages from the transport layer

fn handle_error<'life0, 'async_trait>( &'life0 self, error: TransportError, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Handle transport-level errors

fn handle_close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Handle transport close events