obzenflow_core 0.2.4

Core domain layer for ObzenFlow - pure abstractions with minimal dependencies
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

// SPDX-License-Identifier: MIT OR Apache-2.0
// SPDX-FileCopyrightText: 2025-2026 ObzenFlow Contributors
// https://obzenflow.dev

use super::ChainEvent;
use crate::event::envelope::AuthoredEnvelope;
use crate::event::journal_event::{JournalEvent, Sealed};
use crate::event::provenance::ChainEventProvenance;
use crate::event::types::{AdmissionSeq, EventId, WriterId};
use crate::event::ChainPayload;

impl Sealed for ChainEvent {}

impl JournalEvent for ChainEvent {
    type Payload = ChainPayload;
    fn into_parts(self) -> (AuthoredEnvelope<ChainEventProvenance>, Self::Payload) {
        (self.envelope, self.payload)
    }
    fn from_parts(
        envelope: AuthoredEnvelope<ChainEventProvenance>,
        payload: Self::Payload,
    ) -> Self {
        Self { envelope, payload }
    }

    fn id(&self) -> &EventId {
        &self.id
    }

    fn writer_id(&self) -> &WriterId {
        &self.writer_id
    }

    fn admission_seq(&self) -> Option<AdmissionSeq> {
        self.admission_seq
    }

    fn set_admission_seq(&mut self, seq: AdmissionSeq) {
        self.admission_seq = Some(seq);
    }

    fn event_type_name(&self) -> &str {
        &self.envelope.provenance.event.event_type
    }
}