talead 0.1.0

The talea ledger daemon: init (migrate, generate token, seed, write .env) and serve
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

use std::path::Path;

use clap::Parser;

use talead::cli::{Cli, Command};
use talead::init::{EnvOutcome, InitOpts, run_init};

#[tokio::main]
async fn main() -> std::process::ExitCode {
    match run().await {
        Ok(()) => std::process::ExitCode::SUCCESS,
        Err(e) => {
            eprintln!("error: {e}");
            std::process::ExitCode::FAILURE
        }
    }
}

async fn run() -> Result<(), Box<dyn std::error::Error>> {
    let cli = Cli::parse();
    match cli.command {
        Command::Init {
            db_url,
            seed,
            env_out,
            force,
        } => {
            let opts = InitOpts {
                db_url,
                seed,
                env_out,
                force,
            };
            let report = run_init(&opts).await?;
            match &report.seed {
                Some(s) => println!(
                    "seed: {} assets created, {} already present, {} accounts ensured",
                    s.assets_created, s.assets_existing, s.accounts_ensured
                ),
                None => println!("seed: no seed file found, skipped"),
            }
            match report.env {
                EnvOutcome::Written => println!("wrote {}", opts.env_out.display()),
                EnvOutcome::KeptExisting => println!(
                    "{} exists; left untouched (re-run with --force to overwrite)",
                    opts.env_out.display()
                ),
            }
            println!("ready. next: talead serve");
            Ok(())
        }
        Command::Serve => {
            tracing_subscriber::fmt()
                .with_env_filter(
                    tracing_subscriber::EnvFilter::try_from_default_env()
                        .unwrap_or_else(|_| "info".into()),
                )
                .init();
            let env_path = Path::new(".env");
            let config = talead::serve::load_config(env_path.exists().then_some(env_path), |k| {
                std::env::var(k).ok()
            })?;
            talea_server::run::run(config).await
        }
    }
}