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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use crate::entities::{CouncilJournalEvent, CouncilJournalRecord};
use crate::error::DomainError;
use crate::value_objects::{
    AuthorizationEvidence, CouncilJournalConsumer, CouncilJournalLease, CouncilJournalPageLimit,
    CouncilJournalPosition, DurationMs,
};
use async_trait::async_trait;
use time::OffsetDateTime;

/// Council delivery is independent of ceremony delivery. Immutable publication
/// ids deduplicate append; external consumers deduplicate effects by record
/// identity because a crash before acknowledgement causes redelivery.
#[async_trait]
pub trait CouncilJournalPort: Send + Sync {
    /// Publication events require their original stable EventId. Reusing it
    /// with different content refuses without changing storage.
    async fn publish(
        &self,
        event: CouncilJournalEvent,
    ) -> Result<CouncilJournalRecord, DomainError>;
    async fn publish_authorized(
        &self,
        event: CouncilJournalEvent,
        authorization: Option<AuthorizationEvidence>,
    ) -> Result<CouncilJournalRecord, DomainError> {
        if authorization.is_some() {
            return Err(DomainError::InvariantViolated {
                reason: "council journal adapter cannot persist authorization evidence",
            });
        }
        self.publish(event).await
    }
    async fn read(
        &self,
        after: Option<CouncilJournalPosition>,
        limit: CouncilJournalPageLimit,
    ) -> Result<Vec<CouncilJournalRecord>, DomainError>;
    async fn position(
        &self,
        consumer: &CouncilJournalConsumer,
    ) -> Result<Option<CouncilJournalPosition>, DomainError>;
    async fn lease(
        &self,
        consumer: &CouncilJournalConsumer,
        now: OffsetDateTime,
        duration: DurationMs,
    ) -> Result<Option<CouncilJournalLease>, DomainError>;
    /// Atomically advance and release. Expired, replaced, fabricated or already
    /// released leases cannot advance or interfere with a subsequent worker.
    async fn acknowledge(
        &self,
        lease: &CouncilJournalLease,
        through: CouncilJournalPosition,
        now: OffsetDateTime,
    ) -> Result<(), DomainError>;
    async fn release(
        &self,
        lease: &CouncilJournalLease,
        now: OffsetDateTime,
    ) -> Result<(), DomainError>;
}