postmodern-cli 0.1.1

CLI for postmodern job queue management.
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

//! CLI for postmodern job queue management.

mod cli;
mod cmd;
mod display;
mod path;
mod payload;

use anyhow::{Context, Result};
use clap::Parser;
use postmodern::{config, Queue};

use crate::cli::{Cli, Command};

/// Runs the CLI.
async fn run(cli: Cli) -> Result<()> {
    let database_url = config::resolve_database_url(cli.db)?;

    // Handle pg commands (don't need a Queue connection).
    if let Command::Pg { command } = cli.command {
        return cmd::pg::run(&database_url, command);
    }

    let queue = Queue::connect(&database_url)
        .await
        .context("failed to connect")?;

    match cli.command {
        Command::Queue { command } => cmd::queue::run(&queue, command).await?,
        Command::Job { command } => cmd::job::run(&queue, command).await?,
        Command::Db { command } => cmd::db::run(&queue, command).await?,
        Command::Pg { .. } => unreachable!(),
    }

    Ok(())
}

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