arig 0.2.3

Polyglot service orchestrator
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

mod config;
mod dag;
mod supervisor;

use clap::{Parser, Subcommand};
use std::path::PathBuf;

#[derive(Parser)]
#[command(name = "arig", version, about = "Polyglot service orchestrator")]
struct Cli {
    /// Change to DIR before doing anything else (like git -C).
    #[arg(short = 'C', long = "directory", value_name = "DIR")]
    directory: Option<PathBuf>,

    /// Path to config file
    #[arg(short, long, default_value = "arig.yaml")]
    file: PathBuf,

    #[command(subcommand)]
    command: Commands,
}

#[derive(Subcommand)]
enum Commands {
    /// Build and start all services
    Up,
    /// Stop all services
    Down,
    /// Print the JSON schema for arig.yaml to stdout
    Schema,
}

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let cli = Cli::parse();

    if let Some(dir) = &cli.directory {
        std::env::set_current_dir(dir)
            .map_err(|e| anyhow::anyhow!("failed to chdir to {}: {e}", dir.display()))?;
    }

    if let Commands::Schema = cli.command {
        let schema = schemars::schema_for!(config::ArigConfig);
        println!("{}", serde_json::to_string_pretty(&schema)?);
        return Ok(());
    }

    let config = config::ArigConfig::load(&cli.file)?;

    match cli.command {
        Commands::Up => supervisor::up(config).await?,
        Commands::Down => {
            eprintln!("down: not yet implemented");
        }
        Commands::Schema => unreachable!(),
    }

    Ok(())
}