kmp-adapter-embedded 0.18.2

Embedded SQLite storage adapters for every KMP persistence port
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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

use super::{
    bounded_adjacency,
    engine::{Key, ReadTx, Table},
    serdes::{NodeRecord, decode},
};
use kmp_domain::{AdjacencyPage, AdjacencyRequest, NodeProjection, PortError, TraceSnapshotReader};

pub(super) struct TraceSnapshot<'a>(pub &'a dyn ReadTx);

impl TraceSnapshotReader for TraceSnapshot<'_> {
    fn bodies(
        &self,
        ids: &[String],
    ) -> Result<Vec<Option<kmp_domain::NodeDetailProjection>>, PortError> {
        super::node_detail::read_batch(self.0, ids)
    }

    fn verified_bodies(
        &self,
        ids: &[String],
    ) -> Result<Vec<Option<kmp_domain::NodeDetailProjection>>, PortError> {
        super::node_body_descriptor::read_verified_bodies(self.0, ids)
    }

    fn descriptors(
        &self,
        ids: &[String],
    ) -> Result<Vec<Option<kmp_domain::NodeBodyDescriptor>>, PortError> {
        super::node_body_descriptor::read_batch(self.0, ids)
    }

    fn cards(
        &self,
        ids: &[String],
        language: &str,
    ) -> Result<Vec<Option<kmp_domain::NodeCard>>, PortError> {
        super::node_card::read_batch(self.0, ids, language)
    }

    fn node(&self, id: &str) -> Result<Option<NodeProjection>, PortError> {
        self.0
            .get(Table::Nodes, Key::Str(id))?
            .map(|raw| decode::<NodeRecord>("trace node", &raw)?.into_projection())
            .transpose()
    }

    fn adjacency(&self, request: &AdjacencyRequest) -> Result<AdjacencyPage, PortError> {
        bounded_adjacency::read_page(self.0, request)
    }
}

#[cfg(test)]
#[path = "trace_snapshot_tests.rs"]
mod tests;

#[cfg(test)]
#[path = "trace_proof_snapshot_tests.rs"]
mod proof_tests;