zoi-rs 1.18.0

Advanced Package Manager & Environment Orchestrator
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

use std::fs;
use tempfile::tempdir;
use zoi::project::{config, runner};

mod common;

#[test]
fn test_task_runner_sequential_dependencies() {
    let mut ctx = common::TestContextGuard::acquire();
    let tmp = tempdir().expect("Failed to create temp dir");
    let root = tmp.path().to_path_buf();
    ctx.set_current_dir(&root);

    let yaml = r#"
name: test-task-deps
commands:
  - cmd: first
    run: echo "1" > first.txt
  - cmd: second
    run: echo "2" > second.txt
    depends_on: ["first"]
"#;
    fs::write(root.join("zoi.yaml"), yaml).unwrap();

    let cfg = config::load().unwrap();
    runner::run(Some("second"), &[], &cfg).unwrap();

    assert!(
        root.join("first.txt").exists(),
        "First task should have run"
    );
    assert!(
        root.join("second.txt").exists(),
        "Second task should have run"
    );
}

#[test]
fn test_task_runner_caching() {
    let mut ctx = common::TestContextGuard::acquire();
    let tmp = tempdir().expect("Failed to create temp dir");
    let root = tmp.path().to_path_buf();
    ctx.set_current_dir(&root);

    let yaml = r#"
name: test-task-caching
commands:
  - cmd: cached-task
    run: echo "running" >> output.txt
    cache_files: ["input.txt"]
"#;
    fs::write(root.join("zoi.yaml"), yaml).unwrap();
    fs::write(root.join("input.txt"), "input-v1").unwrap();

    let cfg = config::load().unwrap();

    runner::run(Some("cached-task"), &[], &cfg).unwrap();
    let count1 = fs::read_to_string(root.join("output.txt"))
        .unwrap()
        .lines()
        .count();
    assert_eq!(count1, 1);

    runner::run(Some("cached-task"), &[], &cfg).unwrap();
    let count2 = fs::read_to_string(root.join("output.txt"))
        .unwrap()
        .lines()
        .count();
    assert_eq!(count2, 1, "Should have been skipped due to caching");

    fs::write(root.join("input.txt"), "input-v2").unwrap();
    runner::run(Some("cached-task"), &[], &cfg).unwrap();
    let count3 = fs::read_to_string(root.join("output.txt"))
        .unwrap()
        .lines()
        .count();
    assert_eq!(count3, 2, "Should have run again after input changed");
}

#[test]
fn test_task_runner_circular_dependency_detection() {
    let mut ctx = common::TestContextGuard::acquire();
    let tmp = tempdir().expect("Failed to create temp dir");
    let root = tmp.path().to_path_buf();
    ctx.set_current_dir(&root);

    let yaml = r#"
name: test-circular
commands:
  - cmd: a
    run: echo a
    depends_on: ["b"]
  - cmd: b
    run: echo b
    depends_on: ["a"]
"#;
    fs::write(root.join("zoi.yaml"), yaml).unwrap();

    let cfg = config::load().unwrap();
    let res = runner::run(Some("a"), &[], &cfg);

    assert!(res.is_err(), "Should detect circular dependency");
    assert!(res.unwrap_err().to_string().contains("Circular dependency"));
}