ralph-agent-loop 0.3.1

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

//! Sink rendering helpers for runner JSON events.
//!
//! Responsibilities:
//! - Render normalized display lines to terminal sinks and optional handlers.
//! - Keep output fanout separate from event parsing and stream reading.
//!
//! Does not handle:
//! - JSON parsing or event correlation.
//! - Buffer management.

use crate::runner::{OutputHandler, OutputStream};
use serde_json::Value as JsonValue;

use super::StreamSink;
use super::stream_events::extract_display_lines;

pub(crate) fn display_filtered_json(
    json: &JsonValue,
    sink: &StreamSink,
    output_handler: Option<&OutputHandler>,
    output_stream: OutputStream,
) -> anyhow::Result<()> {
    for mut line in extract_display_lines(json) {
        sink.write_all(line.as_bytes(), output_stream)?;
        sink.write_all(b"\n", output_stream)?;
        if let Some(handler) = output_handler {
            line.push('\n');
            handler(&line);
        }
    }

    Ok(())
}