appcore-core 1.0.2-rc

Core runtime contracts and primitives for AppCore-Runtime.
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
105
106
107
108
109
110
111
112

// =============================================================================
//        #######
//     ###       ###     F: runtime.rs
//    ##   ## ##   ##    P: AppCore-Runtime
//         ## ##
//                       C: 2026/05/29 20:47:35 by dnettoRaw
//    ##   ## ##   ##    U: 2026/07/24 16:07:49 by dnettoRaw
//      ###########      S: 1.0.1-rc.8
// =============================================================================

//! Minimal immutable runtime instance built from runtime builder contracts.

use crate::audit::AuditLog;
use crate::bus::CommandBus;
use crate::command::CommandRegistry;
use crate::context::RuntimeContext;
use crate::decision::{DecisionEngine, DecisionOutcome, DecisionRegistry};
use crate::envelope::CommandEnvelope;
use crate::error::RuntimeResult;
use crate::event::EventRegistry;
use crate::event_bus::EventBus;
use crate::handler::CommandResult;
use crate::identity::RuntimeIdentity;
use crate::lifecycle::RuntimeLifecycle;
use crate::state::StateRegistry;
use appcore_contracts::ApplicationManifestV1;

/// Built runtime instance with manifest and registries.
#[derive(Debug)]
pub struct RuntimeInstance {
    pub(crate) application_manifest: ApplicationManifestV1,
    pub(crate) identity: RuntimeIdentity,
    pub(crate) command_registry: CommandRegistry,
    pub(crate) event_registry: EventRegistry,
    pub(crate) state_registry: StateRegistry,
    pub(crate) decision_registry: DecisionRegistry,
    pub(crate) decision_engine: DecisionEngine,
    pub(crate) command_bus: CommandBus,
    pub(crate) event_bus: EventBus,
    pub(crate) audit_log: AuditLog,
    pub(crate) lifecycle: RuntimeLifecycle,
}

impl RuntimeInstance {
    /// Returns the application-owned V1 manifest.
    pub fn application_manifest(&self) -> &ApplicationManifestV1 {
        &self.application_manifest
    }

    /// Returns Runtime/application identity.
    pub fn identity(&self) -> &RuntimeIdentity {
        &self.identity
    }

    /// Returns declared commands.
    pub fn commands(&self) -> &CommandRegistry {
        &self.command_registry
    }

    /// Returns declared events.
    pub fn events(&self) -> &EventRegistry {
        &self.event_registry
    }

    /// Returns declared states.
    pub fn states(&self) -> &StateRegistry {
        &self.state_registry
    }

    /// Returns declared decision nodes.
    pub fn decisions(&self) -> &DecisionRegistry {
        &self.decision_registry
    }

    /// Returns the command bus.
    pub fn command_bus(&self) -> &CommandBus {
        &self.command_bus
    }

    /// Returns the process lifecycle.
    pub fn lifecycle(&self) -> &RuntimeLifecycle {
        &self.lifecycle
    }

    /// Returns recently emitted events.
    pub fn event_bus(&self) -> &EventBus {
        &self.event_bus
    }

    /// Returns the process-local audit log.
    pub fn audit_log(&self) -> &AuditLog {
        &self.audit_log
    }

    /// Evaluates policy and dispatches one command.
    pub fn dispatch_command(
        &self,
        command: &CommandEnvelope,
        context: &dyn RuntimeContext,
    ) -> RuntimeResult<CommandResult> {
        match self.decision_engine.evaluate(command, context)? {
            DecisionOutcome::Allow => self.command_bus.dispatch(command, context),
            DecisionOutcome::Deny(message) => Ok(CommandResult::rejected(message)),
            DecisionOutcome::Defer(message) => Ok(CommandResult::rejected(message)),
        }
    }

    /// Verifies compatibility with another Runtime identity.
    pub fn ensure_compatible(&self, other: &RuntimeIdentity) -> RuntimeResult<()> {
        self.identity().ensure_compatible(other)
    }
}