108 lines
3.5 KiB
Rust
108 lines
3.5 KiB
Rust
const DB_MAGIC: &str = "bdk_wallet_electrum_example";
|
|
const SEND_AMOUNT: u64 = 5000;
|
|
const STOP_GAP: usize = 50;
|
|
const BATCH_SIZE: usize = 5;
|
|
|
|
use std::io::Write;
|
|
use std::str::FromStr;
|
|
|
|
use bdk::bitcoin::Address;
|
|
use bdk::wallet::Update;
|
|
use bdk::SignOptions;
|
|
use bdk::{bitcoin::Network, Wallet};
|
|
use bdk_electrum::{
|
|
electrum_client::{self, ElectrumApi},
|
|
ElectrumExt, ElectrumUpdate,
|
|
};
|
|
use bdk_file_store::Store;
|
|
|
|
fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|
let db_path = std::env::temp_dir().join("bdk-electrum-example");
|
|
let db = Store::<bdk::wallet::ChangeSet>::open_or_create_new(DB_MAGIC.as_bytes(), db_path)?;
|
|
let external_descriptor = "wpkh(tprv8ZgxMBicQKsPdy6LMhUtFHAgpocR8GC6QmwMSFpZs7h6Eziw3SpThFfczTDh5rW2krkqffa11UpX3XkeTTB2FvzZKWXqPY54Y6Rq4AQ5R8L/84'/1'/0'/0/*)";
|
|
let internal_descriptor = "wpkh(tprv8ZgxMBicQKsPdy6LMhUtFHAgpocR8GC6QmwMSFpZs7h6Eziw3SpThFfczTDh5rW2krkqffa11UpX3XkeTTB2FvzZKWXqPY54Y6Rq4AQ5R8L/84'/1'/0'/1/*)";
|
|
|
|
let mut wallet = Wallet::new_or_load(
|
|
external_descriptor,
|
|
Some(internal_descriptor),
|
|
db,
|
|
Network::Testnet,
|
|
)?;
|
|
|
|
let address = wallet.get_address(bdk::wallet::AddressIndex::New);
|
|
println!("Generated Address: {}", address);
|
|
|
|
let balance = wallet.get_balance();
|
|
println!("Wallet balance before syncing: {} sats", balance.total());
|
|
|
|
print!("Syncing...");
|
|
let client = electrum_client::Client::new("ssl://electrum.blockstream.info:60002")?;
|
|
|
|
let prev_tip = wallet.latest_checkpoint();
|
|
let keychain_spks = wallet
|
|
.spks_of_all_keychains()
|
|
.into_iter()
|
|
.map(|(k, k_spks)| {
|
|
let mut once = Some(());
|
|
let mut stdout = std::io::stdout();
|
|
let k_spks = k_spks
|
|
.inspect(move |(spk_i, _)| match once.take() {
|
|
Some(_) => print!("\nScanning keychain [{:?}]", k),
|
|
None => print!(" {:<3}", spk_i),
|
|
})
|
|
.inspect(move |_| stdout.flush().expect("must flush"));
|
|
(k, k_spks)
|
|
})
|
|
.collect();
|
|
|
|
let (
|
|
ElectrumUpdate {
|
|
chain_update,
|
|
relevant_txids,
|
|
},
|
|
keychain_update,
|
|
) = client.scan(prev_tip, keychain_spks, None, None, STOP_GAP, BATCH_SIZE)?;
|
|
|
|
println!();
|
|
|
|
let missing = relevant_txids.missing_full_txs(wallet.as_ref());
|
|
let graph_update = relevant_txids.into_confirmation_time_tx_graph(&client, None, missing)?;
|
|
|
|
let wallet_update = Update {
|
|
last_active_indices: keychain_update,
|
|
graph: graph_update,
|
|
chain: Some(chain_update),
|
|
};
|
|
wallet.apply_update(wallet_update)?;
|
|
wallet.commit()?;
|
|
|
|
let balance = wallet.get_balance();
|
|
println!("Wallet balance after syncing: {} sats", balance.total());
|
|
|
|
if balance.total() < SEND_AMOUNT {
|
|
println!(
|
|
"Please send at least {} sats to the receiving address",
|
|
SEND_AMOUNT
|
|
);
|
|
std::process::exit(0);
|
|
}
|
|
|
|
let faucet_address = Address::from_str("mkHS9ne12qx9pS9VojpwU5xtRd4T7X7ZUt")?
|
|
.require_network(Network::Testnet)?;
|
|
|
|
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(())
|
|
}
|