arcbox-cli 0.6.9

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

//! Boot asset cache commands.

use clap::{Args, Subcommand};

use super::OutputFormat;

mod cache;
mod status;

/// Boot asset management commands.
#[derive(Subcommand)]
pub enum BootCommands {
    /// Download boot assets in advance
    Prefetch(PrefetchArgs),
    /// Show boot asset status
    Status(StatusArgs),
    /// Clear cached boot assets
    Clear,
    /// List cached versions
    List,
}

/// Arguments for prefetch command.
#[derive(Args)]
pub struct PrefetchArgs {
    /// Force re-download even if cached
    #[arg(long, short)]
    pub force: bool,
    /// Asset version to download (default: current version)
    #[arg(long = "asset-version")]
    pub asset_version: Option<String>,
}

/// Arguments for status command.
#[derive(Args)]
pub struct StatusArgs {
    /// Skip network request for latest version check
    #[arg(long)]
    pub offline: bool,
}

/// Execute boot commands.
pub async fn execute(command: BootCommands, format: OutputFormat) -> anyhow::Result<()> {
    let config = arcbox_core::Config::load()?;
    let boot_config = config.boot_asset_config();
    let cache_dir = boot_config.cache_dir.clone();

    match command {
        BootCommands::Prefetch(args) => {
            cache::prefetch(&config.data_dir, boot_config, args, format).await
        }
        BootCommands::Status(args) => {
            status::status(&config.data_dir, boot_config, args, format).await
        }
        BootCommands::Clear => cache::clear(cache_dir, format).await,
        BootCommands::List => cache::list(cache_dir, format).await,
    }
}

#[cfg(test)]
mod tests {
    use arcbox_constants::paths::ArcboxProfile;
    use arcbox_core::boot_assets::BootAssetProvider;

    #[tokio::test]
    async fn development_profile_accepts_a_local_boot_manifest() {
        let directory = tempfile::tempdir().unwrap();
        let mut config = arcbox_core::Config::for_profile(ArcboxProfile::Development);
        config.data_dir = directory.path().to_owned();
        let development = config.boot_asset_config();
        std::fs::create_dir_all(development.version_cache_dir()).unwrap();
        std::fs::write(
            development.version_cache_dir().join("manifest.json"),
            serde_json::to_vec(&serde_json::json!({
                "schema_version": 0,
                "asset_version": development.version.clone(),
                "built_at": "now",
                "targets": {},
                "binaries": []
            }))
            .unwrap(),
        )
        .unwrap();

        BootAssetProvider::with_config(development)
            .unwrap()
            .read_cached_manifest_required()
            .await
            .unwrap();

        config.profile = ArcboxProfile::Production;
        let error = BootAssetProvider::with_config(config.boot_asset_config())
            .unwrap()
            .read_cached_manifest_required()
            .await
            .unwrap_err();
        assert!(error.to_string().contains("manifest SHA256 mismatch"));
    }
}