Struct FilesystemMcpServer 

pub struct FilesystemMcpServer { /* private fields */ }

MCP server backed by the unified memstead_base::Engine.

Constructed via Self::from_workspace_root.

Implementations

impl FilesystemMcpServer

pub fn from_workspace_root(workspace_root: &Path) -> Result<Self, BootError>

Construct from a workspace root. Boots the unified Engine via Engine::from_workspace_root (lean path — folder + archive backends only). The error envelope wraps every layer (layout dispatch, store load, backend instantiation, engine construction) under one BootError.

Production callers (main.rs, every test fixture) reach the server through this constructor directly.

pub fn from_engine(engine: Engine, workspace_root: PathBuf) -> Self

Construct directly from a pre-built Engine — e.g. a sealed read-only archive mount stood up by an embedding service. workspace_root is consulted only by memstead_changes_since (which reads JSONL off disk); surfaces that do not expose that tool may pass any path.

pub fn export_mem_to_bytes(&self) -> Result<Vec<u8>, EngineError>

Export the server’s single mem as .mem archive bytes. Used by embedding services (the session server) to hand a visitor a self-describing copy of the mem their agent built. The server’s engine carries exactly one mem (filesystem / session mems are single-mem by design); this exports it.

pub fn entity_count(&self) -> usize

Count of real (non-stub) entities across the server’s mem. Used by embedding services (the session server) to enforce a per-session resource cap before admitting a create.

pub fn with_engine<R>(&self, f: impl FnOnce(&Engine) -> R) -> R

Run a read closure against the locked engine. The escape hatch for embedding services that need engine reads the tool surface does not expose — e.g. the session server’s live graph projection and its change-event subscription. Keeps the engine itself private; callers get a borrow only for the duration of f.

impl FilesystemMcpServer

pub fn memstead_entity_tool_attr() -> Tool

Generated tool metadata function for memstead_entity

pub fn memstead_create_tool_attr() -> Tool

Generated tool metadata function for memstead_create

pub fn memstead_update_tool_attr() -> Tool

Generated tool metadata function for memstead_update

pub fn memstead_delete_tool_attr() -> Tool

Generated tool metadata function for memstead_delete

pub fn memstead_relate_tool_attr() -> Tool

Generated tool metadata function for memstead_relate

pub fn memstead_search_tool_attr() -> Tool

Generated tool metadata function for memstead_search

pub fn memstead_health_tool_attr() -> Tool

Generated tool metadata function for memstead_health

pub fn memstead_schema_tool_attr() -> Tool

Generated tool metadata function for memstead_schema

pub fn memstead_diff_tool_attr() -> Tool

Generated tool metadata function for memstead_diff

pub fn memstead_changes_since_tool_attr() -> Tool

Generated tool metadata function for memstead_changes_since

pub fn memstead_rename_tool_attr() -> Tool

Generated tool metadata function for memstead_rename

pub fn memstead_check_tool_attr() -> Tool

Generated tool metadata function for memstead_check

pub fn memstead_overview_tool_attr() -> Tool

Generated tool metadata function for memstead_overview

pub fn tool_router() -> ToolRouter<Self>

Trait Implementations

impl Clone for FilesystemMcpServer

fn clone(&self) -> FilesystemMcpServer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ServerHandler for FilesystemMcpServer

fn get_info(&self) -> ServerInfo

Hand-written so instructions can be the named FS_SERVER_INSTRUCTIONS const (the macro only accepts string literals) and the serverInfo version is the engine’s full build version (semver + git build sha for dev builds) by construction — the historical hardcoded "0.1.0" cannot recur, and two dev builds between releases stay distinguishable.

async fn call_tool( &self, request: CallToolRequestParams, context: RequestContext<RoleServer>, ) -> Result<CallToolResult, McpError>

Friction-ledger seam (agent-trust plan 08), mirroring the full flavour: every dispatched typed refusal appends one content-free ledger entry, best-effort, after the response is built.

async fn initialize( &self, request: InitializeRequestParams, context: RequestContext<RoleServer>, ) -> Result<InitializeResult, McpError>

async fn list_tools( &self, _request: Option<PaginatedRequestParams>, _context: RequestContext<RoleServer>, ) -> Result<ListToolsResult, McpError>

fn get_tool(&self, name: &str) -> Option<Tool>

Get a tool definition by name.

fn enqueue_task( &self, _request: CallToolRequestParams, _context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CreateTaskResult, ErrorData>> + MaybeSendFuture

fn ping( &self, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn complete( &self, request: CompleteRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CompleteResult, ErrorData>> + MaybeSendFuture

fn set_level( &self, request: SetLevelRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn get_prompt( &self, request: GetPromptRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetPromptResult, ErrorData>> + MaybeSendFuture

fn list_prompts( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListPromptsResult, ErrorData>> + MaybeSendFuture

fn list_resources( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourcesResult, ErrorData>> + MaybeSendFuture

fn list_resource_templates( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourceTemplatesResult, ErrorData>> + MaybeSendFuture

fn read_resource( &self, request: ReadResourceRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ReadResourceResult, ErrorData>> + MaybeSendFuture

fn subscribe( &self, request: SubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn unsubscribe( &self, request: UnsubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn on_custom_request( &self, request: CustomRequest, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CustomResult, ErrorData>> + MaybeSendFuture

fn on_cancelled( &self, notification: CancelledNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_progress( &self, notification: ProgressNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_initialized( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_roots_list_changed( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_task_status( &self, params: TaskStatusNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_custom_notification( &self, notification: CustomNotification, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn list_tasks( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListTasksResult, ErrorData>> + MaybeSendFuture

fn get_task_info( &self, request: GetTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetTaskResult, ErrorData>> + MaybeSendFuture

fn get_task_result( &self, request: GetTaskPayloadParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetTaskPayloadResult, ErrorData>> + MaybeSendFuture

fn cancel_task( &self, request: CancelTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CancelTaskResult, ErrorData>> + MaybeSendFuture