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

// `Configure` — the `WireDaemonConfig` patch applier. Each field area is
// applied by its own applier under `commands/configure/`; this file owns the
// patch-level admission checks and the final commit into the shared config.
//
// `include!` fragment of the `turn::daemon` module — see `commands.rs`.

include!(concat!(
    env!("CARGO_MANIFEST_DIR"),
    "/src/turn/daemon/commands/configure/model.rs"
));

include!(concat!(
    env!("CARGO_MANIFEST_DIR"),
    "/src/turn/daemon/commands/configure/catalog.rs"
));

include!(concat!(
    env!("CARGO_MANIFEST_DIR"),
    "/src/turn/daemon/commands/configure/mcp.rs"
));

include!(concat!(
    env!("CARGO_MANIFEST_DIR"),
    "/src/turn/daemon/commands/configure/knobs.rs"
));

impl TurnHost {
    /// Apply a configuration patch on the serialized event loop. Only values
    /// whose runtime applier succeeds are committed to the shared GetConfig
    /// view; transport admission never mutates that view optimistically.
    async fn handle_configure(&mut self, mut config: WireDaemonConfig, turn: &mut TurnState) {
        tracing::info!(
            target: "mcp",
            "configure received: mcp_servers={} clear={:?}",
            config.mcp_servers.len(),
            config.clear_fields
        );
        let unknown = config.unknown_clear_fields();
        if !unknown.is_empty() {
            self.error_line(format!(
                "configure: unknown clear field(s): {}",
                unknown.join(", ")
            ));
            return;
        }

        let mut applied = WireDaemonConfig::default();

        // Issue #136: register controller-provisioned custom models before the
        // model pair is resolved, then seed the credential overlay.
        self.configure_models(&config, &mut applied);
        self.configure_api_key(&config, &mut applied);
        self.configure_auto_fetch_models(&mut config, &mut applied).await;

        self.configure_model_pair(&config, &mut applied).await;
        self.configure_thinking(&config, &mut applied).await;
        self.configure_skills(&config, &mut applied).await;
        self.configure_templates(&config, &mut applied);
        self.configure_mcp_servers(&config, &mut applied).await;
        self.configure_builtin_skills(&config, &mut applied);
        self.configure_skills_dirs(&config, turn, &mut applied).await;
        self.configure_runtime_knobs(&config, &mut applied);

        let touched = write_lock(&self.runtime.config).merge_from(&applied);
        if touched == 0 {
            self.system_line("configure: no applicable settings changed");
        } else {
            self.system_line(format!("configure: applied {touched} setting(s)"));
        }
        // Configure may have supplied the first model for a model-less session;
        // release any queued message that was waiting for one.
        self.start_next_queued_turn(turn);
    }
}