relay-knowledge 1.1.17

Graph-database-based knowledge graph project.
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

//! Handles MCP notifications that affect active request lifecycle.

#[cfg(test)]
mod mod_tests;

use serde::Deserialize;
use serde_json::Value;

use super::{McpServer, json_rpc::request_id_key};

#[derive(Debug, Deserialize)]
struct CancelParams {
    #[serde(rename = "requestId")]
    request_id: Value,
}

pub(super) fn handle_notification(
    server: &McpServer,
    method: &str,
    params: Value,
    namespace: &str,
) -> bool {
    let Some(request_id) = (method == "notifications/cancelled")
        .then(|| serde_json::from_value::<CancelParams>(params).ok())
        .flatten()
        .and_then(|cancel| request_id_key(namespace, &cancel.request_id))
    else {
        return false;
    };
    let cancelled = server.cancellations.cancel(&request_id);
    if cancelled {
        server.qos.record_cancelled();
    }
    cancelled
}