Struct AgentBlockClientHandler 

pub struct AgentBlockClientHandler { /* private fields */ }

Custom MCP client handler that holds per-server Lua callback registries.

AgentBlockClientHandler is cloned into each RunningService<RoleClient, _>. The inner Arc<Mutex<…>> lets all clones share the same registry map so that a callback registered via the Lua bridge after connect is immediately visible to the handler running on the rmcp task.

The server_name field is set per-connection (by McpManager::connect / connect_http) before clone() so that create_message can look up the correct sampling handler by server name without needing the RequestContext to carry server identity.

Subtask evolution

• Subtask 1: skeleton — all notification methods are the default no-ops from rmcp.
• Subtask 2: on_progress wired to handler_isle bytecode forwarding.
• Subtask 3: on_logging_message log bridge + create_message sampling skeleton.
• Subtask 4: progress/log notifications dispatched to main Isle via exec so user callbacks run with their upvalues intact (no bytecode dump/reload across VMs).
• Subtask 5 (M-3): bounded notification channel replaces per-notification spawns to cap memory growth when a chatty server floods notifications faster than Lua can consume them.

Implementations

impl AgentBlockClientHandler

pub fn new() -> Self

Create a handler with an empty registry (no notification dispatch).

Used in concurrency tests and contexts where no Isle is available. Notifications received while main_isle is None are silently dropped (no Lua callback can execute without an Isle).

pub fn mark_on_progress(&self, server_name: &str)

Mark that a Lua on_progress handler has been installed on the handler Isle for the given server.

pub fn mark_on_log(&self, server_name: &str)

Mark that a Lua on_log handler has been installed on the handler Isle.

pub fn mark_on_resource_updated(&self, server_name: &str)

Mark that a Lua on_resource_updated handler has been installed.

pub fn mark_on_resource_list_changed(&self, server_name: &str)

Mark that a Lua on_resource_list_changed handler has been installed.

pub fn mark_on_tool_list_changed(&self, server_name: &str)

Mark that a Lua on_tool_list_changed handler has been installed.

pub fn mark_on_prompt_list_changed(&self, server_name: &str)

Mark that a Lua on_prompt_list_changed handler has been installed.

pub fn trace_context_enabled(&self, server_name: &str) -> bool

Return whether trace context injection is enabled for the named server.

pub fn mark_sampling(&self, server_name: &str)

Mark that a Lua sampling handler has been installed on the handler Isle.

pub fn mark_roots(&self, server_name: &str)

Mark that a Lua roots handler has been installed on the handler Isle.

Arguments

• server_name — the server for which the roots handler was registered.

Side effects

Creates a registry entry for the server if one does not yet exist, then sets roots = true so that list_roots requests are dispatched to the Lua callback rather than returning method_not_found.

pub fn mark_elicitation(&self, server_name: &str)

Mark that a Lua elicitation handler has been installed on the handler Isle.

Arguments

• server_name — the server for which the elicitation handler was registered.

Side effects

Creates a registry entry for the server if one does not yet exist, then sets elicitation = true so that create_elicitation requests are dispatched to the Lua callback rather than returning Decline (no-handler path).

Trait Implementations

impl ClientHandler for AgentBlockClientHandler

fn list_roots( &self, _context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<ListRootsResult, McpError>> + Send + '_

Handle an inbound roots/list request that arrives from the MCP server.

The server sends roots/list to ask the client which filesystem roots are available. This is a server→client request; the implementation looks up the Lua callback registered via mcp.set_roots_handler and returns its result.

Returns

• Ok(ListRootsResult) containing the roots the Lua handler returned.
• Err(McpError::method_not_found) when no server name is wired, no roots handler is registered, or no handler Isle is available.
• Err(McpError::internal_error) when the handler Isle exec fails or the Lua result cannot be parsed.

fn create_elicitation( &self, request: CreateElicitationRequestParams, _context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<CreateElicitationResult, McpError>> + Send + '_

Handle an inbound elicitation/create request that arrives from the MCP server.

The server sends elicitation/create to ask the client to gather user input. This is a server→client request. Form variant is dispatched to the Lua callback registered via mcp.set_elicitation_handler; Url variant is always declined without reaching the Lua layer (crux Form-only dispatch constraint).

Returns

• Ok(CreateElicitationResult { action: Accept, content: Some(json), .. }) on accept.
• Ok(CreateElicitationResult { action: Decline, .. }) on decline, cancel-as-decline, Url variant, or no handler registered (spec neutral — not an error).
• Ok(CreateElicitationResult { action: Cancel, .. }) on cancel.
• Err(McpError::method_not_found) when no server name is wired or no handler Isle is available (mirrors list_roots).
• Err(McpError::internal_error) when the handler Isle exec fails or the Lua result fails 3-action contract validation.

fn on_progress( &self, params: ProgressNotificationParam, _context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + Send + '_

fn on_logging_message( &self, params: LoggingMessageNotificationParam, _context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + Send + '_

fn on_resource_updated( &self, params: ResourceUpdatedNotificationParam, _context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + Send + '_

fn on_resource_list_changed( &self, _context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + Send + '_

fn on_tool_list_changed( &self, _context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + Send + '_

fn on_prompt_list_changed( &self, _context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + Send + '_

fn create_message( &self, params: CreateMessageRequestParams, _context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<CreateMessageResult, McpError>> + Send + '_

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

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

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

fn on_url_elicitation_notification_complete( &self, params: ElicitationResponseNotificationParam, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture

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

fn get_info(&self) -> InitializeRequestParams

impl Clone for AgentBlockClientHandler

fn clone(&self) -> AgentBlockClientHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for AgentBlockClientHandler

fn default() -> Self

Returns the “default value” for a type.