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

// SPDX-License-Identifier: BUSL-1.1

//! Shared utility for injecting row identity fields into trigger payloads.

use std::collections::HashMap;

use nodedb_types::Value;

/// Inject `id` and `document_id` fields into a trigger row's field map.
///
/// If the row already contains these fields, the existing values are preserved.
/// No-op when `row_id` is empty.
pub(crate) fn inject_row_identity(fields: &mut HashMap<String, Value>, row_id: &str) {
    if row_id.is_empty() {
        return;
    }

    let value = Value::String(row_id.to_string());
    fields
        .entry("id".to_string())
        .or_insert_with(|| value.clone());
    fields.entry("document_id".to_string()).or_insert(value);
}