cueloop 0.5.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

//! Debug log tests for runner stream readers.
//!
//! Purpose:
//! - Debug log tests for runner stream readers.
//!
//! Responsibilities:
//! - Provide focused implementation or regression coverage for this file's owning feature.
//!
//! Scope:
//! - Limited to this file's owning feature boundary.
//!
//!
//! Usage:
//! - Used through the crate module tree or integration test harness.
//!
//! Invariants/Assumptions:
//! - Keep behavior aligned with CueLoop's canonical CLI, machine-contract, and queue semantics.

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(".cueloop/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();
}