From 31f8b9531cf28797bfbc882f73d8660b43cebcbe Mon Sep 17 00:00:00 2001 From: valued mammal Date: Tue, 9 Jul 2024 17:27:43 -0400 Subject: [PATCH] example: small fixes, improvements to example-crates --- example-crates/wallet_esplora_async/src/main.rs | 2 +- example-crates/wallet_rpc/src/main.rs | 6 ++++++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/example-crates/wallet_esplora_async/src/main.rs b/example-crates/wallet_esplora_async/src/main.rs index 6e73fe2529..3f232ca022 100644 --- a/example-crates/wallet_esplora_async/src/main.rs +++ b/example-crates/wallet_esplora_async/src/main.rs @@ -44,7 +44,7 @@ async fn main() -> Result<(), anyhow::Error> { let mut stdout = std::io::stdout(); move |spk_i, _| { match once.take() { - Some(_) => print!("\nScanning keychain [{:?}]", kind), + Some(_) => print!("\nScanning keychain [{:?}] {:<3}", kind, spk_i), None => print!(" {:<3}", spk_i), }; stdout.flush().expect("must flush"); diff --git a/example-crates/wallet_rpc/src/main.rs b/example-crates/wallet_rpc/src/main.rs index 39f245ac57..c4e66ebedd 100644 --- a/example-crates/wallet_rpc/src/main.rs +++ b/example-crates/wallet_rpc/src/main.rs @@ -143,6 +143,9 @@ fn main() -> anyhow::Result<()> { let connected_to = block_emission.connected_to(); let start_apply_block = Instant::now(); wallet.apply_block_connected_to(&block_emission.block, height, connected_to)?; + if let Some(changeset) = wallet.take_staged() { + db.write(&changeset)?; + } let elapsed = start_apply_block.elapsed().as_secs_f32(); println!( "Applied block {} at height {} in {}s", @@ -152,6 +155,9 @@ fn main() -> anyhow::Result<()> { Emission::Mempool(mempool_emission) => { let start_apply_mempool = Instant::now(); wallet.apply_unconfirmed_txs(mempool_emission.iter().map(|(tx, time)| (tx, *time))); + if let Some(changeset) = wallet.take_staged() { + db.write(&changeset)?; + } println!( "Applied unconfirmed transactions in {}s", start_apply_mempool.elapsed().as_secs_f32()