flippy 0.4.3

Automates upgrades and pulls remote databases, files, and firmware for the Flipper Zero
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

use anyhow::{Result, bail};
use cliclack::confirm;
use gix::open;
use tokio::fs;
use tracing::instrument;

use crate::{git, progress::progress, types::flip::Flip};

#[instrument]
pub async fn fetch(flip: Flip) -> Result<()> {
    let path = flip.source_path;

    let (progress, handle) = progress();

    for (i, (name, repo)) in flip.repositories.iter().enumerate() {
        let url = gix::url::parse(repo.url.as_str().into())?;
        let path = path.join("store").join(repo.uuid.to_string());
        let exists = fs::try_exists(&path).await?;

        let sub_progress_str = format!(
            "{}: {url} -> store/{}",
            if exists { "fetching" } else { "cloning" },
            repo.uuid
        );

        let mut sub_progress = progress.add_child_with_id(name, (i as u32).to_le_bytes());

        sub_progress.info(sub_progress_str);

        if exists {
            let repo = open(path)?;

            git::fetch::fetch(repo, None, &mut sub_progress)?;
        } else {
            git::clone::clone(url.to_string(), Some(path), &mut sub_progress)?;
        }
    }

    handle.shutdown_and_wait();
    Ok(())
}

#[instrument]
pub async fn clean(flip: Flip) -> Result<()> {
    let path = flip.source_path;

    if !confirm("Delete all store items? This includes repos, firmware, caches, ...etc.")
        .interact()?
    {
        bail!("Aborted");
    }

    tokio::fs::remove_dir_all(path.join("store")).await?;
    tokio::fs::create_dir(path.join("store")).await?;

    Ok(())
}