episteme 0.3.7

Knowledge graph for software engineering — design patterns, refactorings, and laws for AI agents
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

use serde_json::{Value, json};

use crate::server::mcp_handler::EpistemeMCP;
use crate::server::mcp_schemas;

/// Dispatch a single JSON-RPC 2.0 request against the MCP handler.
///
/// Returns `None` for notifications (no response expected).
/// Returns `Some(response)` for requests that expect a response.
pub fn dispatch(mcp: &EpistemeMCP, request: Value) -> Option<Value> {
    let method = request.get("method").and_then(|v| v.as_str()).unwrap_or("");
    let params = request.get("params").cloned().unwrap_or(json!({}));
    let req_id = request.get("id").cloned();

    match method {
        // -- protocol lifecycle ------------------------------------------------
        "initialize" => Some(json!({
            "jsonrpc": "2.0",
            "id": req_id,
            "result": {
                "protocolVersion": mcp_schemas::PROTOCOL_VERSION,
                "capabilities": mcp_schemas::capabilities(),
                "serverInfo": mcp_schemas::server_info(),
                "instructions": mcp_schemas::server_instructions(),
            },
        })),

        "notifications/initialized" => None,

        "ping" => Some(json!({
            "jsonrpc": "2.0",
            "id": req_id,
            "result": {},
        })),

        // -- tools -------------------------------------------------------------
        "tools/list" => Some(json!({
            "jsonrpc": "2.0",
            "id": req_id,
            "result": {
                "tools": mcp_schemas::tool_schemas(),
            },
        })),

        "tools/call" => {
            let tool_name = params.get("name").and_then(|v| v.as_str()).unwrap_or("");
            let arguments = params.get("arguments").cloned().unwrap_or(json!({}));

            let result = mcp.handle_tool_call(tool_name, &arguments);
            Some(tool_text_response(req_id, result))
        }

        // -- resources ---------------------------------------------------------
        "resources/list" => Some(json!({
            "jsonrpc": "2.0",
            "id": req_id,
            "result": {
                "resources": mcp_schemas::resource_schemas(),
            },
        })),

        "resources/read" => {
            let uri = params.get("uri").and_then(|v| v.as_str()).unwrap_or("");
            let data = mcp.handle_resource_read(uri);
            Some(json!({
                "jsonrpc": "2.0",
                "id": req_id,
                "result": {
                    "contents": [{
                        "uri": uri,
                        "mimeType": "application/json",
                        "text": serde_json::to_string(&data).unwrap_or_default(),
                    }]
                },
            }))
        }

        // -- unknown -----------------------------------------------------------
        _ => Some(json!({
            "jsonrpc": "2.0",
            "id": req_id,
            "error": {
                "code": -32601,
                "message": "Method not found",
            },
        })),
    }
}

/// Wrap a result value as an MCP text content block within a JSON-RPC response.
fn tool_text_response(req_id: Option<Value>, result: Value) -> Value {
    json!({
        "jsonrpc": "2.0",
        "id": req_id,
        "result": {
            "content": [{
                "type": "text",
                "text": serde_json::to_string(&result).unwrap_or_default(),
            }]
        },
    })
}