ostraka 1.0.0

Run agent fleets you can actually review.
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

//! `ostraka runs` — what this project has recorded.
//!
//! The same listing the browser shows, for the places a browser cannot go: a
//! pipe, a CI log, a machine reading `--json`.

use ostraka_runtime::index;

type Outcome = Result<bool, Box<dyn std::error::Error>>;

pub fn run(workspace: &crate::workspace::Workspace, json: bool) -> Outcome {
    let runs = index::list(&workspace.records())?;

    if json {
        let rows: Vec<_> = runs
            .iter()
            .map(|r| {
                serde_json::json!({
                    "run_id": r.run_id,
                    "started_at": r.started_at,
                    "prompt": r.prompt,
                    "author": r.author.to_string(),
                    "adapter": r.adapter,
                    "reviewer": r.reviewer.as_ref().map(ToString::to_string),
                    "outcome": r.outcome,
                    "checks_passed": r.checks_passed,
                    "checks_total": r.checks_total,
                })
            })
            .collect();
        println!("{}", serde_json::to_string_pretty(&rows)?);
    } else if runs.is_empty() {
        println!("no runs recorded yet");
    } else {
        for r in &runs {
            let word = match r.outcome {
                Some(ostraka_core::record::Outcome::Approved) => "approved",
                Some(ostraka_core::record::Outcome::Rejected) => "refused",
                Some(ostraka_core::record::Outcome::Failed) => "failed",
                None => "unfinished",
            };
            println!("{:<10}  {:<28}  {}", word, r.run_id, first_line(&r.prompt));
        }
    }

    Ok(true)
}

fn first_line(prompt: &str) -> String {
    if prompt.trim().is_empty() {
        return "(recorded before runs kept the task text)".to_string();
    }
    let line = prompt.lines().next().unwrap_or_default();
    if line.chars().count() > 72 {
        format!("{}…", line.chars().take(71).collect::<String>())
    } else {
        line.to_string()
    }
}