zinc-wallet-cli 0.4.0

Agent-first Bitcoin + Ordinals CLI wallet with account-based taproot ordinals + native segwit payment addresses (optional human mode)
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

use crate::cli::{Cli, SyncArgs, SyncTarget};
use crate::error::AppError;
use crate::network_retry::with_network_retry;
use crate::output::CommandOutput;
use crate::wallet_service::map_wallet_error;
use crate::{load_wallet_session, persist_wallet_session};
use indicatif::{ProgressBar, ProgressStyle};

pub async fn run(cli: &Cli, args: &SyncArgs) -> Result<CommandOutput, AppError> {
    match &args.target {
        SyncTarget::Chain => {
            let mut session = load_wallet_session(cli)?;
            let spinner = make_spinner(cli, "Syncing wallet...");
            let esplora_url = session.profile.esplora_url.clone();
            let events = with_network_retry(cli, "sync chain", &mut session.wallet, |wallet| {
                let url = esplora_url.clone();
                Box::pin(async move { wallet.sync(&url).await.map_err(map_wallet_error) })
            })
            .await?;
            persist_wallet_session(&mut session)?;
            if let Some(pb) = spinner {
                pb.finish_and_clear();
            }
            Ok(CommandOutput::SyncChain { events })
        }
        SyncTarget::Ordinals => {
            let mut session = load_wallet_session(cli)?;
            let spinner = make_spinner(cli, "Syncing ordinals...");
            let ord_url = session.profile.ord_url.clone();
            let count = with_network_retry(cli, "sync ordinals", &mut session.wallet, |wallet| {
                let url = ord_url.clone();
                Box::pin(async move { wallet.sync_ordinals(&url).await.map_err(map_wallet_error) })
            })
            .await?;
            persist_wallet_session(&mut session)?;
            if let Some(pb) = spinner {
                pb.finish_and_clear();
            }
            Ok(CommandOutput::SyncOrdinals {
                inscriptions: count,
            })
        }
    }
}

fn make_spinner(cli: &Cli, message: &str) -> Option<ProgressBar> {
    if cli.agent {
        return None;
    }

    let pb = ProgressBar::new_spinner();
    pb.set_style(
        ProgressStyle::default_spinner()
            .template("{spinner:.green} {msg}")
            .unwrap(),
    );
    pb.set_message(message.to_string());
    pb.enable_steady_tick(std::time::Duration::from_millis(100));
    Some(pb)
}