theway-daemon 0.1.21

theway daemon — the single agent-runtime kernel (bin `thewayd`): harness assembly, local/sandbox tool policy, triggers/cron/session/DAG runtime, skills, MCP/LSP wiring, serving the gRPC/HTTP/MCP transports from theway-transport. Terminal UI lives in the theway-tui crate.
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
113
114
115
116
117
118
119
120
121
122
123

//! Detached activation-build seam for session-scoped runtime assembly.

use std::sync::Arc;

use anyhow::Result;
use theway_contract::dag::PersistedRun;
use theway_contract::session::SessionStore;

use super::{SessionExecutionContext, SessionRuntime, SessionRuntimeBuilder};
use crate::tools;

impl SessionRuntimeBuilder {
    /// Build a runtime for an already-opened store without installing any
    /// process registries/launchers or restoring persisted DAG runs.
    #[allow(dead_code)] // Consumed by the future atomic activation transaction.
    pub(crate) async fn build_opened_detached(
        &self,
        ctx: &SessionExecutionContext,
        store: Arc<dyn SessionStore>,
        rehydrate: bool,
    ) -> Result<SessionRuntime> {
        let (ctx, session_id, store) = self.opened_context(ctx, store).await?;
        let skill_harness_cell = new_skill_harness_cell();
        self.assemble_opened(ctx, store, session_id, rehydrate, skill_harness_cell)
            .await
    }

    /// Install all process mappings and DAG restores after callers finish
    /// fallible loading. This commit phase is nonfallible.
    pub(crate) fn install_execution_context(
        &self,
        ctx: Arc<SessionExecutionContext>,
        restored: Vec<PersistedRun>,
    ) -> crate::tools::skill::SkillHarnessCell {
        self.services
            .session_execution
            .set_context(ctx.session_id.clone(), Arc::clone(&ctx));
        self.subagent_registry.set_session_transcript_store(
            Some(ctx.session_id.clone()),
            ctx.transcript_store.clone(),
        );

        let skill_harness_cell = new_skill_harness_cell();
        self.session_cells
            .lock()
            .insert(ctx.session_id.clone(), skill_harness_cell.clone());
        self.dag_engine.set_session_launcher(
            Some(ctx.session_id.clone()),
            tools::node_launcher_with_kind(
                self.dag_engine.clone(),
                ctx.model.clone(),
                Some(self.stream_fn.clone()),
                ctx.cwd.clone(),
                self.subagent_registry.clone(),
                ctx.resources.memory_dir.clone(),
                ctx.paths.base.clone(),
                skill_harness_cell.clone(),
                ctx.executor.clone(),
                Some(self.services.tgrep.clone()),
                ctx.executor_kind,
            ),
        );

        // `restore` skips live ids, keeping repeated session installation idempotent.
        let restored = self.dag_engine.restore(restored);
        if !restored.is_empty() {
            tracing::info!(
                "session {}: restored {} in-flight DAG run(s): {}",
                ctx.session_id,
                restored.len(),
                restored.join(", ")
            );
        }
        skill_harness_cell
    }

    /// Rebuild the DAG launcher for one installed session with a new parent model,
    /// reusing the session's original skill harness cell so subagent tool sets keep
    /// the already-populated skill source. `SetModel` after activation must reach
    /// future DAG node launches; the launcher otherwise keeps the model snapshot
    /// from activation time. Returns `false` when the session was never installed.
    pub(crate) fn refresh_dag_launcher(
        &self,
        session_id: &str,
        model: theway_llm_provider::Model,
    ) -> bool {
        let Some(cell) = self.session_cells.lock().get(session_id).cloned() else {
            return false;
        };
        let Some(ctx) = self.services.session_execution.get_context(session_id) else {
            return false;
        };
        self.dag_engine.set_session_launcher(
            Some(session_id.to_string()),
            tools::node_launcher_with_kind(
                self.dag_engine.clone(),
                model,
                Some(self.stream_fn.clone()),
                ctx.cwd.clone(),
                self.subagent_registry.clone(),
                ctx.resources.memory_dir.clone(),
                ctx.paths.base.clone(),
                cell,
                ctx.executor.clone(),
                Some(self.services.tgrep.clone()),
                ctx.executor_kind,
            ),
        );
        true
    }
}

/// Load the only fallible persisted state needed before installing a session.
pub(crate) async fn load_persisted_dag_runs(
    ctx: &SessionExecutionContext,
    session_id: &str,
) -> Result<Vec<PersistedRun>> {
    ctx.storage.load_dag_runs(&ctx.cwd, session_id).await
}

fn new_skill_harness_cell() -> crate::tools::skill::SkillHarnessCell {
    std::sync::Arc::new(once_cell::sync::OnceCell::new())
}