agents-kit 0.0.2

Rust agent control Kit for Codex, OpenCode, and provider-backed Custom runtimes
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

use serde_json::Value;

use crate::KitError;
use crate::backends::codex::protocol::notifications::CodexServerNotification;
use crate::backends::codex::protocol::requests::CodexServerRequest;

pub(crate) enum CodexInbound {
    Request(CodexServerRequest),
    MalformedRequest { request_id: Value, error: KitError },
    Notification(CodexServerNotification),
}

pub(crate) enum CodexInboundFrame {
    ServerRequest {
        request_id: Value,
        method: String,
        params: Value,
    },
    ServerNotification {
        method: String,
        params: Value,
    },
}

impl CodexInbound {
    pub(crate) fn decode(frame: CodexInboundFrame) -> Result<Self, KitError> {
        match frame {
            CodexInboundFrame::ServerRequest {
                request_id,
                method,
                params,
            } => match CodexServerRequest::decode(request_id.clone(), &method, params) {
                Ok(request) => Ok(Self::Request(request)),
                Err(error) => Ok(Self::MalformedRequest { request_id, error }),
            },
            CodexInboundFrame::ServerNotification { method, params } => {
                CodexServerNotification::decode(method, params).map(Self::Notification)
            }
        }
    }
}

impl CodexInboundFrame {
    pub(crate) fn request(request_id: Value, method: String, params: Value) -> Self {
        Self::ServerRequest {
            request_id,
            method,
            params,
        }
    }

    pub(crate) fn notification(method: String, params: Value) -> Self {
        Self::ServerNotification { method, params }
    }
}