theway-daemon 0.1.26

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

//! Process-scoped daemon services and their explicit ownership.

use std::path::Path;
use std::sync::{Arc, OnceLock};

use theway_storage::attachments::LocalAttachmentStore;

use crate::commands::CommandOutput;
use crate::session_activation::SessionActivator;
use crate::session_execution::SessionExecutionRegistry;
use crate::stream_auth::ConfiguredApiKeys;
use crate::subagent_settings::SubagentSettingsRegistry;
use crate::tgrep_server::TgrepServerRegistry;
use crate::tools::assembly::reload::ReloadRuntimeSlot;
use crate::triggers::cron::CronRegistry;
use crate::triggers::dynamic::DynamicTriggerRegistry;

/// Shared services owned by one daemon application instance.
#[derive(Clone)]
pub struct DaemonServices {
    pub(crate) command_output: CommandOutput,
    pub(crate) dynamic_triggers: DynamicTriggerRegistry,
    pub(crate) cron: CronRegistry,
    pub(crate) reload: ReloadRuntimeSlot,
    #[allow(dead_code)]
    pub(crate) session_execution: SessionExecutionRegistry,
    pub(crate) session_activator: Arc<OnceLock<Arc<SessionActivator>>>,
    /// Process-scoped `tgrep serve` registry for the built-in grep tool
    /// (issue #121): lazily spawned per project root, shared across sessions.
    pub(crate) tgrep: TgrepServerRegistry,
    /// Project-level last-set subagent model/thinking memory: one shared
    /// settings store per project root, injected into every session's
    /// `dag_plan` / `subagent` tools.
    pub(crate) subagent_settings: SubagentSettingsRegistry,
    /// Controller-provided API keys (issue #136, `config.toml [model]
    /// api_key`), keyed by provider. Consulted by the stream wrapper between
    /// the environment and `auth.json`; `Configure` updates it at runtime.
    pub(crate) configured_api_keys: ConfiguredApiKeys,
    /// Content-addressed attachment library (`<base>/attachments/v1`) shared by
    /// every session: once admission runs, a `UserInput` record names attachment
    /// bytes only by the digest they were stored under here.
    pub(crate) attachments: Arc<LocalAttachmentStore>,
}

impl Default for DaemonServices {
    fn default() -> Self {
        #[cfg(test)]
        let dynamic_triggers = crate::triggers::global_registry().clone();
        #[cfg(not(test))]
        let dynamic_triggers = DynamicTriggerRegistry::default();

        #[cfg(test)]
        let cron = crate::triggers::global_cron_registry().clone();
        #[cfg(not(test))]
        let cron = CronRegistry::default();

        Self {
            command_output: CommandOutput::default(),
            dynamic_triggers,
            cron,
            reload: ReloadRuntimeSlot::default(),
            session_execution: SessionExecutionRegistry::default(),
            session_activator: Arc::new(OnceLock::new()),
            tgrep: TgrepServerRegistry::new(),
            subagent_settings: SubagentSettingsRegistry::new(),
            configured_api_keys: ConfiguredApiKeys::default(),
            // `<base>/attachments/v1` from the contract layout; a caller holding
            // the resolved `DaemonPaths::base` overlays it with
            // `with_attachments_base`.
            attachments: Arc::new(LocalAttachmentStore::from_base_dir()),
        }
    }
}

impl DaemonServices {
    pub fn new() -> Self {
        Self::default()
    }

    /// Share the controller-provided API-key overlay (issue #136) with the
    /// stream wrapper and the settings applier.
    #[must_use]
    pub(crate) fn with_configured_api_keys(mut self, keys: ConfiguredApiKeys) -> Self {
        self.configured_api_keys = keys;
        self
    }

    #[must_use]
    pub(crate) fn with_command_output(mut self, command_output: CommandOutput) -> Self {
        self.command_output = command_output;
        self
    }

    /// Root the attachment library at `<base>/attachments/v1`, the layout
    /// `theway_contract::config::attachments_dir` defines. Only a caller that holds
    /// the resolved `DaemonPaths` can honour a CLI-overridden base dir, so startup
    /// applies the base here instead of this module reading it from the environment.
    #[must_use]
    pub(crate) fn with_attachments_base(mut self, base: &Path) -> Self {
        self.attachments = Arc::new(LocalAttachmentStore::new(
            base.join("attachments").join("v1"),
        ));
        self
    }

    /// Disable the tgrep grep backend (issue #135): the registry reports
    /// `Missing` for every root, so `grep` always takes the walker path and no
    /// `tgrep serve` process or `.tgrep` index is created.
    #[must_use]
    pub(crate) fn with_tgrep_enabled(mut self, enabled: bool) -> Self {
        if !enabled {
            self.tgrep = TgrepServerRegistry::disabled();
        }
        self
    }
}