apicurio-cli 0.1.2

A powerful CLI tool for managing schema artifacts from Apicurio Registry with lockfile-based dependency 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
43
44

use anyhow::Result;
use std::{collections::HashMap, fs, path::PathBuf};

use crate::{
    config::{load_global_config, load_repo_config},
    constants::{APICURIO_CONFIG, APICURIO_LOCK},
    lockfile::LockFile,
    registry::RegistryClient,
};

pub async fn run() -> Result<()> {
    // 1) load configs
    let repo_cfg = load_repo_config(&PathBuf::from(APICURIO_CONFIG))?;
    let global_cfg = load_global_config()?;
    let regs = repo_cfg.merge_registries(global_cfg)?;
    // build clients
    let mut clients = HashMap::new();
    for r in &regs {
        clients.insert(r.name.clone(), RegistryClient::new(r)?);
    }

    crate::commands::lock::run().await?;
    let lock_path = PathBuf::from(APICURIO_LOCK);
    let lock_file = LockFile::load(&lock_path)?;
    for dependency in lock_file.locked_dependencies {
        let client = &clients[&dependency.registry];
        // download by exact URL, but we know API path from download_url
        let data = client
            .client
            .get(&dependency.download_url)
            .send()
            .await?
            .bytes()
            .await?;
        let file_path = PathBuf::from(&dependency.output_path);
        if let Some(parent) = file_path.parent() {
            fs::create_dir_all(parent)?;
        }
        fs::write(&file_path, &data)?;
    }

    println!("✅ pull complete");
    Ok(())
}