blastcode 0.1.0

Incremental code-graph MCP server and blast-radius engine for AI coding agents: file skeletons, call graphs, and impact analysis.
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

use std::io::{BufRead, BufReader, Write};
use std::process::{Command, Stdio};

use serde_json::{json, Value};

#[test]
fn mcp_handshake_list_and_call() {
    let tmp = tempfile::tempdir().unwrap();
    std::fs::write(tmp.path().join("a.py"), "def alpha(x):\n    return x\n").unwrap();

    let mut child = Command::new(env!("CARGO_BIN_EXE_blast"))
        .arg("--root")
        .arg(tmp.path())
        .arg("serve")
        .stdin(Stdio::piped())
        .stdout(Stdio::piped())
        .stderr(Stdio::null())
        .spawn()
        .unwrap();
    let mut stdin = child.stdin.take().unwrap();
    let mut reader = BufReader::new(child.stdout.take().unwrap());

    let mut send = |v: Value| {
        writeln!(stdin, "{}", v).unwrap();
        stdin.flush().unwrap();
    };
    let mut recv = || -> Value {
        let mut line = String::new();
        reader.read_line(&mut line).unwrap();
        serde_json::from_str(&line).unwrap()
    };

    send(json!({"jsonrpc":"2.0","id":1,"method":"initialize","params":{"protocolVersion":"2025-06-18","capabilities":{},"clientInfo":{"name":"t","version":"0"}}}));
    let r = recv();
    assert_eq!(r["id"], 1);
    assert_eq!(r["result"]["serverInfo"]["name"], "blastcode");
    assert_eq!(r["result"]["protocolVersion"], "2025-06-18");

    send(json!({"jsonrpc":"2.0","method":"notifications/initialized"}));

    send(json!({"jsonrpc":"2.0","id":2,"method":"tools/list"}));
    let r = recv();
    let names: Vec<&str> = r["result"]["tools"].as_array().unwrap().iter().map(|t| t["name"].as_str().unwrap()).collect();
    assert_eq!(names.len(), 9);
    assert!(names.contains(&"get_impact_radius"));

    // Background indexing may still be running; poll until the symbol is visible.
    let mut found = false;
    for i in 0..50 {
        send(json!({"jsonrpc":"2.0","id":10+i,"method":"tools/call","params":{"name":"search_symbols","arguments":{"query":"alpha"}}}));
        let r = recv();
        assert_eq!(r["result"]["isError"], false, "{r}");
        let text = r["result"]["content"][0]["text"].as_str().unwrap();
        if text.contains("a.py") {
            found = true;
            break;
        }
        std::thread::sleep(std::time::Duration::from_millis(100));
    }
    assert!(found, "symbol never became searchable");

    send(json!({"jsonrpc":"2.0","id":99,"method":"tools/call","params":{"name":"nope","arguments":{}}}));
    let r = recv();
    assert_eq!(r["error"]["code"], -32602);

    send(json!({"jsonrpc":"2.0","id":100,"method":"does/not/exist"}));
    let r = recv();
    assert_eq!(r["error"]["code"], -32601);

    drop(stdin);
    let _ = child.wait();
}