runifold-cli 0.7.2

Read-only operational CLI for Runifold artifacts and durable journals
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
105
106
107
108
109
110
111
112
113
114
115
116

//! End-to-end tests for the read-only operational CLI.

use std::{fs, path::PathBuf, process::Command};

use runifold_core::{EventFactory, LifecycleEvent, RunEventKind, RunId};
use runifold_store_sqlite::SqliteStore;
use serde_json::json;

#[test]
fn inspect_reads_a_complete_exported_run() {
    let path = temporary_path("json");
    let run_id = RunId::new();
    let factory = EventFactory::new(run_id, None);
    let started = factory.emit(RunEventKind::Lifecycle(LifecycleEvent::Started), None);
    let completed = factory.emit(
        RunEventKind::Lifecycle(LifecycleEvent::Completed {
            output: json!({"answer": 42}),
        }),
        Some(started.meta.event_id),
    );
    fs::write(
        &path,
        serde_json::to_vec(&vec![started, completed]).unwrap(),
    )
    .unwrap();

    let output = runifold()
        .args(["run", "inspect", "--events"])
        .arg(&path)
        .output()
        .unwrap();

    assert!(output.status.success(), "{}", stderr(&output));
    let value: serde_json::Value = serde_json::from_slice(&output.stdout).unwrap();
    assert_eq!(value["status"], "completed");
    assert_eq!(value["event_count"], 2);
    fs::remove_file(path).unwrap();
}

#[test]
fn inspect_rejects_empty_and_invalid_exports() {
    for contents in [b"[]".as_slice(), b"{".as_slice()] {
        let path = temporary_path("json");
        fs::write(&path, contents).unwrap();
        let output = runifold()
            .args(["run", "inspect", "--events"])
            .arg(&path)
            .output()
            .unwrap();
        assert!(!output.status.success());
        assert!(!output.stderr.is_empty());
        fs::remove_file(path).unwrap();
    }
}

#[test]
fn inspect_unknown_sqlite_run_is_read_only_and_fails_cleanly() {
    let path = temporary_path("sqlite3");
    drop(SqliteStore::open(&path).unwrap());
    let output = runifold()
        .args(["run", "inspect", "--sqlite"])
        .arg(&path)
        .args(["--run-id", &RunId::new().to_string()])
        .output()
        .unwrap();

    assert!(!output.status.success());
    assert!(!output.stderr.is_empty());
    assert!(path.exists());
    fs::remove_file(path).unwrap();
}

#[test]
fn replay_atomically_writes_a_complete_bundle() {
    let events = temporary_path("json");
    let output = temporary_path("replay.json");
    let run_id = RunId::new();
    let factory = EventFactory::new(run_id, None);
    let started = factory.emit(RunEventKind::Lifecycle(LifecycleEvent::Started), None);
    let completed = factory.emit(
        RunEventKind::Lifecycle(LifecycleEvent::Completed { output: json!({}) }),
        Some(started.meta.event_id),
    );
    fs::write(
        &events,
        serde_json::to_vec(&vec![started, completed]).unwrap(),
    )
    .unwrap();

    let command = runifold()
        .args(["run", "replay", "--events"])
        .arg(&events)
        .arg("--output")
        .arg(&output)
        .output()
        .unwrap();
    assert!(command.status.success(), "{}", stderr(&command));
    let bundle: serde_json::Value = serde_json::from_slice(&fs::read(&output).unwrap()).unwrap();
    assert_eq!(bundle["mode"], "side_effect_free_evidence");
    assert_eq!(bundle["events"].as_array().unwrap().len(), 2);

    fs::remove_file(events).unwrap();
    fs::remove_file(output).unwrap();
}

fn runifold() -> Command {
    Command::new(env!("CARGO_BIN_EXE_runifold"))
}

fn temporary_path(extension: &str) -> PathBuf {
    std::env::temp_dir().join(format!("runifold-cli-{}.{}", RunId::new(), extension))
}

fn stderr(output: &std::process::Output) -> String {
    String::from_utf8_lossy(&output.stderr).into_owned()
}