Struct RoverHandler 

pub struct RoverHandler { /* private fields */ }

State shared across all MCP tool invocations.

Note: this struct no longer carries its own scheduler Sender. Every storage::tasks::insert call notifies the scheduler via the Db-owned notifier installed by mcp::server::serve_stdio, so the MCP tool layer has no extra wiring to do — it just inserts.

Implementations

impl RoverHandler

pub fn new( db: Db, config: Arc<Config>, client: Client, ssrf_level: SsrfLevel, ssrf_project_root: Option<PathBuf>, har_recorder: Option<Arc<HarRecorder>>, pacer: Arc<Pacer>, summarizer: Arc<SummarizerService>, captioners: Arc<CaptionerRegistry>, guard: Arc<Guard>, ) -> Self

impl RoverHandler

pub fn fetch_tool_tool_attr() -> Tool

Generated tool metadata function for fetch_tool

pub fn fetch_tool( &self, Parameters: Parameters<FetchArgs>, ) -> Pin<Box<dyn Future<Output = Result<Json<FetchOutput>, ErrorData>> + Send + '_>>

Fetch a URL and return cleaned Markdown with frontmatter.

pub fn count_tokens_tool_tool_attr() -> Tool

Generated tool metadata function for count_tokens_tool

pub fn count_tokens_tool( &self, Parameters: Parameters<CountTokensArgs>, ) -> Pin<Box<dyn Future<Output = Result<Json<CountResponse>, ErrorData>> + Send + '_>>

Count tokens in either an inline text or a fetched url.

pub fn get_metadata_tool_tool_attr() -> Tool

Generated tool metadata function for get_metadata_tool

pub fn get_metadata_tool( &self, Parameters: Parameters<GetMetadataArgs>, ) -> Pin<Box<dyn Future<Output = Result<Json<MetadataResponse>, ErrorData>> + Send + '_>>

Fetch a URL and return ONLY its structured metadata (no markdown body).

pub fn summarize_tool_tool_attr() -> Tool

Generated tool metadata function for summarize_tool

pub fn summarize_tool( &self, Parameters: Parameters<SummarizeArgs>, ) -> Pin<Box<dyn Future<Output = Result<Json<SummarizeResponse>, ErrorData>> + Send + '_>>

Apply summarization to a URL’s cached or freshly-fetched markdown.

pub fn batch_fetch_tool_tool_attr() -> Tool

Generated tool metadata function for batch_fetch_tool

pub fn batch_fetch_tool( &self, Parameters: Parameters<BatchFetchArgs>, ) -> Pin<Box<dyn Future<Output = Result<Json<TaskCreatedResponse>, ErrorData>> + Send + '_>>

Fetch multiple URLs concurrently in the background.

impl RoverHandler

pub async fn batch_fetch_inner( &self, args: BatchFetchArgs, ) -> Result<TaskCreatedResponse, McpError>

Tool body, decoupled from the #[tool] macro for unit testing.

impl RoverHandler

pub async fn count_tokens_inner( &self, args: CountTokensArgs, ) -> Result<CountResponse, McpError>

Tool body, decoupled from the #[tool] macro for unit testing.

impl RoverHandler

pub async fn fetch_inner( &self, args: FetchArgs, ) -> Result<FetchOutput, McpError>

Tool body, decoupled from the #[tool] macro for unit testing. Task 11 wires this into the router; here it’s a plain async method.

impl RoverHandler

pub async fn get_metadata_inner( &self, args: GetMetadataArgs, ) -> Result<MetadataResponse, McpError>

impl RoverHandler

pub async fn summarize_inner( &self, args: SummarizeArgs, ) -> Result<SummarizeResponse, McpError>

Tool body, decoupled from the #[tool] macro for unit testing.

Trait Implementations

impl Clone for RoverHandler

fn clone(&self) -> RoverHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServerHandler for RoverHandler

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

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 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_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: GetTaskInfoParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetTaskResult, ErrorData>> + MaybeSendFuture

fn get_task_result( &self, request: GetTaskResultParams, 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