use rmcp::handler::server::wrapper::Parameters;
use std::path::PathBuf;
use std::sync::Arc;
use tokio::sync::RwLock;
use anyhow::Result;
use rmcp::schemars::{self, JsonSchema};
use rmcp::{
ErrorData, RoleServer, ServerHandler,
handler::server::{router::prompt::PromptRouter, router::tool::ToolRouter},
model::{
GetPromptRequestParam, GetPromptResult, ListPromptsResult, PaginatedRequestParam,
PromptMessage, PromptMessageRole, ServerCapabilities, ServerInfo,
},
prompt, prompt_handler, prompt_router,
service::RequestContext,
tool, tool_handler, tool_router,
};
use serde::{Deserialize, Serialize};
use crate::analysis::tools::{AnalysisTools, AnalyzeCrateStructureParams};
use crate::cache::{
CrateCache,
tools::{
CacheCrateFromCratesIOParams, CacheCrateFromGitHubParams, CacheCrateFromLocalParams,
CacheTools, GetCratesMetadataParams, ListCachedCratesParams, ListCrateVersionsParams,
RemoveCrateParams,
},
};
use crate::deps::tools::{DepsTools, GetDependenciesParams};
use crate::docs::tools::{
DocsTools, GetItemDetailsParams, GetItemDocsParams, GetItemSourceParams, ListItemsParams,
SearchItemsParams, SearchItemsPreviewParams,
};
use crate::search::tools::{SearchItemsFuzzyParams, SearchTools};
#[derive(Debug, Serialize, Deserialize, JsonSchema)]
struct CacheDependenciesArgs {
/// Path to the Cargo.toml file or project directory (defaults to current working directory if not specified)
#[serde(skip_serializing_if = "Option::is_none")]
pub project_path: Option<String>,
/// Optional workspace member name to focus on specific member dependencies
#[serde(skip_serializing_if = "Option::is_none")]
pub member_name: Option<String>,
/// Whether to force re-cache dependencies that are already cached
#[serde(
default,
deserialize_with = "crate::util::deserialize_bool_from_anything"
)]
pub force_update: bool,
}
#[derive(Debug, Clone)]
pub struct RustDocsService {
tool_router: ToolRouter<Self>,
prompt_router: PromptRouter<Self>,
cache_tools: CacheTools,
docs_tools: DocsTools,
deps_tools: DepsTools,
analysis_tools: AnalysisTools,
search_tools: SearchTools,
}
#[tool_router]
impl RustDocsService {
pub fn new(cache_dir: Option<PathBuf>) -> Result<Self> {
let cache = Arc::new(RwLock::new(CrateCache::new(cache_dir)?));
Ok(Self {
tool_router: Self::tool_router(),
prompt_router: Self::prompt_router(),
cache_tools: CacheTools::new(cache.clone()),
docs_tools: DocsTools::new(cache.clone()),
deps_tools: DepsTools::new(cache.clone()),
analysis_tools: AnalysisTools::new(cache.clone()),
search_tools: SearchTools::new(cache),
})
}
// Cache tools
#[tool(
description = "Download and cache a specific crate version from crates.io for offline use. This happens automatically when using other tools, but use this to pre-cache crates. Useful for preparing offline access or ensuring a crate is available before searching."
)]
pub async fn cache_crate_from_cratesio(
&self,
Parameters(params): Parameters<CacheCrateFromCratesIOParams>,
) -> String {
let output = self.cache_tools.cache_crate_from_cratesio(params).await;
output.to_json()
}
#[tool(
description = "Download and cache a specific crate version from GitHub for offline use. Supports cloning from any GitHub repository URL. You must specify either a branch OR a tag (but not both). The crate will be cached using the branch/tag name as the version."
)]
pub async fn cache_crate_from_github(
&self,
Parameters(params): Parameters<CacheCrateFromGitHubParams>,
) -> String {
let output = self.cache_tools.cache_crate_from_github(params).await;
output.to_json()
}
#[tool(
description = "Cache a specific crate version from a local file system path. Supports absolute paths, home paths (~), and relative paths. The specified directory must contain a Cargo.toml file."
)]
pub async fn cache_crate_from_local(
&self,
Parameters(params): Parameters<CacheCrateFromLocalParams>,
) -> String {
let output = self.cache_tools.cache_crate_from_local(params).await;
output.to_json()
}
#[tool(
description = "Remove a cached crate version from local storage. Use to free up disk space or remove outdated versions. This only affects the local cache - the crate can be re-downloaded later if needed."
)]
pub async fn remove_crate(&self, Parameters(params): Parameters<RemoveCrateParams>) -> String {
match self.cache_tools.remove_crate(params).await {
Ok(output) => output.to_json(),
Err(error) => error.to_json(),
}
}
#[tool(
description = "List all locally cached crates with their versions and sizes. Use to see what crates are available offline and how much disk space they use. Shows cache metadata including when each crate was cached."
)]
pub async fn list_cached_crates(
&self,
Parameters(_params): Parameters<ListCachedCratesParams>,
) -> String {
match self.cache_tools.list_cached_crates().await {
Ok(output) => output.to_json(),
Err(error) => error.to_json(),
}
}
#[tool(
description = "List all locally cached versions of a crate. Use to check what versions are available offline without downloading. Useful before calling other tools to verify if a version needs to be cached first."
)]
pub async fn list_crate_versions(
&self,
Parameters(params): Parameters<ListCrateVersionsParams>,
) -> String {
match self.cache_tools.list_crate_versions(params).await {
Ok(output) => output.to_json(),
Err(error) => error.to_json(),
}
}
#[tool(
description = "Get metadata for multiple crates and their workspace members in a single call. Use this to efficiently check the caching and analysis status of multiple crates at once. Returns metadata including caching status, analysis status, and cache sizes for each requested crate and member."
)]
pub async fn get_crates_metadata(
&self,
Parameters(params): Parameters<GetCratesMetadataParams>,
) -> String {
let output = self.cache_tools.get_crates_metadata(params).await;
output.to_json()
}
// Docs tools
#[tool(
description = "List all items in a crate's documentation. Use when browsing a crate's contents without a specific search term. Returns full item details including documentation. For large crates, consider using search_items_preview for a lighter response that only includes names and types. For workspace crates, specify the member parameter with the member path (e.g., 'crates/rmcp')."
)]
pub async fn list_crate_items(
&self,
Parameters(params): Parameters<ListItemsParams>,
) -> String {
match self.docs_tools.list_crate_items(params).await {
Ok(output) => output.to_json(),
Err(error) => error.to_json(),
}
}
#[tool(
description = "Search for items by name pattern in a crate. Use when looking for specific functions, types, or modules. Returns FULL details including documentation. WARNING: May exceed token limits for large results. Use search_items_preview first for exploration, then get_item_details for specific items. For workspace crates, specify the member parameter with the member path (e.g., 'crates/rmcp')."
)]
pub async fn search_items(&self, Parameters(params): Parameters<SearchItemsParams>) -> String {
match self.docs_tools.search_items(params).await {
Ok(output) => output.to_json(),
Err(error) => error.to_json(),
}
}
#[tool(
description = "Search for items by name pattern in a crate - PREVIEW MODE. Use this FIRST when searching to avoid token limits. Returns only id, name, kind, and path. Once you find items of interest, use get_item_details to fetch full documentation. This is the recommended search method for exploration. For workspace crates, specify the member parameter with the member path (e.g., 'crates/rmcp')."
)]
pub async fn search_items_preview(
&self,
Parameters(params): Parameters<SearchItemsPreviewParams>,
) -> String {
match self.docs_tools.search_items_preview(params).await {
Ok(output) => output.to_json(),
Err(error) => error.to_json(),
}
}
#[tool(
description = "Get detailed information about a specific item by ID. Use after search_items_preview to fetch full details including documentation, signatures, fields, methods, etc. The item_id comes from search results. This is the recommended way to get complete information about a specific item. For workspace crates, specify the member parameter with the member path (e.g., 'crates/rmcp')."
)]
pub async fn get_item_details(
&self,
Parameters(params): Parameters<GetItemDetailsParams>,
) -> String {
self.docs_tools.get_item_details(params).await.to_json()
}
#[tool(
description = "Get ONLY the documentation string for a specific item. Use when you need just the docs without other details. More efficient than get_item_details if you only need the documentation text. Returns null if no documentation exists. For workspace crates, specify the member parameter with the member path (e.g., 'crates/rmcp')."
)]
pub async fn get_item_docs(&self, Parameters(params): Parameters<GetItemDocsParams>) -> String {
match self.docs_tools.get_item_docs(params).await {
Ok(output) => output.to_json(),
Err(error) => error.to_json(),
}
}
#[tool(
description = "Get the source code for a specific item. Returns the actual source code with optional context lines. Use after finding items of interest to view their implementation. The source location is also included in get_item_details responses. For workspace crates, specify the member parameter with the member path (e.g., 'crates/rmcp')."
)]
pub async fn get_item_source(
&self,
Parameters(params): Parameters<GetItemSourceParams>,
) -> String {
self.docs_tools.get_item_source(params).await.to_json()
}
// Deps tools
#[tool(
description = "Get dependency information for a crate. Returns direct dependencies by default, with option to include full dependency tree. Use this to understand what a crate depends on, check for version conflicts, or explore the dependency graph. For workspace crates, specify the member parameter with the member path (e.g., 'crates/rmcp')."
)]
pub async fn get_dependencies(
&self,
Parameters(params): Parameters<GetDependenciesParams>,
) -> String {
match self.deps_tools.get_dependencies(params).await {
Ok(output) => output.to_json(),
Err(error) => error.to_json(),
}
}
// Analysis tools
#[tool(
description = "View the hierarchical structure as a tree to view the high level components of the crate. This is a good starting point to have a high-level overview of the crate's organization. This will allow you to narrow down your search confidently to find what you are looking for."
)]
pub async fn structure(
&self,
Parameters(params): Parameters<AnalyzeCrateStructureParams>,
) -> String {
match self.analysis_tools.structure(params).await {
Ok(output) => output.to_json(),
Err(error) => error.to_json(),
}
}
// Search tools
#[tool(
description = "Perform fuzzy search on crate items with typo tolerance and semantic similarity. This provides more flexible searching compared to exact pattern matching, allowing you to find items even with typos or partial matches. The search indexes item names, documentation, and metadata using Tantivy full-text search engine. For workspace crates, specify the member parameter with the member path (e.g., 'crates/rmcp')."
)]
pub async fn search_items_fuzzy(
&self,
Parameters(params): Parameters<SearchItemsFuzzyParams>,
) -> String {
match self.search_tools.search_items_fuzzy(params).await {
Ok(output) => output.to_json(),
Err(error) => error.to_json(),
}
}
}
#[prompt_router]
impl RustDocsService {
#[prompt(
name = "cache_dependencies",
description = "Cache all dependencies from a Rust project's Cargo.toml"
)]
pub async fn cache_dependencies(
&self,
Parameters(args): Parameters<CacheDependenciesArgs>,
_ctx: RequestContext<RoleServer>,
) -> Result<Vec<PromptMessage>, ErrorData> {
let messages = vec![
PromptMessage::new_text(
PromptMessageRole::User,
format!(
"I need to cache all dependencies from the Rust project{}{}. \
Please analyze the Cargo.toml file{} and cache every dependency using the rust-docs MCP caching tools.",
args.project_path
.as_ref()
.map(|p| format!(" at {p}"))
.unwrap_or_else(|| " in the current working directory".to_string()),
args.member_name
.as_ref()
.map(|m| format!(" (focusing on member: {m})"))
.unwrap_or_default(),
if args.force_update {
" and force update existing cached dependencies"
} else {
""
}
),
),
PromptMessage::new_text(
PromptMessageRole::Assistant,
format!(
"I'll help you cache all dependencies from the project{}. \
I'll read the Cargo.toml file{}, analyze all dependencies (including dev-dependencies), \
and cache them using the appropriate rust-docs MCP tools.\n\n\
First, I'll aggregate a list of all dependencies with their:\n\
- Source (crates.io, GitHub, or local absolute path)\n\
- Full semver version (e.g., 4.0.0 not 4.0 - if minor/patch are missing, fill with zeros)\n\n\
Then I'll cache them using:\n\
- For crates.io dependencies: cache_crate_from_cratesio\n\
- For Git dependencies: cache_crate_from_github\n\
- For local path dependencies: cache_crate_from_local\n\n\
Let me start by examining the Cargo.toml file to identify all dependencies.",
args.project_path
.as_ref()
.map(|p| format!(" at '{p}'"))
.unwrap_or_else(|| " in the current working directory".to_string()),
args.member_name
.as_ref()
.map(|m| format!(" (member: {m})"))
.unwrap_or_default()
),
),
];
Ok(messages)
}
}
#[tool_handler]
#[prompt_handler]
impl ServerHandler for RustDocsService {
fn get_info(&self) -> ServerInfo {
ServerInfo {
server_info: rmcp::model::Implementation {
name: "rust-docs-mcp".to_string(),
version: "0.1.1".to_string(),
title: None,
website_url: None,
icons: None,
},
capabilities: ServerCapabilities {
tools: Some(Default::default()),
prompts: Some(Default::default()),
..Default::default()
},
instructions: Some(
"MCP server for analyzing crate structure and querying documentation, dependencies and source code. Use the structure tool to get a high-level overview of the crate's organization before narrowing down your search. Use list_cached_crates to see what crates are already cached and to easily find the crate or member from a workspace crate instead of guessing. Common workflow: search_items_preview to find items quickly by symbol name, then get_item_details to fetch full documentation. For more flexible searching, use search_items_fuzzy which supports typo tolerance and fuzzy matching. Use get_item_source to view the actual source code of items. Use get_dependencies to understand a crate's dependency graph.".to_string(),
),
..Default::default()
}
}
}