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

//! Debug log tests for runner stream readers.

use super::super::stream::{StreamSink, spawn_reader};
use crate::debuglog::{enable, reset_for_tests, test_lock};
use crate::runner::OutputStream;
use serial_test::serial;
use std::fs;
use std::io::Cursor;
use std::sync::{Arc, Mutex};
use tempfile::tempdir;

#[test]
#[serial]
fn spawn_reader_writes_raw_chunks_to_debug_log() {
    let _guard = test_lock().lock().expect("debug log lock");
    reset_for_tests();
    let dir = tempdir().expect("tempdir");
    enable(dir.path()).expect("enable debug log");

    let payload = b"raw stderr chunk\nsecond line\n";
    let buffer = Arc::new(Mutex::new(String::new()));

    let handle = spawn_reader(
        Cursor::new(payload),
        StreamSink::Stderr,
        Arc::clone(&buffer),
        None,
        OutputStream::HandlerOnly,
    );
    handle.join().expect("join").expect("reader ok");

    let debug_log = dir.path().join(".ralph/logs/debug.log");
    let contents = fs::read_to_string(&debug_log).expect("read log");
    assert!(
        contents.contains("[RUNNER STDERR]"),
        "log contents: {contents}"
    );
    assert!(
        contents.contains("raw stderr chunk"),
        "log contents: {contents}"
    );
    assert!(contents.contains("second line"), "log contents: {contents}");
    reset_for_tests();
}