warmplane 0.30.0

Local control plane that keeps MCP sessions warm with compact capability/resource/prompt facades.
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

// Rust guideline compliant 2026-08-29

//! Integration tests for MCP list_changed notifications (tools, resources, prompts) in Warmplane.

use serde_json::json;
use tempfile::NamedTempFile;
use tokio::{
    io::{AsyncWriteExt, BufReader},
    process::Command,
};

mod common;
use common::read_jsonrpc_until_id;
use warmplane::config::{save_config, AliasTarget, McpConfig};

#[tokio::test]
async fn test_mcp_list_changed_notifications_and_discovery_hint() {
    let bin_path = env!("CARGO_BIN_EXE_warmplane");

    let temp_config = NamedTempFile::new().unwrap();
    let config_path = temp_config.path().to_str().unwrap().to_string();

    let mcp_config = McpConfig::default();
    save_config(&config_path, &mcp_config).unwrap();

    let mut child = Command::new(bin_path)
        .arg("mcp-server")
        .arg("--config")
        .arg(&config_path)
        .stdin(std::process::Stdio::piped())
        .stdout(std::process::Stdio::piped())
        .stderr(std::process::Stdio::inherit())
        .spawn()
        .expect("failed to spawn warmplane mcp-server");

    let mut stdin = child.stdin.take().expect("failed to open stdin");
    let stdout = child.stdout.take().expect("failed to open stdout");
    let mut reader = BufReader::new(stdout);

    // 1. Initialize MCP session and verify advertised capabilities
    let init_req = json!({
        "jsonrpc": "2.0",
        "id": 1,
        "method": "initialize",
        "params": {
            "protocolVersion": "2024-11-05",
            "capabilities": {},
            "clientInfo": {
                "name": "test-client",
                "version": "1.0.0"
            }
        }
    });
    stdin
        .write_all(format!("{}\n", init_req).as_bytes())
        .await
        .unwrap();
    stdin.flush().await.unwrap();

    let init_resp = read_jsonrpc_until_id(&mut reader, 1).await;
    let caps = init_resp["result"]["capabilities"].clone();
    assert_eq!(
        caps["tools"]["listChanged"], true,
        "tools.listChanged must be advertised"
    );
    assert_eq!(
        caps["resources"]["listChanged"], true,
        "resources.listChanged must be advertised"
    );
    assert_eq!(
        caps["prompts"]["listChanged"], true,
        "prompts.listChanged must be advertised"
    );

    // Initialized notification
    let initialized_notif = json!({
        "jsonrpc": "2.0",
        "method": "notifications/initialized",
        "params": {}
    });
    stdin
        .write_all(format!("{}\n", initialized_notif).as_bytes())
        .await
        .unwrap();
    stdin.flush().await.unwrap();

    // 2. Trigger alias addition via CLI / config mutation
    let mut updated_config = mcp_config.clone();
    updated_config.capability_aliases.insert(
        "search_live".to_string(),
        AliasTarget::Detailed {
            target: "mock.search".to_string(),
            summary: Some("Search live docs".to_string()),
            description: None,
            passthrough: true,
        },
    );
    save_config(&config_path, &updated_config).unwrap();

    // 3. Inspect tools list
    let list_req = json!({
        "jsonrpc": "2.0",
        "id": 2,
        "method": "tools/list",
        "params": {}
    });
    stdin
        .write_all(format!("{}\n", list_req).as_bytes())
        .await
        .unwrap();
    stdin.flush().await.unwrap();

    let list_resp = read_jsonrpc_until_id(&mut reader, 2).await;
    let tools = list_resp["result"]["tools"].as_array().unwrap();
    let has_search_live = tools.iter().any(|t| t["name"] == "search_live");
    assert!(
        has_search_live,
        "Newly added passthrough alias 'search_live' must be visible in tools/list"
    );

    // Clean up
    let _ = child.kill().await;
}