nodedb 0.0.0-beta.1

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
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

//! Graph pattern matching handler — executes MATCH queries on the Data Plane.

use tracing::{debug, warn};

use crate::bridge::envelope::{ErrorCode, Response};
use crate::data::executor::core_loop::CoreLoop;
use crate::data::executor::task::ExecutionTask;
use crate::engine::graph::pattern::ast::MatchQuery;

impl CoreLoop {
    pub(in crate::data::executor) fn execute_graph_match(
        &self,
        task: &ExecutionTask,
        query_bytes: &[u8],
    ) -> Response {
        debug!(core = self.core_id, "graph match execution");

        // Deserialize the MatchQuery from MessagePack.
        let query: MatchQuery = match rmp_serde::from_slice(query_bytes) {
            Ok(q) => q,
            Err(e) => {
                warn!(core = self.core_id, error = %e, "failed to deserialize MatchQuery");
                return self.response_error(
                    task,
                    ErrorCode::Internal {
                        detail: format!("invalid match query: {e}"),
                    },
                );
            }
        };

        // Execute the pattern match on CSR + EdgeStore.
        match crate::engine::graph::pattern::executor::execute(&query, &self.csr, &self.edge_store)
        {
            Ok(rows) => match crate::engine::graph::pattern::executor::rows_to_json(&rows) {
                Ok(payload) => self.response_with_payload(task, payload),
                Err(e) => self.response_error(task, ErrorCode::from(e)),
            },
            Err(e) => self.response_error(task, ErrorCode::from(e)),
        }
    }
}