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

//! Productivity stats persistence layer.
//!
//! Responsibilities:
//! - Load and save productivity stats from/to the cache directory.
//!
//! Not handled here:
//! - Data structure definitions (see `super::types`).
//! - Business logic for updating stats (see `super::calculations`).
//!
//! Invariants/assumptions:
//! - Stats file is JSON with schema version for migrations.
//! - All operations are atomic (read-modify-write with temp file + rename).

use anyhow::{Context, Result};
use std::fs;
use std::io::Write;
use std::path::Path;

use crate::constants::paths::STATS_FILENAME;

use super::types::ProductivityStats;

/// Load productivity stats from cache directory
pub fn load_productivity_stats(cache_dir: &Path) -> Result<ProductivityStats> {
    let path = cache_dir.join(STATS_FILENAME);

    if !path.exists() {
        return Ok(ProductivityStats::default());
    }

    let content = fs::read_to_string(&path)
        .with_context(|| format!("Failed to read productivity stats from {}", path.display()))?;

    let stats: ProductivityStats = serde_json::from_str(&content)
        .with_context(|| format!("Failed to parse productivity stats from {}", path.display()))?;

    Ok(stats)
}

/// Save productivity stats to cache directory
pub fn save_productivity_stats(stats: &ProductivityStats, cache_dir: &Path) -> Result<()> {
    let path = cache_dir.join(STATS_FILENAME);

    // Ensure cache directory exists
    fs::create_dir_all(cache_dir)
        .with_context(|| format!("Failed to create cache directory {}", cache_dir.display()))?;

    let content =
        serde_json::to_string_pretty(stats).context("Failed to serialize productivity stats")?;

    // Atomic write: write to temp file then rename
    let temp_path = path.with_extension("tmp");
    let mut file = fs::File::create(&temp_path)
        .with_context(|| format!("Failed to create temp file {}", temp_path.display()))?;
    file.write_all(content.as_bytes())
        .with_context(|| format!("Failed to write to temp file {}", temp_path.display()))?;
    file.flush()
        .with_context(|| format!("Failed to flush temp file {}", temp_path.display()))?;
    drop(file);

    fs::rename(&temp_path, &path)
        .with_context(|| format!("Failed to rename temp file to {}", path.display()))?;

    Ok(())
}