tcrm-task 0.4.2

Task execution unit for TCRM project
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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

use crate::tasks::config::TaskConfig;

#[test]
fn basic() {
    let config = TaskConfig::new("cargo")
        .args(["build", "--release"])
        .working_dir("/home/user/project")
        .env([("RUST_LOG", "debug"), ("CARGO_TARGET_DIR", "target")])
        .timeout_ms(300)
        .enable_stdin(true);

    assert_eq!(config.command, "cargo");
    assert_eq!(
        config.args,
        Some(vec!["build".to_string(), "--release".to_string()])
    );
    assert_eq!(config.working_dir, Some("/home/user/project".to_string()));
    assert!(config.env.is_some());
    assert_eq!(config.timeout_ms, Some(300));
    assert_eq!(config.enable_stdin, Some(true));
}

#[test]
fn env_hashmap() {
    use std::collections::HashMap;
    let mut env = HashMap::new();
    env.insert("FOO".to_string(), "bar".to_string());
    env.insert("BAZ".to_string(), "qux".to_string());
    let config = TaskConfig::new("env").env(env.clone());
    assert_eq!(config.env, Some(env));
}

#[test]
fn config_builder_timeout() {
    let config = TaskConfig::new("server").timeout_ms(5000);
    assert_eq!(config.timeout_ms, Some(5000));
}

#[test]
fn config_builder_ready_indicator_stdout() {
    let config = TaskConfig::new("server")
        .ready_indicator("Server started")
        .ready_indicator_source(crate::tasks::config::StreamSource::Stdout);
    assert_eq!(config.ready_indicator, Some("Server started".to_string()));
    assert_eq!(
        config.ready_indicator_source,
        Some(crate::tasks::config::StreamSource::Stdout)
    );
}
#[test]
fn config_builder_ready_indicator_stderr() {
    let config = TaskConfig::new("server")
        .ready_indicator("Server started")
        .ready_indicator_source(crate::tasks::config::StreamSource::Stderr);
    assert_eq!(config.ready_indicator, Some("Server started".to_string()));
    assert_eq!(
        config.ready_indicator_source,
        Some(crate::tasks::config::StreamSource::Stderr)
    );
}

#[cfg(feature = "process-group")]
#[test]
fn process_group_disabled() {
    let config = TaskConfig::new("cmd").use_process_group(false);
    assert_eq!(config.use_process_group, Some(false));
}

#[cfg(feature = "process-group")]
#[test]
fn process_group_enabled_default() {
    let config = TaskConfig::new("cmd");
    assert_eq!(config.use_process_group, Some(true));
}

#[test]
fn disable_stdin_default() {
    let config = TaskConfig::new("python");
    assert_eq!(config.enable_stdin, Some(false));
}

#[test]
fn args_vec() {
    let config = TaskConfig::new("ls").args(vec!["-l", "/tmp"]);
    assert_eq!(
        config.args,
        Some(vec!["-l".to_string(), "/tmp".to_string()])
    );
}

#[test]
fn working_dir_none_by_default() {
    let config = TaskConfig::new("ls");
    assert_eq!(config.working_dir, None);
}

#[test]
fn env_none_by_default() {
    let config = TaskConfig::new("ls");
    assert_eq!(config.env, None);
}

#[test]
fn timeout_none_by_default() {
    let config = TaskConfig::new("ls");
    assert_eq!(config.timeout_ms, None);
}

#[test]
fn ready_indicator_none_by_default() {
    let config = TaskConfig::new("ls");
    assert_eq!(config.ready_indicator, None);
}

#[test]
fn ready_indicator_source_default() {
    let config = TaskConfig::new("ls");
    assert_eq!(
        config.ready_indicator_source,
        Some(crate::tasks::config::StreamSource::Stdout)
    );
}