nodedb 0.3.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

// SPDX-License-Identifier: BUSL-1.1

//! Shared helpers for `bfs` and `shortest_path`: payload encoding +
//! `Response` construction.

use crate::bridge::envelope::Response;
use crate::types::{Lsn, RequestId};

pub(super) fn encode_path<S: serde::Serialize>(path: &[S]) -> crate::Result<Vec<u8>> {
    sonic_rs::to_vec(path).map_err(|e| crate::Error::Serialization {
        format: "json".into(),
        detail: e.to_string(),
    })
}

pub(super) fn ok_response(payload: Vec<u8>) -> Response {
    Response {
        request_id: RequestId::new(0),
        status: crate::bridge::envelope::Status::Ok,
        attempt: 1,
        partial: false,
        payload: crate::bridge::envelope::Payload::from_vec(payload),
        watermark_lsn: Lsn::ZERO,
        error_code: None,
    }
}