ralph-agent-loop 0.4.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

//! Shared helpers for stream event display extraction.
//!
//! Responsibilities:
//! - Provide small formatting helpers reused by protocol-specific collectors.
//! - Keep repeated text/error/result extraction logic out of the hot-path router.
//!
//! Does not handle:
//! - Protocol-specific event branching.
//! - Tool-call correlation.

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

pub(super) fn push_result_line(json: &JsonValue, lines: &mut Vec<String>) {
    if let Some(result) = json.get("result").and_then(|r| r.as_str())
        && !result.is_empty()
    {
        lines.push(result.to_string());
    }
}

pub(super) fn push_text(lines: &mut Vec<String>, text: Option<&str>) {
    if let Some(text) = text
        && !text.is_empty()
    {
        lines.push(text.to_string());
    }
}

pub(super) fn push_reasoning(lines: &mut Vec<String>, text: Option<&str>) {
    if let Some(text) = text
        && !text.is_empty()
    {
        lines.push(outpututil::format_reasoning(text));
    }
}

pub(super) fn push_error(lines: &mut Vec<String>, text: Option<&str>) {
    if let Some(text) = text
        && !text.trim().is_empty()
    {
        lines.push(format!("[Error] {}", text));
    }
}

pub(super) fn push_permission_denials(json: &JsonValue, lines: &mut Vec<String>) {
    if let Some(denials) = json.get("permission_denials").and_then(|d| d.as_array()) {
        for denial in denials {
            if let Some(tool_name) = denial.get("tool_name").and_then(|t| t.as_str()) {
                lines.push(outpututil::format_permission_denied(tool_name));
            }
        }
    }
}