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
41
42

// SPDX-License-Identifier: BUSL-1.1

//! Server-built document-row mutations for `CrdtOp::DocUpsert` / `DocDelete`.

use loro::LoroValue;

use super::TenantCrdtEngine;

impl TenantCrdtEngine {
    /// Insert-or-replace a document row's scalar fields (full-projection LWW
    /// replace — scalar keys absent from `fields` are pruned).
    pub fn doc_upsert(
        &mut self,
        collection: &str,
        row_id: &str,
        fields: &[(&str, LoroValue)],
    ) -> crate::Result<()> {
        self.state_mut(collection)?
            .upsert(collection, row_id, fields)
            .map_err(crate::Error::Crdt)
    }

    /// Partial-merge a document row's scalar fields (UPDATE SET — only the
    /// provided fields are written, untouched keys survive).
    pub fn doc_set_fields(
        &mut self,
        collection: &str,
        row_id: &str,
        fields: &[(&str, LoroValue)],
    ) -> crate::Result<()> {
        self.state_mut(collection)?
            .set_fields(collection, row_id, fields)
            .map_err(crate::Error::Crdt)
    }

    /// Delete a document row (tombstone in the collection's Loro doc).
    pub fn doc_delete(&mut self, collection: &str, row_id: &str) -> crate::Result<()> {
        self.state_mut(collection)?
            .delete(collection, row_id)
            .map_err(crate::Error::Crdt)
    }
}