Struct Bus 

pub struct Bus {
    pub db: PgPool,
    pub hub: EventHub,
    pub backends: Backends,
    pub tool_router: ToolRouter<Self>,
}

The MCP server. Cheap to clone: PgPool and EventHub are Arcs internally, and the tool router is rebuilt per session by the transport’s service factory.

Fields

db: PgPool

hub: EventHub

backends: Backends

Where each conversation’s bodies live. Postgres for everyone unless an operator routed a team elsewhere and started the server with a broker.

tool_router: ToolRouter<Self>

Implementations

impl Bus

pub fn attach_file_tool_attr() -> Tool

Generated tool metadata function for attach_file

pub fn get_attachment_tool_attr() -> Tool

Generated tool metadata function for get_attachment

pub fn attachments_router() -> ToolRouter<Self>

impl Bus

pub fn create_conversation_tool_attr() -> Tool

Generated tool metadata function for create_conversation

pub fn list_conversations_tool_attr() -> Tool

Generated tool metadata function for list_conversations

pub fn invite_to_conversation_tool_attr() -> Tool

Generated tool metadata function for invite_to_conversation

pub fn join_conversation_tool_attr() -> Tool

Generated tool metadata function for join_conversation

pub fn leave_conversation_tool_attr() -> Tool

Generated tool metadata function for leave_conversation

pub fn remove_conversation_member_tool_attr() -> Tool

Generated tool metadata function for remove_conversation_member

pub fn archive_conversation_tool_attr() -> Tool

Generated tool metadata function for archive_conversation

pub fn transfer_membership_tool_attr() -> Tool

Generated tool metadata function for transfer_membership

pub fn send_conversation_message_tool_attr() -> Tool

Generated tool metadata function for send_conversation_message

pub fn read_conversation_tool_attr() -> Tool

Generated tool metadata function for read_conversation

pub fn get_conversation_message_tool_attr() -> Tool

Generated tool metadata function for get_conversation_message

pub fn ack_message_tool_attr() -> Tool

Generated tool metadata function for ack_message

pub fn get_message_receipts_tool_attr() -> Tool

Generated tool metadata function for get_message_receipts

pub fn fetch_conversation_inbox_tool_attr() -> Tool

Generated tool metadata function for fetch_conversation_inbox

pub fn confirm_inbox_delivery_tool_attr() -> Tool

Generated tool metadata function for confirm_inbox_delivery

pub fn conversation_inbox_status_tool_attr() -> Tool

Generated tool metadata function for conversation_inbox_status

pub fn wait_for_conversation_updates_tool_attr() -> Tool

Generated tool metadata function for wait_for_conversation_updates

pub fn create_project_tool_attr() -> Tool

Generated tool metadata function for create_project

pub fn list_projects_tool_attr() -> Tool

Generated tool metadata function for list_projects

pub fn grant_project_access_tool_attr() -> Tool

Generated tool metadata function for grant_project_access

pub fn recover_conversation_history_tool_attr() -> Tool

Generated tool metadata function for recover_conversation_history

pub fn conversations_router() -> ToolRouter<Self>

impl Bus

pub fn wait_for_updates_tool_attr() -> Tool

Generated tool metadata function for wait_for_updates

pub fn events_router() -> ToolRouter<Self>

impl Bus

pub fn acquire_lock_tool_attr() -> Tool

Generated tool metadata function for acquire_lock

pub fn release_lock_tool_attr() -> Tool

Generated tool metadata function for release_lock

pub fn list_locks_tool_attr() -> Tool

Generated tool metadata function for list_locks

pub fn locks_router() -> ToolRouter<Self>

impl Bus

pub fn list_channels_tool_attr() -> Tool

Generated tool metadata function for list_channels

pub fn create_channel_tool_attr() -> Tool

Generated tool metadata function for create_channel

pub fn post_message_tool_attr() -> Tool

Generated tool metadata function for post_message

pub fn read_messages_tool_attr() -> Tool

Generated tool metadata function for read_messages

pub fn ask_agent_tool_attr() -> Tool

Generated tool metadata function for ask_agent

pub fn search_messages_tool_attr() -> Tool

Generated tool metadata function for search_messages

pub fn messaging_router() -> ToolRouter<Self>

impl Bus

pub fn set_note_tool_attr() -> Tool

Generated tool metadata function for set_note

pub fn get_note_tool_attr() -> Tool

Generated tool metadata function for get_note

pub fn list_notes_tool_attr() -> Tool

Generated tool metadata function for list_notes

pub fn search_notes_tool_attr() -> Tool

Generated tool metadata function for search_notes

pub fn delete_note_tool_attr() -> Tool

Generated tool metadata function for delete_note

pub fn notes_router() -> ToolRouter<Self>

impl Bus

pub fn heartbeat_tool_attr() -> Tool

Generated tool metadata function for heartbeat

pub fn list_agents_tool_attr() -> Tool

Generated tool metadata function for list_agents

pub fn list_sessions_tool_attr() -> Tool

Generated tool metadata function for list_sessions

pub fn presence_router() -> ToolRouter<Self>

impl Bus

pub fn create_task_tool_attr() -> Tool

Generated tool metadata function for create_task

pub fn list_tasks_tool_attr() -> Tool

Generated tool metadata function for list_tasks

pub fn get_task_tool_attr() -> Tool

Generated tool metadata function for get_task

pub fn claim_task_tool_attr() -> Tool

Generated tool metadata function for claim_task

pub fn claim_next_task_tool_attr() -> Tool

Generated tool metadata function for claim_next_task

pub fn renew_task_lease_tool_attr() -> Tool

Generated tool metadata function for renew_task_lease

pub fn release_task_tool_attr() -> Tool

Generated tool metadata function for release_task

pub fn complete_task_tool_attr() -> Tool

Generated tool metadata function for complete_task

pub fn tasks_router() -> ToolRouter<Self>

impl Bus

pub fn new(db: PgPool, hub: EventHub) -> Self

The default installation: every body in Postgres, no broker.

pub fn with_backends(db: PgPool, hub: EventHub, backends: Backends) -> Self

impl Bus

pub fn whoami_tool_attr() -> Tool

Generated tool metadata function for whoami

pub fn team_digest_tool_attr() -> Tool

Generated tool metadata function for team_digest

pub fn core_router() -> ToolRouter<Self>

impl Bus

pub fn register_session_tool_attr() -> Tool

Generated tool metadata function for register_session

pub fn resume_session_tool_attr() -> Tool

Generated tool metadata function for resume_session

pub fn renew_session_tool_attr() -> Tool

Generated tool metadata function for renew_session

pub fn revoke_session_tool_attr() -> Tool

Generated tool metadata function for revoke_session

pub fn sessions_router() -> ToolRouter<Self>

Trait Implementations

impl Clone for Bus

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServerHandler for Bus

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

The catalogue this caller’s team actually has.

An off capability is not only a refusal at call time: advertising eighteen tools that every call rejects is a catalogue that lies, and the model reading it wastes a turn finding out. The per-call check stays exactly where it was — a catalogue is not an authorization boundary.

fn get_info(&self) -> ServerConfig

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

Handle a tools/call request from a client.

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

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

fn negotiate_initialize( &self, request: &InitializeRequestParams, ) -> Result<InitializeResult, ErrorData>

Build the initialize response for request, negotiating the protocol version against Self::supported_protocol_versions.

fn supported_protocol_versions(&self) -> Cow<'static, [ProtocolVersion]>

Return the protocol versions supported by this server.

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

Return this server’s discovery information.

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<GetPromptResponse, 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<ReadResourceResponse, ErrorData>> + MaybeSendFuture

fn accepted_subscription_filter( &self, requested: &SubscriptionFilter, ) -> Option<SubscriptionFilter>

Return the subset of a requested notification filter this server accepts.

fn listen( &self, context: SubscriptionContext, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

Run one established subscription until it is cancelled or closed gracefully.

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

👎Deprecated:

resources/subscribe is legacy-only; implement accepted_subscription_filter and listen for protocol version 2026-07-28

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

👎Deprecated:

resources/unsubscribe is legacy-only; subscriptions/listen is cancelled through its request lifecycle

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

Get a tool definition by name.

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_custom_notification( &self, notification: CustomNotification, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

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

SEP-2663 tasks/get: return the current DetailedTask state.

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

SEP-2663 tasks/update: accept responses to outstanding in-task input requests. Returns an empty acknowledgement on success.

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

SEP-2663 tasks/cancel: cooperative cancellation. Returns an empty acknowledgement; the task’s observable status may lag.