Struct ForgeServer 

pub struct ForgeServer { /* private fields */ }

The Forge MCP server handler.

Implements ServerHandler from rmcp to serve the search and execute Code Mode tools over MCP stdio or SSE transport.

Implementations

impl ForgeServer

pub fn new( config: SandboxConfig, manifest: Manifest, dispatcher: Arc<dyn ToolDispatcher>, resource_dispatcher: Option<Arc<dyn ResourceDispatcher>>, ) -> Self

Create a new Forge server with the given config, manifest, dispatcher, and optional resource dispatcher.

pub fn with_group_policy(self, policy: GroupPolicy) -> Self

Set a group policy for cross-server data flow enforcement.

When set, each execute() call wraps the dispatcher with a fresh GroupEnforcingDispatcher that tracks group access for that execution. If a resource dispatcher is also configured, it is wrapped with a GroupEnforcingResourceDispatcher sharing the same lock.

pub fn with_stash(self, config: StashConfig) -> Self

Enable the session stash with the given configuration.

When enabled, forge.stash.put/get/delete/keys() are available in sandbox execute mode.

pub fn new_with_executor( executor: SandboxExecutor, manifest: Manifest, dispatcher: Arc<dyn ToolDispatcher>, resource_dispatcher: Option<Arc<dyn ResourceDispatcher>>, ) -> Self

Create a new Forge server with a pre-configured executor.

Use this when you need to attach a worker pool to the executor before wrapping it in the server.

pub fn live_manifest(&self) -> &LiveManifest

Get a reference to the live manifest for external updates.

Background tasks can call LiveManifest::update() to refresh the manifest without restarting the server.

impl ForgeServer

pub fn search_tool_attr() -> Tool

Generated tool metadata function for search

pub fn search( &self, Parameters: Parameters<SearchInput>, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + '_>>

Search the capability manifest to discover available tools across all connected servers. The manifest is available as globalThis.manifest.

pub fn execute_tool_attr() -> Tool

Generated tool metadata function for execute

pub fn execute( &self, Parameters: Parameters<ExecuteInput>, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + '_>>

Execute code against the tool API in a sandboxed V8 isolate.

Trait Implementations

impl Clone for ForgeServer

fn clone(&self) -> ForgeServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServerHandler for ForgeServer

fn get_info(&self) -> ServerInfo

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

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

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>> + Send

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

fn initialize( &self, request: InitializeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<InitializeResult, ErrorData>> + Send

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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