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
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
92
93
94
95
96
97
98
99
100
101
102
103
104

use serde::{Deserialize, Deserializer, Serialize};

use crate::error::DomainError;

use super::{CeremonyId, ChildDepth, ChildDepthBudget, ChildGroupId, ChildPosition};

#[derive(Debug, Clone, PartialEq, Eq, Serialize)]
pub struct CeremonyLineage {
    root_id: CeremonyId,
    parent_id: CeremonyId,
    group_id: ChildGroupId,
    position: ChildPosition,
    depth: ChildDepth,
    remaining_depth: ChildDepthBudget,
}

impl CeremonyLineage {
    pub fn new(
        root_id: CeremonyId,
        parent_id: CeremonyId,
        group_id: ChildGroupId,
        position: ChildPosition,
        depth: ChildDepth,
        remaining_depth: ChildDepthBudget,
    ) -> Result<Self, DomainError> {
        let lineage = Self {
            root_id,
            parent_id,
            group_id,
            position,
            depth,
            remaining_depth,
        };
        lineage.validate()?;
        Ok(lineage)
    }
    #[must_use]
    pub fn root_id(&self) -> &CeremonyId {
        &self.root_id
    }
    #[must_use]
    pub fn parent_id(&self) -> &CeremonyId {
        &self.parent_id
    }
    #[must_use]
    pub fn group_id(&self) -> &ChildGroupId {
        &self.group_id
    }
    #[must_use]
    pub const fn position(&self) -> ChildPosition {
        self.position
    }
    #[must_use]
    pub const fn depth(&self) -> ChildDepth {
        self.depth
    }
    #[must_use]
    pub const fn remaining_depth(&self) -> ChildDepthBudget {
        self.remaining_depth
    }

    pub fn validate(&self) -> Result<(), DomainError> {
        let root_is_parent = self.root_id == self.parent_id;
        if (self.depth == ChildDepth::FIRST) != root_is_parent {
            return Err(DomainError::InvalidDocument {
                reason: "child lineage root and parent are inconsistent with depth".to_owned(),
            });
        }
        if self.depth.get() + self.remaining_depth.get() > super::MaxChildDepth::SERVER_MAX.get() {
            return Err(DomainError::InvalidDocument {
                reason: "child lineage exceeds the server depth ceiling".to_owned(),
            });
        }
        Ok(())
    }
}

impl<'de> Deserialize<'de> for CeremonyLineage {
    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
    where
        D: Deserializer<'de>,
    {
        #[derive(Deserialize)]
        struct UncheckedCeremonyLineage {
            root_id: CeremonyId,
            parent_id: CeremonyId,
            group_id: ChildGroupId,
            position: ChildPosition,
            depth: ChildDepth,
            remaining_depth: ChildDepthBudget,
        }

        let raw = UncheckedCeremonyLineage::deserialize(deserializer)?;
        Self::new(
            raw.root_id,
            raw.parent_id,
            raw.group_id,
            raw.position,
            raw.depth,
            raw.remaining_depth,
        )
        .map_err(serde::de::Error::custom)
    }
}