codex-client-sdk 0.107.0

Rust SDK for embedding the Codex agent via CLI-over-JSONL transport
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

mod helpers;

use std::collections::HashMap;

use codex::{CodexOptions, Input, UserInput};
use serde_json::json;

use crate::helpers::MockCodexHarness;

#[tokio::test]
async fn rejects_when_process_exits_non_zero() {
    let harness = MockCodexHarness::new(vec![vec![json!({
        "type": "thread.started",
        "thread_id": "thread_1"
    })]]);

    let mut options = CodexOptions::default();
    let mut env = HashMap::new();
    env.insert("CODEX_MOCK_EXIT_CODE".to_string(), "2".to_string());
    options.env = Some(env);

    let codex = harness.codex(options).expect("codex");
    let thread = codex.start_thread(None);
    let err = thread.run("hi", None).await.expect_err("must fail");
    assert!(err.to_string().contains("code 2"));
}

#[tokio::test]
async fn places_resume_args_before_image_args() {
    let harness = MockCodexHarness::new(vec![
        vec![
            json!({ "type": "thread.started", "thread_id": "thread_1" }),
            json!({ "type": "turn.started" }),
            json!({
                "type": "item.completed",
                "item": { "id": "item_1", "type": "agent_message", "text": "First" }
            }),
            json!({
                "type": "turn.completed",
                "usage": { "input_tokens": 1, "cached_input_tokens": 0, "output_tokens": 1 }
            }),
        ],
        vec![
            json!({ "type": "turn.started" }),
            json!({
                "type": "item.completed",
                "item": { "id": "item_2", "type": "agent_message", "text": "Second" }
            }),
            json!({
                "type": "turn.completed",
                "usage": { "input_tokens": 1, "cached_input_tokens": 0, "output_tokens": 1 }
            }),
        ],
    ]);

    let codex = harness.codex(CodexOptions::default()).expect("codex");
    let thread = codex.start_thread(None);
    thread.run("first", None).await.expect("first run");

    let second_input = Input::Entries(vec![
        UserInput::Text {
            text: "second".to_string(),
        },
        UserInput::LocalImage {
            path: "img.png".into(),
        },
    ]);
    thread.run(second_input, None).await.expect("second run");

    let logs = harness.logs();
    let args = &logs[1].args;
    let resume_index = args
        .iter()
        .position(|arg| arg == "resume")
        .expect("resume arg");
    let image_index = args
        .iter()
        .position(|arg| arg == "--image")
        .expect("image arg");
    assert!(resume_index < image_index);
}