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

//! [`DeliberationRepositoryPort`] — persistence for deliberations
//! across process restarts / replicas.

use async_trait::async_trait;

use crate::entities::Deliberation;
use crate::error::DomainError;
use crate::value_objects::{AuthorizationEvidence, TaskId};

#[async_trait]
pub trait DeliberationRepositoryPort: Send + Sync {
    /// Persist (or update) a deliberation keyed by its task id.
    async fn save(&self, deliberation: &Deliberation) -> Result<(), DomainError>;
    async fn save_authorized(
        &self,
        deliberation: &Deliberation,
        authorization: Option<AuthorizationEvidence>,
    ) -> Result<(), DomainError> {
        if authorization.is_some() {
            return Err(DomainError::InvariantViolated {
                reason: "deliberation repository cannot persist authorization evidence",
            });
        }
        self.save(deliberation).await
    }

    /// Fetch a deliberation by task id. Returns
    /// [`DomainError::NotFound`] when absent.
    async fn get(&self, task_id: &TaskId) -> Result<Deliberation, DomainError>;

    /// Cheap existence check.
    async fn exists(&self, task_id: &TaskId) -> Result<bool, DomainError>;
}