ralph-agent-loop 0.3.0

A Rust CLI for managing AI agent loops with a structured JSON task queue
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

//! OpenCode stream event extraction.
//!
//! Responsibilities:
//! - Render plain `text`, `reasoning`, `error`, and tool-use events emitted by OpenCode.
//! - Handle assistant `message` content carried outside the Claude schema.
//!
//! Does not handle:
//! - Codex item streams or Cursor tool call envelopes.

use crate::outpututil;
use serde_json::Value as JsonValue;

use super::super::stream_tool_details::format_tool_details;
use super::common;

pub(super) fn collect_lines(json: &JsonValue, lines: &mut Vec<String>) {
    let Some(event_type) = json.get("type").and_then(|t| t.as_str()) else {
        return;
    };

    match event_type {
        "text" => common::push_text(
            lines,
            json.get("part")
                .and_then(|p| p.get("text"))
                .and_then(|t| t.as_str()),
        ),
        "reasoning" => common::push_reasoning(
            lines,
            json.get("part")
                .and_then(|p| p.get("text"))
                .and_then(|t| t.as_str()),
        ),
        "error" => common::push_error(lines, json.get("message").and_then(|m| m.as_str())),
        "tool_use" => {
            if let Some(tool) = json
                .get("part")
                .and_then(|p| p.get("tool"))
                .and_then(|t| t.as_str())
            {
                let status = json
                    .get("part")
                    .and_then(|p| p.get("state"))
                    .and_then(|s| s.get("status"))
                    .and_then(|s| s.as_str())
                    .map(|value| format!("({value})"));
                let details = json
                    .get("part")
                    .and_then(|p| {
                        p.get("state")
                            .and_then(|s| s.get("input"))
                            .or_else(|| p.get("input"))
                    })
                    .and_then(format_tool_details);
                let merged = match (status.as_deref(), details.as_deref()) {
                    (None, None) => None,
                    (None, Some(details)) => Some(details.to_string()),
                    (Some(status), None) => Some(status.to_string()),
                    (Some(status), Some(details)) => Some(format!("{} {}", status, details)),
                };
                lines.push(outpututil::format_tool_call(tool, merged.as_deref()));
            }
        }
        "message" => {
            if json.get("role").and_then(|r| r.as_str()) == Some("assistant")
                && let Some(content) = json.get("content")
            {
                match content {
                    JsonValue::String(text) => common::push_text(lines, Some(text)),
                    JsonValue::Array(items) => {
                        for item in items {
                            common::push_text(lines, item.get("text").and_then(|t| t.as_str()));
                        }
                    }
                    _ => {}
                }
            }
        }
        _ => {}
    }
}