made-core 0.6.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

use crate::entities::ceremony_commands::ApplyTransition;
use crate::entities::ceremony_events::{CeremonyCompleted, TransitionApplied};
use crate::entities::{CeremonyDefinition, CeremonyEvent, CeremonyInstance};
use crate::error::DomainError;
use crate::value_objects::{CeremonyTransitionRecord, RoleAction};

impl CeremonyInstance {
    /// The one place a session moves.
    ///
    /// A move into a terminal state is also the ceremony's completion,
    /// so it yields two events: the move, then the ending. They are
    /// decided together so no caller can seal one without the other.
    pub(super) fn decide_apply_transition(
        &self,
        command: &ApplyTransition,
        definition: &CeremonyDefinition,
    ) -> Result<Vec<CeremonyEvent>, DomainError> {
        if let Some(role_id) = command.role_id.as_ref() {
            self.require_role(
                definition,
                role_id,
                &RoleAction::transition(command.trigger.clone()),
            )?;
        }
        self.require_definition(definition)?;
        if self.is_terminal(definition) {
            return Err(DomainError::InvariantViolated {
                reason: "terminal ceremony instances cannot transition",
            });
        }

        let transition = definition
            .transition_for_trigger(&self.current_state, &command.trigger)
            .ok_or(DomainError::InvalidTransition {
                from: "ceremony_instance.current_state",
                to: "transition_trigger",
            })?;
        self.require_transition_budget(definition, transition)?;
        if self.has_live_step_leases_at(definition, command.now) {
            return Err(DomainError::InvariantViolated {
                reason: "ceremony cannot transition while a step lease is active",
            });
        }
        if !self.state_repeat_permits_transition(definition) {
            return Err(DomainError::InvariantViolated {
                reason: "ceremony state repeat condition is not satisfied",
            });
        }
        if !definition.guards_are_satisfied(transition, &self.step_records, &self.context) {
            return Err(DomainError::InvariantViolated {
                reason: "ceremony transition guards are not satisfied",
            });
        }

        let to_state = transition.to().clone();
        self.require_interventions_resolved_before_entering(definition, &to_state)?;
        let mut events = vec![CeremonyEvent::TransitionApplied(TransitionApplied {
            destination: Some(crate::entities::ceremony_events::StateVisitEntry {
                state_visit: self.current_state_visit.next()?,
                step_ids: definition
                    .steps_for_state(&to_state)
                    .map(|step| step.id().clone())
                    .collect(),
            }),
            transition: CeremonyTransitionRecord::record_at(
                command.trigger.clone(),
                self.current_state.clone(),
                self.current_state_iteration,
                to_state.clone(),
                command.role_id.clone(),
                command.now,
            )
            .with_state_visit(self.current_state_visit),
        })];
        if definition.is_terminal_state(&to_state) {
            events.push(CeremonyEvent::CeremonyCompleted(CeremonyCompleted {
                final_state: to_state,
                completed_at: command.now,
            }));
        }
        Ok(events)
    }
}