theway-daemon 0.1.27

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

// Per-session provider credential commands (memory-only secrets).
//
// `include!` fragment of the `turn::daemon` module — see `commands.rs`.

impl TurnHost {
    fn handle_set_credential(
        &mut self,
        request: WireSetCredentialRequest,
    ) -> Result<(), WireRpcError> {
        if request.session_id.trim().is_empty() {
            return Err(WireRpcError {
                code: "invalid_argument".into(),
                message: "session_id must not be empty".into(),
            });
        }
        if request.provider.trim().is_empty() {
            return Err(WireRpcError {
                code: "invalid_argument".into(),
                message: "provider must not be empty".into(),
            });
        }
        self.automation
            .services
            .session_execution
            .set_credential(&request.session_id, &request.provider, request.secret)
            .map_err(|error| match error {
                crate::session_execution::RegistryError::SessionNotRegistered(id) => WireRpcError {
                    code: "not_found".into(),
                    message: format!("session {id} is not registered; activate it first"),
                },
                other => WireRpcError {
                    code: "failed_precondition".into(),
                    message: other.to_string(),
                },
            })
    }

    fn handle_clear_credential(
        &mut self,
        request: WireClearCredentialRequest,
    ) -> Result<(), WireRpcError> {
        let session_id = request.session_id.trim();
        if session_id.is_empty() {
            return Err(WireRpcError {
                code: "invalid_argument".into(),
                message: "session_id must not be empty".into(),
            });
        }
        if self
            .automation
            .services
            .session_execution
            .get(session_id)
            .is_none()
        {
            return Err(WireRpcError {
                code: "not_found".into(),
                message: format!("session {session_id} is not registered; activate it first"),
            });
        }
        match request.provider.as_deref() {
            Some(provider) if provider.trim().is_empty() => Err(WireRpcError {
                code: "invalid_argument".into(),
                message: "provider must not be empty".into(),
            }),
            Some(provider) => {
                self.automation
                    .services
                    .session_execution
                    .clear_credential(session_id, provider);
                Ok(())
            }
            None => {
                self.automation
                    .services
                    .session_execution
                    .clear_credentials(session_id);
                Ok(())
            }
        }
    }
}