batpak 0.5.0

Event sourcing with causal graphs and policy gates. Sync API, zero async.
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

/// Blake3 hash chain for per-entity integrity verification.
pub mod hash;
/// Metadata header attached to every event.
pub mod header;
/// Discriminant enum identifying the category of an event.
pub mod kind;
/// Traits for event-sourced and reactive state reconstruction.
pub mod sourcing;

pub use hash::HashChain;
pub use header::EventHeader;
pub use kind::EventKind;
pub use sourcing::{
    EventSourced, ProjectionEvent, ProjectionInput, ProjectionMode, ProjectionPayload,
    RawMsgpackInput, Reactive, ValueInput,
};

use crate::coordinate::Coordinate;
use serde::{Deserialize, Serialize};

/// `Event<P>`: header + payload + optional hash chain.
/// [SPEC:src/event/mod.rs]
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct Event<P> {
    /// Metadata describing the event's identity, timing, and position.
    pub header: EventHeader,
    /// Domain-specific data carried by this event.
    pub payload: P,
    /// Optional hash chain linking this event to its predecessor.
    pub hash_chain: Option<HashChain>,
}

/// `StoredEvent<P>`: what store.get() returns. Coordinate + Event.
/// store.get() returns StoredEvent<serde_json::Value> because segments are
/// schema-free MessagePack. [SPEC:src/event/mod.rs]
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct StoredEvent<P> {
    /// Stream coordinate (entity + segment) where this event is stored.
    pub coordinate: Coordinate,
    /// The full event, including header, payload, and optional hash chain.
    pub event: Event<P>,
}

impl<P> Event<P> {
    /// Creates a new event from a header and payload, with no hash chain.
    pub fn new(header: EventHeader, payload: P) -> Self {
        Self {
            header,
            payload,
            hash_chain: None,
        }
    }

    /// Attaches a hash chain to this event, enabling integrity verification.
    pub fn with_hash_chain(mut self, chain: HashChain) -> Self {
        self.hash_chain = Some(chain);
        self
    }

    /// Returns the unique event identifier.
    pub fn event_id(&self) -> u128 {
        self.header.event_id
    }

    /// Returns the kind of this event.
    pub fn event_kind(&self) -> EventKind {
        self.header.event_kind
    }

    /// Returns the DAG position of this event within its stream.
    pub fn position(&self) -> &crate::coordinate::DagPosition {
        &self.header.position
    }

    /// Returns `true` if this is the first event in its hash chain.
    pub fn is_genesis(&self) -> bool {
        self.hash_chain
            .as_ref()
            .map(|c| c.prev_hash == [0u8; 32])
            .unwrap_or(true)
    }

    /// Transforms the payload with `f`, preserving the header and hash chain.
    pub fn map_payload<U, F: FnOnce(P) -> U>(self, f: F) -> Event<U> {
        Event {
            header: self.header,
            payload: f(self.payload),
            hash_chain: self.hash_chain,
        }
    }
}