infinite-db 0.4.0

A spatial-graph database using n-dimensional curves and hyperedges for engineering logic.
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
59
60
61
62
63
64
65

//! Assertion events fed to the derivation bus.

use crate::infinitedb_core::{
    address::{RevisionId, SpaceId},
    branch::BranchId,
    hyperedge::Hyperedge,
};

/// Operation on a hyperedge assertion stream.
#[derive(Debug, Clone)]
pub enum AssertionOp {
    Upsert(Hyperedge),
    Delete(Hyperedge),
}

impl AssertionOp {
    pub fn edge_id(&self) -> crate::infinitedb_core::hyperedge::HyperedgeId {
        match self {
            AssertionOp::Upsert(e) | AssertionOp::Delete(e) => e.id,
        }
    }
}

/// One committed assertion the bus derives index geometry from.
#[derive(Debug, Clone)]
pub struct AssertionEvent {
    pub edge_space: SpaceId,
    pub op: AssertionOp,
    pub source_revision: RevisionId,
    pub branch: BranchId,
}

impl AssertionEvent {
    pub fn upsert(
        edge_space: SpaceId,
        edge: Hyperedge,
        source_revision: RevisionId,
        branch: BranchId,
    ) -> Self {
        Self {
            edge_space,
            op: AssertionOp::Upsert(edge),
            source_revision,
            branch,
        }
    }

    pub fn delete(
        edge_space: SpaceId,
        edge: Hyperedge,
        source_revision: RevisionId,
        branch: BranchId,
    ) -> Self {
        Self {
            edge_space,
            op: AssertionOp::Delete(edge),
            source_revision,
            branch,
        }
    }

    pub fn edge_id(&self) -> crate::infinitedb_core::hyperedge::HyperedgeId {
        self.op.edge_id()
    }
}