pend 0.1.0

do now, wait later – tiny job runner
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

use assert_cmd::prelude::*;
use std::fs;
use std::process::Command;
use tempfile::TempDir;

fn pend_bin() -> Command {
    Command::cargo_bin("pend").expect("binary")
}

fn pend_with_temp() -> (TempDir, Command) {
    let tmp = TempDir::new().expect("tmp");
    let mut cmd = pend_bin();
    cmd.env("PEND_DIR", tmp.path());
    (tmp, cmd)
}

#[test]
fn clean_specific_job() {
    let (tmp, mut pend) = pend_with_temp();

    // create artifacts via quick command
    pend.args(["do", "jobx", "bash", "-c", "echo hi"]).assert().success();
    // wait to finish
    pend_bin()
        .env("PEND_DIR", tmp.path())
        .args(["wait", "jobx"])
        .assert()
        .success();

    let log_path = tmp.path().join("jobx.log");
    assert!(log_path.exists());

    // run clean for jobx
    pend_bin()
        .env("PEND_DIR", tmp.path())
        .args(["clean", "jobx"])
        .assert()
        .success();

    assert!(!log_path.exists());
}

#[test]
fn clean_all() {
    let (tmp, mut pend) = pend_with_temp();

    pend.args(["do", "one", "bash", "-c", "echo 1"]).assert().success();
    pend_bin()
        .env("PEND_DIR", tmp.path())
        .args(["wait", "one"])
        .assert()
        .success();

    pend_bin()
        .env("PEND_DIR", tmp.path())
        .args(["clean", "--all"])
        .assert()
        .success();

    assert!(fs::read_dir(tmp.path()).unwrap().next().is_none());
}