o7 0.1.1

O7 workflow DSL runner
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

use crate::state::types::RunStatus;

fn quote_shell_arg(value: &str) -> String {
    let escaped = value.replace('\'', "'\"'\"'");
    format!("'{}'", escaped)
}

pub fn build_quit_summary(
    run_id: &str,
    root_workflow: &str,
    status: &RunStatus,
    project_root: &str,
) -> String {
    let project_arg = quote_shell_arg(project_root);
    let mut lines = vec![
        "Run summary:".to_string(),
        format!("  Run ID: {}", run_id),
        format!("  Status: {}", status),
        format!("  Workflow: {}", root_workflow),
        format!("  Inspect: o7 inspect {} --project {}", run_id, project_arg),
    ];

    if *status == RunStatus::Paused {
        lines.push(format!(
            "  Resume:  o7 resume {} --project {}",
            run_id, project_arg
        ));
    } else {
        lines.push(format!("  Resume:  not available (run is {})", status));
    }

    lines.join("\n")
}

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

    #[test]
    fn test_build_quit_summary_for_paused_run() {
        let summary =
            build_quit_summary("run-123", "main", &RunStatus::Paused, "/tmp/project root");
        assert!(summary.contains("Run ID: run-123"));
        assert!(summary.contains("Status: paused"));
        assert!(summary.contains("Workflow: main"));
        assert!(summary.contains("o7 resume run-123 --project '/tmp/project root'"));
    }

    #[test]
    fn test_build_quit_summary_for_completed_run() {
        let summary =
            build_quit_summary("run-456", "deploy", &RunStatus::Completed, "/tmp/project");
        assert!(summary.contains("Run ID: run-456"));
        assert!(summary.contains("Status: completed"));
        assert!(summary.contains("Resume:  not available (run is completed)"));
    }
}