frost/bdk
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update the wallet_electrum example

Browse Source
This commit is contained in:
志宇 2023-05-18 10:14:47 +08:00
parent 78a7920ba3
commit 2952341e52
No known key found for this signature in database
GPG Key ID: F6345C9837C2BDE8
1 changed files with 76 additions and 88 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

166
example-crates/wallet_electrum/src/main.rs
View File

@ -1,105 +1,93 @@
// use std::{io::Write, str::FromStr}; const DB_MAGIC: &str = "bdk_wallet_electrum_example";
const SEND_AMOUNT: u64 = 5000;
const STOP_GAP: usize = 50;
const BATCH_SIZE: usize = 5;
// use bdk::{ use std::io::Write;
// bitcoin::{Address, Network}, use std::str::FromStr;
// SignOptions, Wallet,
// };
// use bdk_electrum::{
// electrum_client::{self, ElectrumApi},
// ElectrumExt,
// };
// use bdk_file_store::KeychainStore;
// const SEND_AMOUNT: u64 = 5000; use bdk::bitcoin::Address;
// const STOP_GAP: usize = 50; use bdk::SignOptions;
// const BATCH_SIZE: usize = 5; use bdk::{bitcoin::Network, Wallet};
use bdk_electrum::electrum_client::{self, ElectrumApi};
use bdk_electrum::v2::ElectrumExt;
use bdk_file_store::Store;
fn main() -> Result<(), Box<dyn std::error::Error>> { fn main() -> Result<(), Box<dyn std::error::Error>> {
todo!("update this example!"); let db_path = std::env::temp_dir().join("bdk-electrum-example");
// println!("Hello, world!"); let db = Store::<bdk::wallet::ChangeSet>::new_from_path(DB_MAGIC.as_bytes(), db_path)?;
let external_descriptor = "wpkh(tprv8ZgxMBicQKsPdy6LMhUtFHAgpocR8GC6QmwMSFpZs7h6Eziw3SpThFfczTDh5rW2krkqffa11UpX3XkeTTB2FvzZKWXqPY54Y6Rq4AQ5R8L/84'/0'/0'/0/*)";
let internal_descriptor = "wpkh(tprv8ZgxMBicQKsPdy6LMhUtFHAgpocR8GC6QmwMSFpZs7h6Eziw3SpThFfczTDh5rW2krkqffa11UpX3XkeTTB2FvzZKWXqPY54Y6Rq4AQ5R8L/84'/0'/0'/1/*)";
// let db_path = std::env::temp_dir().join("bdk-electrum-example"); let mut wallet = Wallet::new(
// let db = KeychainStore::new_from_path(db_path)?; external_descriptor,
// let external_descriptor = "wpkh(tprv8ZgxMBicQKsPdy6LMhUtFHAgpocR8GC6QmwMSFpZs7h6Eziw3SpThFfczTDh5rW2krkqffa11UpX3XkeTTB2FvzZKWXqPY54Y6Rq4AQ5R8L/84'/0'/0'/0/*)"; Some(internal_descriptor),
// let internal_descriptor = "wpkh(tprv8ZgxMBicQKsPdy6LMhUtFHAgpocR8GC6QmwMSFpZs7h6Eziw3SpThFfczTDh5rW2krkqffa11UpX3XkeTTB2FvzZKWXqPY54Y6Rq4AQ5R8L/84'/0'/0'/1/*)"; db,
Network::Testnet,
)?;
// let mut wallet = Wallet::new( let address = wallet.get_address(bdk::wallet::AddressIndex::New);
// external_descriptor, println!("Generated Address: {}", address);
// Some(internal_descriptor),
// db,
// Network::Testnet,
// )?;
// let address = wallet.get_address(bdk::wallet::AddressIndex::New); let balance = wallet.get_balance();
// println!("Generated Address: {}", address); println!("Wallet balance before syncing: {} sats", balance.total());
// let balance = wallet.get_balance(); print!("Syncing...");
// println!("Wallet balance before syncing: {} sats", balance.total()); let client = electrum_client::Client::new("ssl://electrum.blockstream.info:60002")?;
// print!("Syncing..."); let local_chain = wallet.checkpoints();
// // Scanning the chain... let keychain_spks = wallet
// let electrum_url = "ssl://electrum.blockstream.info:60002"; .spks_of_all_keychains()
// let client = electrum_client::Client::new(electrum_url)?; .into_iter()
// let local_chain = wallet.checkpoints(); .map(|(k, k_spks)| {
// let spks = wallet let mut once = Some(());
// .spks_of_all_keychains() let mut stdout = std::io::stdout();
// .into_iter() let k_spks = k_spks
// .map(|(k, spks)| { .inspect(move |(spk_i, _)| match once.take() {
// let mut first = true; Some(_) => print!("\nScanning keychain [{:?}]", k),
// ( None => print!(" {:<3}", spk_i),
// k, })
// spks.inspect(move |(spk_i, _)| { .inspect(move |_| stdout.flush().expect("must flush"));
// if first { (k, k_spks)
// first = false; })
// print!("\nScanning keychain [{:?}]:", k); .collect();
// }
// print!(" {}", spk_i);
// let _ = std::io::stdout().flush();
// }),
// )
// })
// .collect();
// let electrum_update = client
// .scan(
// local_chain,
// spks,
// core::iter::empty(),
// core::iter::empty(),
// STOP_GAP,
// BATCH_SIZE,
// )?
// .into_confirmation_time_update(&client)?;
// println!();
// let new_txs = client.batch_transaction_get(electrum_update.missing_full_txs(&wallet))?;
// let update = electrum_update.into_keychain_scan(new_txs, &wallet)?;
// wallet.apply_update(update)?;
// wallet.commit()?;
// let balance = wallet.get_balance(); let electrum_update =
// println!("Wallet balance after syncing: {} sats", balance.total()); client.scan(local_chain, keychain_spks, None, None, STOP_GAP, BATCH_SIZE)?;
// if balance.total() < SEND_AMOUNT { println!();
// println!(
// "Please send at least {} sats to the receiving address",
// SEND_AMOUNT
// );
// std::process::exit(0);
// }
// let faucet_address = Address::from_str("mkHS9ne12qx9pS9VojpwU5xtRd4T7X7ZUt")?; let missing = electrum_update.missing_full_txs(wallet.as_ref());
let update = electrum_update.finalize_as_confirmation_time(&client, None, missing)?;
// let mut tx_builder = wallet.build_tx(); wallet.apply_update(update)?;
// tx_builder wallet.commit()?;
// .add_recipient(faucet_address.script_pubkey(), SEND_AMOUNT)
// .enable_rbf();
// let (mut psbt, _) = tx_builder.finish()?; let balance = wallet.get_balance();
// let finalized = wallet.sign(&mut psbt, SignOptions::default())?; println!("Wallet balance after syncing: {} sats", balance.total());
// assert!(finalized);
// let tx = psbt.extract_tx(); if balance.total() < SEND_AMOUNT {
// client.transaction_broadcast(&tx)?; println!(
// println!("Tx broadcasted! Txid: {}", tx.txid()); "Please send at least {} sats to the receiving address",
SEND_AMOUNT
// Ok(()) );
std::process::exit(0);
}
let faucet_address = Address::from_str("mkHS9ne12qx9pS9VojpwU5xtRd4T7X7ZUt")?;
let mut tx_builder = wallet.build_tx();
tx_builder
.add_recipient(faucet_address.script_pubkey(), SEND_AMOUNT)
.enable_rbf();
let (mut psbt, _) = tx_builder.finish()?;
let finalized = wallet.sign(&mut psbt, SignOptions::default())?;
assert!(finalized);
let tx = psbt.extract_tx();
client.transaction_broadcast(&tx)?;
println!("Tx broadcasted! Txid: {}", tx.txid());
Ok(())
} }