objectiveai-cli 2.1.1

ObjectiveAI command-line interface and embeddable library
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

//! End-to-end snapshot tests: fixture tool binaries are placed in a
//! temp tools dir and dispatched via `objectiveai-cli tools <name>`.
//! We assert on a deterministic summary (per-stream stdout/stderr
//! arrays + exit code) via insta snapshots.

mod cli_test_util;

use std::path::Path;
use std::process::Command;

#[derive(serde::Serialize)]
struct Summary {
    exit_code: i32,
    stdout: Vec<String>,
    stderr: Vec<String>,
}

/// Spawn the cli with `CONFIG_BASE_DIR=<base>`, args `tools run <name>`,
/// then bucket every `tools::run::ResponseItem` into its originating
/// stream. Order is preserved within each bucket; cross-bucket
/// ordering is dropped (the dispatch drains both streams
/// concurrently via `tokio_stream::StreamExt::merge`).
///
/// Each cli stdout line is the leaf `tools::run::ResponseItem`
/// serialized at the wire. Every `cli/command` aggregator
/// `Response`/`ResponseItem` is `#[serde(untagged)]` (sdk commit
/// 39c3320e7), so the `RunItem::Command(_)`, `cli::command::ResponseItem`,
/// and `tools::ResponseItem` wrappers all collapse and the wire is
/// just the leaf:
///   - `Stdout(String)` → a bare JSON string, e.g. `"hello, world"`
///   - `Stderr(cli::Error)` → the error struct directly, e.g.
///     `{"type":"error","message":"...", ...}`
/// — no `Tools/Run` wrapper to navigate.
fn run_and_summarize(base: &Path, name: &str) -> Summary {
    let cli = cli_test_util::cli_binary();
    let output = Command::new(cli)
        .env("CONFIG_BASE_DIR", base)
        .args([
            "tools", "run", "--owner", "objectiveai", "--name", name, "--version",
            "0.0.1",
        ])
        .output()
        .expect("failed to run cli");

    let stdout_text = String::from_utf8(output.stdout).expect("cli stdout not utf-8");
    let mut stdout_lines = Vec::new();
    let mut stderr_lines = Vec::new();
    for line in stdout_text.lines() {
        let Ok(v) = serde_json::from_str::<serde_json::Value>(line) else {
            continue;
        };
        if let Some(text) = v.as_str() {
            stdout_lines.push(text.to_string());
        } else if let Some(msg) = v.pointer("/message").and_then(|m| m.as_str()) {
            stderr_lines.push(msg.to_string());
        }
    }

    Summary {
        exit_code: output.status.code().unwrap_or(-1),
        stdout: stdout_lines,
        stderr: stderr_lines,
    }
}

#[test]
fn hello_tool_dispatch_snapshot() {
    let base = cli_test_util::test_base_dir();
    let summary = run_and_summarize(&base, "hello");
    insta::assert_json_snapshot!(summary);
}

#[test]
fn error_tool_dispatch_snapshot() {
    let base = cli_test_util::test_base_dir();
    let summary = run_and_summarize(&base, "error");
    insta::assert_json_snapshot!(summary);
}