zagens-core 0.8.0

Core runtime boundaries for Zagens agent architecture
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

//! Engine construction (`Engine::with_hosts`, M7).

use std::sync::{Arc, Mutex as StdMutex};

use tokio::sync::{RwLock, mpsc};
use tokio_util::sync::CancellationToken;

use crate::coherence::CoherenceState;
use crate::engine::config::EngineConfig;
use crate::engine::handle::EngineHandle;
use crate::engine::host_bundle::EngineHostBundle;
use crate::engine::runtime::Engine;
use crate::session::Session;

impl<P, R> Engine<P, R>
where
    P: Send + Sync + 'static,
    R: Send + Sync + 'static,
{
    /// Construct an engine from lean config + tui-wired host bundle.
    ///
    /// Creates the seven mpsc channel pairs core-side (spike R11) and
    /// returns `(engine, handle)` for the tui builder to spawn the loop.
    #[must_use]
    pub fn with_hosts(
        config: EngineConfig,
        session: Session,
        hosts: EngineHostBundle<P, R>,
    ) -> (Self, EngineHandle<P, R>) {
        let EngineHostBundle {
            lsp,
            shell,
            sandbox,
            seam,
            workshop,
            topic_memory,
            capacity_controller,
            deepseek_client,
            deepseek_client_error,
            api_key_env_only_recovery,
            ext,
            scratchpad_run_id,
        } = hosts;

        let (tx_op, rx_op) = mpsc::channel(32);
        let (tx_event, rx_event) = mpsc::channel(256);
        let (tx_approval, rx_approval) = mpsc::channel(64);
        let (tx_user_input, rx_user_input) = mpsc::channel(32);
        let (tx_steer, rx_steer) = mpsc::channel(64);
        let cancel_token = CancellationToken::new();
        let shared_cancel_token = Arc::new(StdMutex::new(cancel_token.clone()));
        let tool_exec_lock = Arc::new(RwLock::new(()));

        let engine = Self {
            config,
            ext: Some(ext),
            deepseek_client,
            deepseek_client_error,
            api_key_env_only_recovery,
            session,
            shell,
            rx_op,
            tx_approval: tx_approval.clone(),
            rx_approval,
            rx_user_input,
            rx_steer,
            tx_event,
            cancel_token,
            shared_cancel_token: shared_cancel_token.clone(),
            tool_exec_lock,
            capacity_controller,
            seam,
            coherence_state: CoherenceState::default(),
            turn_counter: 0,
            lsp,
            workshop,
            sandbox,
            pending_lsp_blocks: Vec::new(),
            scratchpad_step: Default::default(),
            scratchpad_run_id,
            scratchpad_summary_injected_this_turn: false,
            scratchpad_audit_continue_injected_this_turn: false,
            long_horizon_continue_injected_this_turn: false,
            long_horizon_auto_continue_rounds: 0,
            topic_memory,
            overflow_source_budget_cap: None,
        };

        let handle = EngineHandle::new(
            tx_op,
            Arc::new(RwLock::new(rx_event)),
            shared_cancel_token,
            tx_approval,
            tx_user_input,
            tx_steer,
        );

        (engine, handle)
    }
}