cleanlib-cli 0.1.0

Terminal interface to CleanLibrary — query dependency verdicts and scan package manifests for ALLOW / DENY / WARN signals from the terminal or CI pipelines.
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

//! `cleanlib fetch` (cycle-7 Cli2). Migrates `cmd_fetch` from `main.rs`.

use std::path::PathBuf;

use anyhow::Result;
use cleanlib_client::{config, transport};
use tokio::io::AsyncWriteExt;

pub async fn run(
    ecosystem: String,
    package: String,
    version: String,
    output: Option<PathBuf>,
) -> Result<()> {
    let path = config::default_path();
    let cfg = config::load_with_env_overrides(path.as_deref())?;
    let client = transport::Client::from_config(&cfg)?;

    match output {
        Some(p) => {
            if let Some(parent) = p.parent() {
                if !parent.as_os_str().is_empty() {
                    std::fs::create_dir_all(parent)?;
                }
            }
            let file = tokio::fs::File::create(&p).await?;
            let mut writer = tokio::io::BufWriter::new(file);
            let total = client
                .fetch_artifact_stream(&ecosystem, &package, &version, &mut writer)
                .await?;
            writer.flush().await?;
            eprintln!("wrote {} ({} bytes)", p.display(), total);
        }
        None => {
            let stdout = tokio::io::stdout();
            let mut writer = tokio::io::BufWriter::new(stdout);
            client
                .fetch_artifact_stream(&ecosystem, &package, &version, &mut writer)
                .await?;
            writer.flush().await?;
        }
    }

    Ok(())
}