made-core 0.8.0

Domain core of MADE: entities, value objects, events, ports. No IO.
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

use serde::{Deserialize, Serialize};

use crate::entities::{Council, CouncilSnapshotProvenance, Deliberation, Statistics};
use crate::events::{
    DeliberationCompletedEvent, PhaseChangedEvent, TaskCompletedEvent, TaskDispatchedEvent,
    TaskFailedEvent,
};
use crate::ports::AgentDescriptor;
use crate::value_objects::{AgentId, EventId, OutputContract, OutputContractId, Specialty};

/// Council facts have their own durable order, separate from ceremony events.
/// A saved deliberation is explicitly a snapshot, never an invented phase history.
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(tag = "kind", content = "fact", rename_all = "snake_case")]
pub enum CouncilJournalEvent {
    SnapshotImported(CouncilSnapshotProvenance),
    CouncilRegistered(Council),
    CouncilReplaced(Council),
    CouncilDeleted(Specialty),
    AgentRegistered(AgentDescriptor),
    AgentUnregistered(AgentId),
    ContractRegistered(OutputContract),
    ContractDeleted(OutputContractId),
    DeliberationSnapshotSaved(Deliberation),
    StatisticsRecorded(Statistics),
    TaskDispatched(TaskDispatchedEvent),
    TaskCompleted(TaskCompletedEvent),
    TaskFailed(TaskFailedEvent),
    DeliberationCompleted(DeliberationCompletedEvent),
    PhaseChanged(PhaseChangedEvent),
}

impl CouncilJournalEvent {
    /// The caller's stable publication identity, if this is a messaging fact.
    #[must_use]
    pub fn publication_id(&self) -> Option<&EventId> {
        match self {
            Self::TaskDispatched(event) => Some(event.envelope().event_id()),
            Self::TaskCompleted(event) => Some(event.envelope().event_id()),
            Self::TaskFailed(event) => Some(event.envelope().event_id()),
            Self::DeliberationCompleted(event) => Some(event.envelope().event_id()),
            Self::PhaseChanged(event) => Some(event.envelope().event_id()),
            _ => None,
        }
    }
}