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
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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

//! Snapshot tests for `ralph queue graph` output formats.
//!
//! Responsibilities:
//! - Lock in deterministic graph outputs for the primary human-readable and export formats.
//! - Provide small fixtures that exercise dependencies + blocks + relates + duplicates.
//!
//! Not handled here:
//! - Deep algorithm validation (covered by graph unit tests / invariants near implementation).
//! - Exhaustive traversal edge cases beyond the focused fixture below.
//!
//! Invariants/assumptions:
//! - DOT output ordering is deterministic (nodes are collected into a Vec and sorted).

use anyhow::Result;
use ralph::contracts::TaskStatus;

mod test_support;

fn write_graph_fixture(dir: &std::path::Path) -> Result<()> {
    let t1 = test_support::make_test_task("RQ-0001", "Root", TaskStatus::Todo);
    let mut t2 = test_support::make_test_task("RQ-0002", "Depends on RQ-0001", TaskStatus::Todo);
    t2.depends_on = vec!["RQ-0001".to_string()];

    let mut t3 = test_support::make_test_task("RQ-0003", "Blocks RQ-0002", TaskStatus::Doing);
    t3.blocks = vec!["RQ-0002".to_string()];

    let mut t4 = test_support::make_test_task("RQ-0004", "Relates/duplicates", TaskStatus::Todo);
    t4.relates_to = vec!["RQ-0001".to_string()];
    t4.duplicates = Some("RQ-0002".to_string());

    test_support::write_queue(dir, &[t1, t2, t3, t4])?;
    test_support::write_done(dir, &[])?;
    Ok(())
}

#[test]
fn graph_tree_snapshot() -> Result<()> {
    let dir = test_support::temp_dir_outside_repo();
    test_support::git_init(dir.path())?;
    test_support::seed_ralph_dir(dir.path())?;
    write_graph_fixture(dir.path())?;

    let (status, stdout, stderr) = test_support::run_in_dir(dir.path(), &["queue", "graph"]);
    anyhow::ensure!(status.success(), "graph tree failed\nstderr:\n{stderr}");

    test_support::with_insta_settings(|| {
        insta::assert_snapshot!(
            "queue_graph_tree_full",
            test_support::normalize_for_snapshot(&stdout)
        );
    });

    Ok(())
}

#[test]
fn graph_dot_focus_task_snapshot() -> Result<()> {
    let dir = test_support::temp_dir_outside_repo();
    test_support::git_init(dir.path())?;
    test_support::seed_ralph_dir(dir.path())?;
    write_graph_fixture(dir.path())?;

    let (status, stdout, stderr) = test_support::run_in_dir(
        dir.path(),
        &["queue", "graph", "--format", "dot", "--task", "RQ-0002"],
    );
    anyhow::ensure!(status.success(), "graph dot failed\nstderr:\n{stderr}");

    test_support::with_insta_settings(|| {
        insta::assert_snapshot!(
            "queue_graph_dot_task_rq_0002",
            test_support::normalize_for_snapshot(&stdout)
        );
    });

    Ok(())
}

#[test]
fn graph_rejects_unknown_task_id() -> Result<()> {
    let dir = test_support::temp_dir_outside_repo();
    test_support::git_init(dir.path())?;
    test_support::seed_ralph_dir(dir.path())?;
    write_graph_fixture(dir.path())?;

    let (status, _stdout, stderr) =
        test_support::run_in_dir(dir.path(), &["queue", "graph", "--task", "RQ-9999"]);
    anyhow::ensure!(!status.success(), "expected failure for unknown task");
    anyhow::ensure!(
        stderr.to_lowercase().contains("task not found"),
        "unexpected stderr:\n{stderr}"
    );
    Ok(())
}

#[test]
fn graph_list_snapshot() -> Result<()> {
    let dir = test_support::temp_dir_outside_repo();
    test_support::git_init(dir.path())?;
    test_support::seed_ralph_dir(dir.path())?;
    write_graph_fixture(dir.path())?;

    let (status, stdout, stderr) =
        test_support::run_in_dir(dir.path(), &["queue", "graph", "--format", "list"]);
    anyhow::ensure!(status.success(), "graph list failed\nstderr:\n{stderr}");

    test_support::with_insta_settings(|| {
        insta::assert_snapshot!(
            "queue_graph_list_full",
            test_support::normalize_for_snapshot(&stdout)
        );
    });

    Ok(())
}