awaken-runtime 0.6.0

Phase-based execution engine, plugin system, and agent loop for Awaken
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

//! Commit-coordinator wiring for `AgentRuntime` (ADR-0036).

use std::sync::Arc;

use awaken_runtime_contract::contract::commit_coordinator::CommitCoordinator;

use super::AgentRuntime;

impl AgentRuntime {
    /// Wire a `CommitCoordinator` for atomic checkpoint commits across
    /// `ThreadRunStore` and `EventStore` writes (ADR-0036). When set, the
    /// runtime tees durable canonical drafts through the coordinator at
    /// checkpoint cadence instead of letting `ThreadRunStore::checkpoint`
    /// and `EventWriter::append` run in independent transactions.
    #[must_use]
    pub fn with_commit_coordinator(mut self, coordinator: Arc<dyn CommitCoordinator>) -> Self {
        // Adopt the coordinator's reader as the runtime's checkpoint read port
        // unless an explicit reader was already wired.
        if self.checkpoint_storage.is_none() {
            self.checkpoint_storage = Some(coordinator.reader());
        }
        self.commit_coordinator = Some(coordinator);
        self
    }

    /// ADR-0036 D8 test/development convenience: pair an in-memory store with a
    /// matching `MemoryCommitCoordinator` in one call. The runtime adopts the
    /// coordinator's `reader()` as its checkpoint read port.
    #[cfg(feature = "test-utils")]
    #[must_use]
    pub fn with_in_memory_thread_run_store(self, store: Arc<awaken_stores::InMemoryStore>) -> Self {
        let coord = awaken_stores::MemoryCommitCoordinator::wrap(store);
        self.with_commit_coordinator(coord as Arc<dyn CommitCoordinator>)
    }

    /// Return the wired commit coordinator, if any.
    pub fn commit_coordinator(&self) -> Option<&Arc<dyn CommitCoordinator>> {
        self.commit_coordinator.as_ref()
    }
}