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

//! Shared queue validation data structures.
//!
//! Responsibilities:
//! - Build stable task lookup structures shared across validators.
//! - Expose active-task and all-task views without repeating collection code.
//!
//! Not handled here:
//! - Validation policy or warning generation.
//! - Queue mutation or repair.
//!
//! Invariants/assumptions:
//! - Task IDs are trimmed before use as lookup keys.
//! - The active queue is the only source used for dependency-depth warnings.

use crate::contracts::{QueueFile, Task};
use std::collections::{HashMap, HashSet};

pub(crate) struct TaskCatalog<'a> {
    pub(crate) active_tasks: Vec<&'a Task>,
    pub(crate) tasks: Vec<&'a Task>,
    pub(crate) all_tasks: HashMap<&'a str, &'a Task>,
    pub(crate) all_task_ids: HashSet<&'a str>,
}

impl<'a> TaskCatalog<'a> {
    pub(crate) fn new(active: &'a QueueFile, done: Option<&'a QueueFile>) -> Self {
        let active_tasks: Vec<&Task> = active.tasks.iter().collect();
        let mut tasks = active_tasks.clone();
        if let Some(done_file) = done {
            tasks.extend(done_file.tasks.iter());
        }

        let mut all_tasks = HashMap::new();
        for task in &tasks {
            all_tasks.insert(task.id.trim(), *task);
        }

        let all_task_ids = all_tasks.keys().copied().collect();

        Self {
            active_tasks,
            tasks,
            all_tasks,
            all_task_ids,
        }
    }
}