Struct CodeAnalyzer 

pub struct CodeAnalyzer { /* private fields */ }

MCP server handler that wires the four analysis tools to the rmcp transport.

Holds shared state: tool router, analysis cache, peer connection, log-level filter, log event channel, metrics sender, and per-session sequence tracking.

Implementations

impl CodeAnalyzer

pub fn list_tools() -> Vec<Tool>

pub fn new( peer: Arc<TokioMutex<Option<Peer<RoleServer>>>>, metrics_tx: MetricsSender, ) -> Self

pub fn analyze_directory_tool_attr() -> Tool

Generated tool metadata function for analyze_directory

pub fn analyze_file_tool_attr() -> Tool

Generated tool metadata function for analyze_file

pub fn analyze_symbol_tool_attr() -> Tool

Generated tool metadata function for analyze_symbol

pub fn analyze_module_tool_attr() -> Tool

Generated tool metadata function for analyze_module

pub fn edit_overwrite_tool_attr() -> Tool

Generated tool metadata function for edit_overwrite

pub fn edit_replace_tool_attr() -> Tool

Generated tool metadata function for edit_replace

pub fn exec_command_tool_attr() -> Tool

Generated tool metadata function for exec_command

pub fn exec_command( &self, params: Parameters<ExecCommandParams>, context: RequestContext<RoleServer>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, ErrorData>> + Send + '_>>

Trait Implementations

impl Clone for CodeAnalyzer

fn clone(&self) -> CodeAnalyzer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServerHandler for CodeAnalyzer

async fn discover( &self, _context: RequestContext<RoleServer>, ) -> Result<DiscoverResult, ErrorData>

Returns server discovery information including supported protocol versions and capabilities.

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

fn get_info(&self) -> InitializeResult

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

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

Handle a tools/call request from a client.

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

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

async fn read_resource( &self, request: ReadResourceRequestParams, _context: RequestContext<RoleServer>, ) -> Result<ReadResourceResponse, ErrorData>

async fn on_initialized(&self, context: NotificationContext<RoleServer>)

async fn on_cancelled( &self, notification: CancelledNotificationParam, _context: NotificationContext<RoleServer>, )

async fn complete( &self, request: CompleteRequestParams, _context: RequestContext<RoleServer>, ) -> Result<CompleteResult, ErrorData>

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

Get a tool definition by name.

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

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

Return the protocol versions supported by this server.

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

fn on_progress( &self, notification: ProgressNotificationParam, 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.