Extend MCP endpoint with tools, resources, and prompts

Add comprehensive MCP capabilities:

Tools:
- list_weavers: List weavers owned by user
- get_weaver: Get weaver details
- delete_weaver: Delete a weaver
- attach_weaver: Get connection info for weaver

Resources (loom:// URIs):
- threads, threads/{id}, threads/{id}/messages
- repos, repos/{id}
- weavers, weavers/{id}

Prompts:
- create-weaver: Recommended settings by language
- code-review: Code review assistance
- debug-session: Debugging help
- explain-code: Code explanation
- write-tests: Test generation

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: ghuntley

crates/loom-server/src/routes/mcp/handler.rs

@@ -15,10 +15,10 @@ use crate::{api::AppState, auth_middleware::RequireAuth};
 
 use super::{
 	error::{McpError, McpErrorResponse},
-	tools,
+	prompts, resources, tools,
 	types::{
-		InitializeParams, InitializeResult, JsonRpcRequest, JsonRpcResponse, ToolsCallParams,
-		ToolsListResult, JSONRPC_VERSION,
+		InitializeParams, InitializeResult, JsonRpcRequest, JsonRpcResponse, PromptsGetParams,
+		ResourcesReadParams, ToolsCallParams, ToolsListResult, JSONRPC_VERSION,
 	},
 };
 
@@ -94,6 +94,11 @@ async fn route_method(
 		"notifications/initialized" => handle_initialized_notification(request),
 		"tools/list" => handle_tools_list(request),
 		"tools/call" => handle_tools_call(state, current_user, request).await,
+		"resources/list" => handle_resources_list(state, current_user, request).await,
+		"resources/read" => handle_resources_read(state, current_user, request).await,
+		"resources/templates/list" => handle_resource_templates_list(request),
+		"prompts/list" => handle_prompts_list(request),
+		"prompts/get" => handle_prompts_get(request),
 		"ping" => handle_ping(request),
 		_ => Err(McpError::MethodNotFound(request.method.clone())),
 	}
@@ -221,6 +226,87 @@ fn handle_ping(request: &JsonRpcRequest) -> Result<(JsonRpcResponse, Option<Stri
 	Ok((response, None))
 }
 
+/// Handle the resources/list method.
+async fn handle_resources_list(
+	state: &AppState,
+	current_user: &loom_server_auth::CurrentUser,
+	request: &JsonRpcRequest,
+) -> Result<(JsonRpcResponse, Option<String>), McpError> {
+	tracing::info!(
+		user_id = %current_user.user.id,
+		"MCP resources/list request"
+	);
+
+	let result = resources::list_resources(state, current_user).await?;
+	let response = JsonRpcResponse::success(request.id.clone(), serde_json::to_value(result)?);
+	Ok((response, None))
+}
+
+/// Handle the resources/read method.
+async fn handle_resources_read(
+	state: &AppState,
+	current_user: &loom_server_auth::CurrentUser,
+	request: &JsonRpcRequest,
+) -> Result<(JsonRpcResponse, Option<String>), McpError> {
+	let params: ResourcesReadParams = request
+		.params
+		.as_ref()
+		.map(|v| serde_json::from_value(v.clone()))
+		.transpose()
+		.map_err(|e| McpError::InvalidParams(format!("Invalid resources/read params: {e}")))?
+		.ok_or_else(|| McpError::InvalidParams("resources/read requires params".to_string()))?;
+
+	tracing::info!(
+		uri = %params.uri,
+		user_id = %current_user.user.id,
+		"MCP resources/read request"
+	);
+
+	let result = resources::read_resource(state, current_user, &params.uri).await?;
+	let response = JsonRpcResponse::success(request.id.clone(), serde_json::to_value(result)?);
+	Ok((response, None))
+}
+
+/// Handle the resources/templates/list method.
+fn handle_resource_templates_list(
+	request: &JsonRpcRequest,
+) -> Result<(JsonRpcResponse, Option<String>), McpError> {
+	let result = resources::list_resource_templates();
+	let response = JsonRpcResponse::success(request.id.clone(), serde_json::to_value(result)?);
+	Ok((response, None))
+}
+
+/// Handle the prompts/list method.
+fn handle_prompts_list(
+	request: &JsonRpcRequest,
+) -> Result<(JsonRpcResponse, Option<String>), McpError> {
+	let result = prompts::list_prompts();
+	let response = JsonRpcResponse::success(request.id.clone(), serde_json::to_value(result)?);
+	Ok((response, None))
+}
+
+/// Handle the prompts/get method.
+fn handle_prompts_get(
+	request: &JsonRpcRequest,
+) -> Result<(JsonRpcResponse, Option<String>), McpError> {
+	let params: PromptsGetParams = request
+		.params
+		.as_ref()
+		.map(|v| serde_json::from_value(v.clone()))
+		.transpose()
+		.map_err(|e| McpError::InvalidParams(format!("Invalid prompts/get params: {e}")))?
+		.ok_or_else(|| McpError::InvalidParams("prompts/get requires params".to_string()))?;
+
+	tracing::info!(
+		prompt_name = %params.name,
+		"MCP prompts/get request"
+	);
+
+	let result = prompts::get_prompt(&params.name, &params.arguments)?;
+	let response = JsonRpcResponse::success(request.id.clone(), serde_json::to_value(result)?);
+	Ok((response, None))
+}
+
 impl From<serde_json::Error> for McpError {
 	fn from(err: serde_json::Error) -> Self {
 		McpError::Internal(format!("JSON serialization error: {err}"))

crates/loom-server/src/routes/mcp/mod.rs

@@ -12,9 +12,32 @@
 //! - Format: JSON-RPC 2.0
 //! - Version: MCP 2025-11-25
 //!
-//! ## Available Tools
+//! ## Capabilities
 //!
-//! - `create_weaver`: Create an ephemeral Kubernetes pod for code execution
+//! ### Tools
+//!
+//! - `create_weaver`: Create an ephemeral Kubernetes pod
+//! - `list_weavers`: List weavers owned by the user
+//! - `get_weaver`: Get details of a specific weaver
+//! - `delete_weaver`: Delete a weaver
+//! - `attach_weaver`: Get connection info for a weaver
+//!
+//! ### Resources
+//!
+//! - `loom://threads` - List conversation threads
+//! - `loom://threads/{id}` - Thread details with messages
+//! - `loom://repos` - List connected repositories
+//! - `loom://repos/{id}` - Repository details
+//! - `loom://weavers` - List active weavers
+//! - `loom://weavers/{id}` - Weaver details
+//!
+//! ### Prompts
+//!
+//! - `create-weaver`: Create weaver with recommended settings
+//! - `code-review`: Code review assistance
+//! - `debug-session`: Debugging session
+//! - `explain-code`: Code explanation
+//! - `write-tests`: Test generation
 //!
 //! ## Example Usage
 //!
@@ -36,24 +59,19 @@
 //! POST /mcp
 //! { "jsonrpc": "2.0", "method": "tools/list", "id": 2 }
 //!
-//! // Call create_weaver
+//! // List resources
 //! POST /mcp
-//! {
-//!   "jsonrpc": "2.0",
-//!   "method": "tools/call",
-//!   "params": {
-//!     "name": "create_weaver",
-//!     "arguments": {
-//!       "image": "python:3.12",
-//!       "org_id": "550e8400-e29b-41d4-a716-446655440000"
-//!     }
-//!   },
-//!   "id": 3
-//! }
+//! { "jsonrpc": "2.0", "method": "resources/list", "id": 3 }
+//!
+//! // List prompts
+//! POST /mcp
+//! { "jsonrpc": "2.0", "method": "prompts/list", "id": 4 }
 //! ```
 
 mod error;
 mod handler;
+mod prompts;
+mod resources;
 pub mod session;
 mod tools;
 mod types;