arpx 0.5.0

Small-scale process orchestration
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

mod cli;

use anyhow::{Context, Result};
use arpx::{BinCommand, Logs, Runtime};
use cli::Cli;
use log::{debug, LevelFilter};

fn main() -> Result<()> {
    let matches = Cli::run();

    Logs::init(
        if matches.is_present("debug") {
            LevelFilter::Debug
        } else {
            LevelFilter::Info
        },
        matches.is_present("verbose"),
    )?;

    debug!("CLI returned matches: {:#?}", matches);

    let path = match matches.value_of("file") {
        Some(f) => f,
        _ => "arpx.yaml",
    };
    let jobs = match matches.values_of("job") {
        Some(jobs) => jobs.map(std::string::ToString::to_string).collect(),
        None => Vec::new(),
    };

    debug!("Profile path from CLI matches: {}", path);
    debug!("Jobs from CLI matches: {:?}", jobs);
    debug!("Program start");

    let mut runtime =
        Runtime::from_profile(path, &jobs).context(format!("Error loading profile at {}", path))?;

    if let Some(("bin", sub_matches)) = matches.subcommand() {
        let bin = sub_matches.value_of("BIN");
        let args = match sub_matches.values_of("args") {
            Some(a) => a.map(std::string::ToString::to_string).collect(),
            None => Vec::new(),
        };

        if let Some(cmd) = bin {
            runtime = runtime.bin_command(BinCommand::new(cmd.into(), args));
        }
    }

    runtime.run()
}