mcp-runner 0.3.1

A Rust library for running and interacting with Model Context Protocol (MCP) servers locally
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136

use mcp_runner::config::{Config, ServerConfig};
use mcp_runner::error::Result;
use std::collections::HashMap;

#[test]
fn test_parse_config() -> Result<()> {
    let config_str = r#"{
        "mcpServers": {
            "filesystem": {
                "command": "npx",
                "args": ["-y", "@modelcontextprotocol/server-filesystem", "/path/to/files"]
            },
            "github": {
                "command": "npx",
                "args": ["-y", "@modelcontextprotocol/server-github"],
                "env": {
                    "GITHUB_TOKEN": "your_token_here"
                }
            }
        }
    }"#;

    let config = Config::parse_from_str(config_str)?;

    assert_eq!(config.mcp_servers.len(), 2);
    assert!(config.mcp_servers.contains_key("filesystem"));
    assert!(config.mcp_servers.contains_key("github"));

    let fs_config = &config.mcp_servers["filesystem"];
    assert_eq!(fs_config.command, "npx");
    assert_eq!(
        fs_config.args,
        vec![
            "-y",
            "@modelcontextprotocol/server-filesystem",
            "/path/to/files"
        ]
    );
    assert!(fs_config.env.is_empty());

    let gh_config = &config.mcp_servers["github"];
    assert_eq!(gh_config.command, "npx");
    assert_eq!(
        gh_config.args,
        vec!["-y", "@modelcontextprotocol/server-github"]
    );
    assert_eq!(
        gh_config.env.get("GITHUB_TOKEN"),
        Some(&"your_token_here".to_string())
    );

    Ok(())
}

#[test]
fn test_validate_config() -> Result<()> {
    let mut config_map = HashMap::new();

    let fs_config = ServerConfig {
        command: "npx".to_string(),
        args: vec![
            "-y".to_string(),
            "@modelcontextprotocol/server-filesystem".to_string(),
            "/path".to_string(),
        ],
        env: HashMap::new(),
    };

    config_map.insert("filesystem".to_string(), fs_config);

    let gh_config = ServerConfig {
        command: "npx".to_string(),
        args: vec![
            "-y".to_string(),
            "@modelcontextprotocol/server-github".to_string(),
        ],
        env: {
            let mut env = HashMap::new();
            env.insert("GITHUB_TOKEN".to_string(), "token".to_string());
            env
        },
    };

    config_map.insert("github".to_string(), gh_config);

    // Import the validator
    use mcp_runner::config::validate_config;

    // Validate the config
    validate_config(&config_map)?;

    // Test invalid config
    let mut invalid_config = HashMap::new();
    let invalid_server = ServerConfig {
        command: "".to_string(), // Empty command is invalid
        args: vec![],
        env: HashMap::new(),
    };

    invalid_config.insert("invalid".to_string(), invalid_server);

    // This should fail
    assert!(validate_config(&invalid_config).is_err());

    Ok(())
}

#[test]
fn test_parse_claude_config() -> Result<()> {
    let config_str = r#"{
        "mcpServers": {
            "filesystem": {
                "command": "npx",
                "args": ["-y", "@modelcontextprotocol/server-filesystem", "/path/to/allowed/files"]
            }
        }
    }"#;

    let config = Config::parse_from_str(config_str)?;

    assert_eq!(config.mcp_servers.len(), 1);
    assert!(config.mcp_servers.contains_key("filesystem"));

    let fs_config = &config.mcp_servers["filesystem"];
    assert_eq!(fs_config.command, "npx");
    assert_eq!(
        fs_config.args,
        vec![
            "-y",
            "@modelcontextprotocol/server-filesystem",
            "/path/to/allowed/files"
        ]
    );

    Ok(())
}