loopflow 0.10.1

Run steps and flows with coding agents
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

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

use crate::engine::config::load_config_or_default;
use crate::engine::git::current_branch;
use crate::engine::naming::wave_name_from_branch;
use crate::engine::worktrees::wave_name_from_worktree;

pub fn command_exists(name: &str) -> bool {
    Command::new(name)
        .arg("--version")
        .stdout(std::process::Stdio::null())
        .stderr(std::process::Stdio::null())
        .status()
        .map(|status| status.success())
        .unwrap_or(false)
}

pub fn stderr_from_output(output: &Output) -> String {
    String::from_utf8_lossy(&output.stderr).trim().to_string()
}

/// Resolve the wave name for workflow operations.
///
/// Priority: explicit wave name > worktree directory name > branch name component.
pub fn resolve_wave_name(repo: &Path, explicit: Option<&str>) -> Option<String> {
    if let Some(name) = explicit.and_then(normalize_wave_name) {
        return Some(name);
    }
    if let Some(name) = wave_name_from_worktree(repo).and_then(|name| normalize_wave_name(&name)) {
        return Some(name);
    }
    if let Ok(Some(branch)) = current_branch(repo) {
        let config = load_config_or_default(Some(repo));
        return wave_name_from_branch(&branch, config.branch_names.as_ref())
            .and_then(|name| normalize_wave_name(&name));
    }
    None
}

fn normalize_wave_name(value: &str) -> Option<String> {
    let trimmed = value.trim();
    if trimmed.is_empty() {
        return None;
    }
    let normalized = trimmed
        .strip_prefix("wave/")
        .unwrap_or(trimmed)
        .trim_matches('/');
    if normalized.is_empty() {
        None
    } else {
        Some(normalized.to_string())
    }
}