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

use theway_contract::extension::{ExtensionHookClass, ExtensionLifecycleEvent, ExtensionScope};
use theway_core::agent::runtime_extensions::{
    RawRuntimeExtensionResult, RuntimeCompactionExtensionPort, RuntimeExtensionInvocation,
    RuntimeMessageExtensionPort, RuntimeRequestExtensionPort, RuntimeRunExtensionPort,
    RuntimeSessionExtensionPort, RuntimeToolExtensionPort,
};

use super::host::SessionPluginHost;

#[async_trait::async_trait]
impl RuntimeSessionExtensionPort for SessionPluginHost {
    async fn invoke_session(
        &self,
        invocation: RuntimeExtensionInvocation,
    ) -> RawRuntimeExtensionResult {
        let shutdown = invocation.event() == ExtensionLifecycleEvent::SessionShutdown;
        let result = self.invoke_runtime(invocation).await;
        if shutdown {
            self.unload_after_core_shutdown().await;
        }
        result
    }
}

macro_rules! impl_runtime_domain {
    ($trait_name:ident, $method:ident) => {
        #[async_trait::async_trait]
        impl $trait_name for SessionPluginHost {
            async fn $method(
                &self,
                invocation: RuntimeExtensionInvocation,
            ) -> RawRuntimeExtensionResult {
                self.invoke_runtime(invocation).await
            }
        }
    };
}

impl_runtime_domain!(RuntimeMessageExtensionPort, invoke_message);
impl_runtime_domain!(RuntimeCompactionExtensionPort, invoke_compaction);

#[async_trait::async_trait]
impl RuntimeRunExtensionPort for SessionPluginHost {
    async fn invoke_run(
        &self,
        invocation: RuntimeExtensionInvocation,
    ) -> RawRuntimeExtensionResult {
        let event = invocation.event();
        if event == ExtensionLifecycleEvent::RunStarted {
            self.mark_run_started().await;
        }
        let run_id = invocation.context().scope.run_id.clone();
        let request_id = invocation.context().scope.request_id.clone();
        let result = self.invoke_runtime(invocation).await;
        match event {
            ExtensionLifecycleEvent::TurnCompleted => {
                self.dispose_boundary_effects(ExtensionScope::Request, request_id.as_deref());
            }
            ExtensionLifecycleEvent::RunSettled => {
                self.settle_run_reload_boundary(run_id.as_deref()).await;
            }
            _ => {}
        }
        result
    }
}

#[async_trait::async_trait]
impl RuntimeToolExtensionPort for SessionPluginHost {
    async fn invoke_tool(
        &self,
        invocation: RuntimeExtensionInvocation,
    ) -> RawRuntimeExtensionResult {
        let event = invocation.event();
        if event == ExtensionLifecycleEvent::ToolExecutionStart {
            self.mark_tool_execution_started().await;
        }
        let result = self.invoke_runtime(invocation).await;
        if event == ExtensionLifecycleEvent::ToolExecutionEnd {
            self.settle_tool_reload_boundary().await;
        }
        result
    }
}

#[async_trait::async_trait]
impl RuntimeRequestExtensionPort for SessionPluginHost {
    fn has_request_hook(&self, event: ExtensionLifecycleEvent, class: ExtensionHookClass) -> bool {
        self.has_subscription(event, class) || self.has_request_registration(event, class)
    }

    async fn invoke_request(
        &self,
        invocation: RuntimeExtensionInvocation,
    ) -> RawRuntimeExtensionResult {
        self.invoke_runtime(invocation).await
    }
}