cueloop 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

//! Shared diff helpers for task command reporting.
//!
//! Purpose:
//! - Compute field-level task JSON diffs for task update reporting.
//!
//! Responsibilities:
//! - Compare before/after JSON payloads and return a stable list of changed top-level fields.
//!
//! Not handled here:
//! - Logging.
//! - Queue loading.
//! - Semantic validation of task updates.
//!
//! Usage:
//! - Used by task update reporting helpers and tests that assert task field deltas.
//!
//! Invariants/assumptions:
//! - Inputs are valid JSON objects or valid JSON values; non-object comparisons collapse to `task`.
//! - Changed field ordering follows the after-object iteration order.

use anyhow::Result;

pub fn compare_task_fields(before: &str, after: &str) -> Result<Vec<String>> {
    let before_value: serde_json::Value = serde_json::from_str(before)?;
    let after_value: serde_json::Value = serde_json::from_str(after)?;

    if let (Some(before_obj), Some(after_obj)) = (before_value.as_object(), after_value.as_object())
    {
        let mut changed = Vec::new();
        for (key, after_val) in after_obj {
            if let Some(before_val) = before_obj.get(key) {
                if before_val != after_val {
                    changed.push(key.clone());
                }
            } else {
                changed.push(key.clone());
            }
        }
        Ok(changed)
    } else {
        Ok(vec!["task".to_string()])
    }
}