isothrum-runner 1.0.1

The Isothrum runner: executes the run manifest Isoloom writes next to a target's files (lifecycle, state and locks, drivers, checks, events).
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

use super::*;
use crate::testing::proxmox_manifest;

fn state(text: &str) -> state::TfState {
    state::parse(text).unwrap()
}

#[test]
fn every_machine_is_absent_until_the_state_holds_resources() {
    let m = proxmox_manifest();
    let o = observed(&m, &state::TfState::default());
    assert!(o.machines.iter().all(|x| x.state == MachineState::Absent));
    assert!(o.published.is_empty() && o.outputs.is_empty());
}

#[test]
fn an_applied_state_runs_every_machine_and_publishes_at_the_routers_address() {
    let m = proxmox_manifest();
    let tf = state(r#"{"outputs":{"ip":{"value":"10.10.10.7"},"published":{"value":{"web/web":"10.10.10.7:8080"}}},"resources":[{"instances":[{}]}]}"#);
    let o = observed(&m, &tf);
    assert!(o.machines.iter().all(|x| x.state == MachineState::Running), "{:?}", o.machines);
    assert_eq!(o.published.get(&("web".to_owned(), "web".to_owned())), Some(&8080));
    assert_eq!(o.outputs.get("ip").map(String::as_str), Some("10.10.10.7"));
    let web = o.machines.iter().find(|x| x.name == "web").unwrap();
    assert_eq!(web.addresses.get("app").map(String::as_str), Some("10.80.0.10"));
}

#[test]
fn a_tainted_resource_leaves_the_machines_unhealthy() {
    // A machine's create or provisioner failed: the VMs exist, the run never came up.
    let tf = state(r#"{"resources":[{"instances":[{"status":"tainted"}]}]}"#);
    let o = observed(&proxmox_manifest(), &tf);
    assert!(o.machines.iter().all(|x| x.state == MachineState::Unhealthy));
}

#[test]
fn removing_what_isnt_there_is_fine() {
    let dir = tempfile::tempdir().unwrap();
    remove(&dir.path().join("missing")).unwrap();
    std::fs::create_dir_all(dir.path().join(".terraform/providers")).unwrap();
    std::fs::write(dir.path().join(LOCK_FILE), "{}").unwrap();
    remove(&dir.path().join(".terraform")).unwrap();
    remove(&dir.path().join(LOCK_FILE)).unwrap();
    assert_eq!(std::fs::read_dir(dir.path()).unwrap().count(), 0);
}