envoy-cli 0.1.3-hotfix

A Git-like CLI for managing encrypted environment files
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

use console::style;
use indicatif::{ProgressBar, ProgressStyle};
use std::path::Path;

use crate::utils::{
    config::load_token,
    manifest::{load_manifest, save_manifest, write_applied},
    project_config::{get_remote_url, load_project_config},
    storage::{upload_blob, upload_manifest},
};

pub async fn push(passphrase: &str, remote: Option<&str>) -> anyhow::Result<()> {
    let token = load_token()?;
    let project = load_project_config()?;
    let server = get_remote_url(&project, remote)?;

    let manifest = load_manifest(passphrase)?;

    let client = reqwest::Client::new();

    let total = manifest.files.len();
    println!("\n{} Pushing {} files...", style("→").cyan().bold(), total);

    let pb = ProgressBar::new(total as u64);
    pb.set_style(
        ProgressStyle::default_bar()
            .template("{spinner:.green} [{bar:40.cyan/blue}] {pos}/{len} {msg}")
            .unwrap()
            .progress_chars("█▓▒░"),
    );

    let mut uploaded = 0;

    for hash in manifest.files.values() {
        let blob_path = Path::new(".envoy/cache").join(format!("{}.blob", hash));

        if !blob_path.exists() {
            anyhow::bail!("Missing blob {}", hash);
        }

        pb.set_message(format!("Uploading {}...", &hash[..8]));
        upload_blob(
            &client,
            &server,
            &token,
            &project.project_id,
            hash,
            &blob_path,
        )
        .await?;

        uploaded += 1;
        pb.inc(1);
    }

    pb.finish_and_clear();

    let manifest_hash = save_manifest(&manifest, passphrase)?;

    let manifest_blob_path = Path::new(".envoy/cache").join(format!("{}.blob", manifest_hash));

    upload_manifest(
        &client,
        &server,
        &token,
        &project.project_id,
        &manifest_hash,
        &manifest_blob_path,
    )
    .await?;

    write_applied(&manifest_hash)?;

    println!(
        "{} {} {}",
        style("✓").green().bold(),
        style("Uploaded").green(),
        style(format!("{} blobs", uploaded)).cyan()
    );
    println!(
        "{} {}",
        style("📦").cyan(),
        style(format!("Manifest: {}", &manifest_hash[..12])).dim()
    );

    Ok(())
}