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

//! Processor-hook temp-file IO helpers.
//!
//! Responsibilities:
//! - Materialize task/prompt/stdout payloads into temp files.
//! - Read back modified payloads from hook temp files.
//!
//! Not handled here:
//! - Hook dispatch or subprocess execution.
//! - Plugin discovery and enable policy.
//!
//! Invariants/assumptions:
//! - Hook payload files remain UTF-8 text.
//! - Temp payloads live long enough for the full hook chain invocation.

use std::io::Write;
use std::path::Path;

use anyhow::{Context, Result};
use tempfile::TempPath;

use crate::contracts::Task;

use super::ProcessorExecutor;

impl ProcessorExecutor<'_> {
    pub(super) fn write_task_payload(&self, task: &Task) -> Result<TempPath> {
        let task_json =
            serde_json::to_string_pretty(task).context("serialize task for validate_task hook")?;
        self.write_text_payload("plugin", &task_json, "validate_task")
    }

    pub(super) fn write_text_payload(
        &self,
        label: &str,
        content: &str,
        context_label: &str,
    ) -> Result<TempPath> {
        let mut temp_file = crate::fsutil::create_ralph_temp_file(label)
            .with_context(|| format!("create temp file for {context_label}"))?;
        temp_file
            .write_all(content.as_bytes())
            .with_context(|| format!("write {context_label} payload to temp file"))?;
        Ok(temp_file.into_temp_path())
    }

    pub(super) fn read_text_payload(&self, path: &Path, context_label: &str) -> Result<String> {
        std::fs::read_to_string(path)
            .with_context(|| format!("read {context_label} from temp file"))
    }
}