nodedb 0.4.0

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

// SPDX-License-Identifier: BUSL-1.1

//! Shared result construction for graph read handlers.

use serde_json::{Map, Value as JsonValue};

use crate::control::server::response_shape::types::{DdlColType, ShapedRows};
use crate::data::executor::response_codec;

use super::super::super::result::DdlResult;

/// Render a Data-Plane JSON payload as a single-column `result` row set.
///
/// An empty payload yields an empty result set with the schema still attached
/// so the entrypoint can decode column metadata — byte-identical to the pgwire
/// handler's empty `QueryResponse`.
pub(super) fn payload_to_rows(payload: &crate::bridge::envelope::Payload) -> Vec<DdlResult> {
    let columns = vec!["result".to_string()];
    let column_types = vec![DdlColType::Text];

    if payload.is_empty() {
        return vec![DdlResult::Rows(ShapedRows {
            columns,
            column_types,
            rows: Vec::new(),
            notice: None,
        })];
    }

    let json_text = response_codec::decode_payload_to_json(payload);
    let mut row = Map::new();
    row.insert("result".to_string(), JsonValue::String(json_text));

    vec![DdlResult::Rows(ShapedRows {
        columns,
        column_types,
        rows: vec![row],
        notice: None,
    })]
}