arcbox-cli 0.4.10

Command-line interface for ArcBox
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

//! ArcBox CLI - High-performance container and VM runtime.

use anyhow::Result;
use clap::Parser;
use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};

mod commands;

use commands::{Cli, Commands};

fn main() -> Result<()> {
    // Sentry must be initialized before the tokio runtime so that spawned
    // threads inherit the Hub from the main thread.
    // When SENTRY_DSN is unset, this is a no-op with zero overhead.
    let _sentry_guard = sentry::init(sentry::ClientOptions {
        dsn: std::env::var("ARCBOX_CLI_SENTRY_DSN")
            .or_else(|_| std::env::var("SENTRY_DSN"))
            .ok()
            .and_then(|s| s.parse().ok()),
        release: Some(env!("CARGO_PKG_VERSION").into()),
        environment: std::env::var("ARCBOX_CLI_SENTRY_ENVIRONMENT")
            .or_else(|_| std::env::var("SENTRY_ENVIRONMENT"))
            .ok()
            .map(Into::into),
        sample_rate: 1.0,
        attach_stacktrace: true,
        ..Default::default()
    });

    let cli = Cli::parse();

    // Set ARCBOX_SOCKET env var if --socket was provided.
    // This makes it available to gRPC socket resolution in machine commands.
    // SAFETY: This is called at the start of main(), before any threads are spawned,
    // and we're the only ones modifying this environment variable.
    if let Some(ref socket) = cli.socket {
        unsafe {
            std::env::set_var("ARCBOX_SOCKET", socket.as_os_str());
        }
    }

    // Initialize logging based on debug flag
    let filter = if cli.debug {
        "arcbox=debug,arcbox_cli=debug"
    } else {
        "arcbox=info"
    };

    tracing_subscriber::registry()
        .with(
            tracing_subscriber::EnvFilter::try_from_default_env().unwrap_or_else(|_| filter.into()),
        )
        .with(tracing_subscriber::fmt::layer().with_target(false))
        .init();

    tokio::runtime::Builder::new_multi_thread()
        .enable_all()
        .build()
        .expect("Failed to build tokio runtime")
        .block_on(async {
            match cli.command {
                Commands::Machine(cmd) => commands::machine::execute(cmd).await,
                Commands::Migrate(cmd) => commands::migrate::execute(cmd).await,
                Commands::Sandbox(cmd) => commands::sandbox::execute(cmd).await,
                Commands::Docker(cmd) => commands::docker::execute(cmd, cli.format).await,
                Commands::Kubernetes(cmd) => commands::kubernetes::execute(cmd).await,
                Commands::Boot(cmd) => commands::boot::execute(cmd, cli.format).await,
                Commands::Disk(cmd) => commands::disk::execute(cmd).await,
                #[cfg(target_os = "macos")]
                Commands::Dns(cmd) => commands::dns::execute(cmd).await,
                Commands::Daemon(args) => commands::daemon::execute(args).await,
                Commands::Logs(args) => commands::logs::execute(args).await,
                Commands::Setup(cmd) => commands::setup::execute(cmd, cli.format).await,
                Commands::Doctor => commands::doctor::execute().await,
                #[cfg(target_os = "macos")]
                Commands::Install(args) => commands::install::execute(args).await,
                #[cfg(target_os = "macos")]
                Commands::Uninstall(args) => commands::uninstall::execute(args).await,
                #[cfg(target_os = "macos")]
                Commands::Internal(cmd) => commands::internal::execute(cmd).await,
                Commands::Info => execute_info().await,
                Commands::Version => commands::version::execute().await,
            }
        })
}

/// Display system-wide information.
async fn execute_info() -> Result<()> {
    println!("ArcBox Version: {}", env!("CARGO_PKG_VERSION"));
    println!("OS: {}", std::env::consts::OS);
    println!("Arch: {}", std::env::consts::ARCH);
    println!(
        "CPUs: {}",
        std::thread::available_parallelism().map_or(1, |n| n.get())
    );

    match commands::machine::machine_count().await {
        Ok(machine_count) => println!("Machines: {}", machine_count),
        Err(_) => println!("Machines: (daemon not running)"),
    }

    Ok(())
}