22274043356

Committed 22 Feb 2026 08:56AM UTC coverage: 81.711% (-11.2%) from 92.959%

Build # 22274043356

Build Type

push

github

Committed by

nicholaswilde

Commit Message

chore: Bump version to 0.1.8

Coverage Stats

2359 of 2887 relevant lines covered (81.71%)

5.4 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/server/stdio.rs

use anyhow::Result;
use mcp_sdk_rs::server::Server;
use mcp_sdk_rs::transport::stdio::StdioTransport;
use std::sync::Arc;
use tokio::sync::RwLock;

use crate::aria2::Aria2Client;
use crate::resources::ResourceRegistry;
use crate::server::handler::McpHandler;
use crate::tools::ToolRegistry;

pub async fn run_server(
    registry: Arc<RwLock<ToolRegistry>>,
    resource_registry: Arc<RwLock<ResourceRegistry>>,
    clients: Vec<Arc<Aria2Client>>,
) -> Result<()> {
    let (transport, _sender) = StdioTransport::new();
    let handler = Arc::new(McpHandler::new(registry, resource_registry, clients));
    let server = Server::new(Arc::new(transport), handler);

    server
        .start()
        .await
        .map_err(|e| anyhow::anyhow!("Server error: {:?}", e))?;
    Ok(())
}

#[cfg(test)]
mod tests {
    // We can't easily test run_server as it's blocking
}

1	use anyhow::Result;
2	use mcp_sdk_rs::server::Server;
3	use mcp_sdk_rs::transport::stdio::StdioTransport;
4	use std::sync::Arc;
5	use tokio::sync::RwLock;
6
7	use crate::aria2::Aria2Client;
8	use crate::resources::ResourceRegistry;
9	use crate::server::handler::McpHandler;
10	use crate::tools::ToolRegistry;
11
12	pub async fn run_server(	×
13	registry: Arc<RwLock<ToolRegistry>>,	×
14	resource_registry: Arc<RwLock<ResourceRegistry>>,	×
15	clients: Vec<Arc<Aria2Client>>,	×
16	) -> Result<()> {	×
17	let (transport, _sender) = StdioTransport::new();	×
18	let handler = Arc::new(McpHandler::new(registry, resource_registry, clients));	×
19	let server = Server::new(Arc::new(transport), handler);	×
20
21	server	×
22	.start()	×
23	.await	×
24	.map_err(\|e\| anyhow::anyhow!("Server error: {:?}", e))?;	×
25	Ok(())	×
26	}	×
27
28	#[cfg(test)]
29	mod tests {
30	// We can't easily test run_server as it's blocking
31	}

nicholaswilde / aria2-mcp-rs / 22274043356

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous