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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

//! Shared GitHub CLI helpers for git-facing integrations.
//!
//! Responsibilities:
//! - Provide consistent `gh` command construction with updater prompts disabled.
//! - Run managed `gh` subprocesses with centralized truncation logging.
//! - Share small output-parsing helpers used by PR/issue modules.
//!
//! Not handled here:
//! - PR- or issue-specific command flags and JSON parsing.
//! - Authentication or lifecycle policy decisions.
//!
//! Invariants/assumptions:
//! - All commands use `GH_NO_UPDATE_NOTIFIER=1`.
//! - Callers choose the appropriate timeout class for the operation.

use anyhow::Result;
use std::path::Path;
use std::process::{Command, Output};

use crate::runutil::{ManagedCommand, TimeoutClass, execute_managed_command};

pub(crate) fn gh_command(repo_root: &Path) -> Command {
    gh_command_in(repo_root)
}

pub(crate) fn gh_command_in(cwd: &Path) -> Command {
    let mut command = Command::new("gh");
    command.current_dir(cwd).env("GH_NO_UPDATE_NOTIFIER", "1");
    command
}

pub(crate) fn extract_first_url(output: &str) -> Option<String> {
    output
        .lines()
        .map(str::trim)
        .find(|line| line.starts_with("http://") || line.starts_with("https://"))
        .map(ToString::to_string)
}

pub(crate) fn run_gh_command(
    command: Command,
    description: impl Into<String>,
    timeout_class: TimeoutClass,
    truncation_log_label: &str,
) -> Result<Output> {
    execute_managed_command(ManagedCommand::new(command, description, timeout_class))
        .map(|output| {
            if output.stdout_truncated || output.stderr_truncated {
                log::debug!("managed {truncation_log_label} capture truncated command output");
            }
            output.into_output()
        })
        .map_err(Into::into)
}

#[cfg(test)]
mod tests {
    use super::extract_first_url;

    #[test]
    fn extract_first_url_picks_first_url_line() {
        let output = "Starting operation...\nhttps://github.com/org/repo/issues/5\n";
        let url = extract_first_url(output).expect("url");
        assert_eq!(url, "https://github.com/org/repo/issues/5");
    }

    #[test]
    fn extract_first_url_returns_none_when_absent() {
        assert!(extract_first_url("no url here").is_none());
    }
}