shep 0.13.0

The shep binary: a process manager that keeps a flock of long-running processes alive on macOS, Linux and Windows, with logs, watch and cron restarts, and webhook alerts
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

//! `emit_dog_action`: the one place a dog verb's row reaches stdout.

use shep_core::protocol::DogSource;

use super::emit_dog_action;
use super::test_support::streams;
use crate::cli::Format;
use crate::exit::ExitCode;

#[test]
fn emit_dog_action_wraps_the_row_in_the_verb_s_envelope_under_json() {
    let mut out = Vec::new();
    let mut err = Vec::new();
    let mut streams = streams(&mut out, &mut err);
    streams.fmt = Format::Json;

    let code = emit_dog_action(
        &mut streams,
        "disable",
        "bark",
        DogSource::BuiltIn,
        "stopped",
        true,
    );

    assert_eq!(code, ExitCode::Success);
    let value: serde_json::Value = serde_json::from_slice(&out).unwrap();
    assert_eq!(value["command"], "disable");
    assert_eq!(value["data"]["name"], "bark");
    assert_eq!(value["data"]["status"], "stopped");
    assert_eq!(value["data"]["shepherd_acted"], true);
    assert!(err.is_empty());
}

#[test]
fn emit_dog_action_carries_shepherd_acted_false_when_no_shepherd_answered() {
    let mut out = Vec::new();
    let mut err = Vec::new();
    let mut streams = streams(&mut out, &mut err);
    streams.fmt = Format::Json;

    let code = emit_dog_action(&mut streams, "enable", "bark", None, "will start", false);

    assert_eq!(code, ExitCode::Success);
    let value: serde_json::Value = serde_json::from_slice(&out).unwrap();
    assert_eq!(value["command"], "enable");
    assert_eq!(value["data"]["shepherd_acted"], false);
}

#[test]
fn emit_dog_action_writes_the_table_row_under_table() {
    let mut out = Vec::new();
    let mut err = Vec::new();

    let code = emit_dog_action(
        &mut streams(&mut out, &mut err),
        "adopt",
        "otel",
        None,
        "running",
        true,
    );

    assert_eq!(code, ExitCode::Success);
    let text = String::from_utf8(out).unwrap();
    assert!(text.contains("otel"), "{text}");
    assert!(text.contains("running"), "{text}");
}