|
| 1 | +#![allow(unused)] |
1 | 2 | use std::{collections::BTreeSet, io::Write};
|
2 | 3 |
|
3 | 4 | use anyhow::Ok;
|
4 | 5 | use bdk_esplora::{esplora_client, EsploraAsyncExt};
|
5 | 6 | use bdk_wallet::{
|
6 | 7 | bitcoin::{Amount, Network},
|
| 8 | + chain::{DescriptorExt, DescriptorId}, |
7 | 9 | rusqlite::Connection,
|
8 |
| - KeychainKind, SignOptions, Wallet, |
| 10 | + ChangeSet, CreateParams, Keychain, Keyring, SignOptions, Wallet, |
9 | 11 | };
|
10 | 12 |
|
11 | 13 | const SEND_AMOUNT: Amount = Amount::from_sat(5000);
|
12 | 14 | const STOP_GAP: usize = 5;
|
13 | 15 | const PARALLEL_REQUESTS: usize = 5;
|
14 | 16 |
|
15 |
| -const DB_PATH: &str = "bdk-example-esplora-async.sqlite"; |
| 17 | +// const DB_PATH: &str = "bdk-example-esplora-async.sqlite"; |
| 18 | +const DB_PATH: &str = ".bdk_example_wallet_esplora_async.sqlite"; |
16 | 19 | const NETWORK: Network = Network::Signet;
|
17 |
| -const EXTERNAL_DESC: &str = "wpkh(tprv8ZgxMBicQKsPdy6LMhUtFHAgpocR8GC6QmwMSFpZs7h6Eziw3SpThFfczTDh5rW2krkqffa11UpX3XkeTTB2FvzZKWXqPY54Y6Rq4AQ5R8L/84'/1'/0'/0/*)"; |
18 |
| -const INTERNAL_DESC: &str = "wpkh(tprv8ZgxMBicQKsPdy6LMhUtFHAgpocR8GC6QmwMSFpZs7h6Eziw3SpThFfczTDh5rW2krkqffa11UpX3XkeTTB2FvzZKWXqPY54Y6Rq4AQ5R8L/84'/1'/0'/1/*)"; |
| 20 | +// const EXTERNAL_DESC: &str = "wpkh(tprv8ZgxMBicQKsPdy6LMhUtFHAgpocR8GC6QmwMSFpZs7h6Eziw3SpThFfczTDh5rW2krkqffa11UpX3XkeTTB2FvzZKWXqPY54Y6Rq4AQ5R8L/84'/1'/0'/0/*)"; |
| 21 | +// const INTERNAL_DESC: &str = "wpkh(tprv8ZgxMBicQKsPdy6LMhUtFHAgpocR8GC6QmwMSFpZs7h6Eziw3SpThFfczTDh5rW2krkqffa11UpX3XkeTTB2FvzZKWXqPY54Y6Rq4AQ5R8L/84'/1'/0'/1/*)"; |
19 | 22 | const ESPLORA_URL: &str = "http://signet.bitcoindevkit.net";
|
20 | 23 |
|
| 24 | +const MULTIPATH_DESCRIPTOR: &str = "wpkh([e273fe42/84'/1'/0']tpubDCmr3Luq75npLaYmRqqW1rLfSbfpnBXwLwAmUbR333fp95wjCHar3zoc9zSWovZFwrWr53mm3NTVqt6d1Pt6G26uf4etQjc3Pr5Hxe9QEQ2/<0;1>/*)"; |
| 25 | +const PK_DESCRIPTOR: &str = "tr(b511bd5771e47ee27558b1765e87b541668304ec567721c7b880edc0a010da55)"; |
| 26 | +// Desc ID of pk descriptor: "ef8a67b77b83797a1ad56504cc79e8c6990408265f1afdce72990b8a5baf7d3b" |
| 27 | + |
21 | 28 | #[tokio::main]
|
22 | 29 | async fn main() -> Result<(), anyhow::Error> {
|
23 |
| - let mut conn = Connection::open(DB_PATH)?; |
24 |
| - |
25 |
| - let wallet_opt = Wallet::load() |
26 |
| - .descriptor(KeychainKind::External, Some(EXTERNAL_DESC)) |
27 |
| - .descriptor(KeychainKind::Internal, Some(INTERNAL_DESC)) |
28 |
| - .extract_keys() |
29 |
| - .check_network(NETWORK) |
30 |
| - .load_wallet(&mut conn)?; |
31 |
| - let mut wallet = match wallet_opt { |
32 |
| - Some(wallet) => wallet, |
33 |
| - None => Wallet::create(EXTERNAL_DESC, INTERNAL_DESC) |
34 |
| - .network(NETWORK) |
35 |
| - .create_wallet(&mut conn)?, |
36 |
| - }; |
37 |
| - |
38 |
| - let address = wallet.next_unused_address(KeychainKind::External); |
39 |
| - wallet.persist(&mut conn)?; |
40 |
| - println!("Next unused address: ({}) {}", address.index, address); |
41 |
| - |
42 |
| - let balance = wallet.balance(); |
43 |
| - println!("Wallet balance before syncing: {}", balance.total()); |
44 |
| - |
45 |
| - print!("Syncing..."); |
46 |
| - let client = esplora_client::Builder::new(ESPLORA_URL).build_async()?; |
47 |
| - |
48 |
| - let request = wallet.start_full_scan().inspect({ |
49 |
| - let mut stdout = std::io::stdout(); |
50 |
| - let mut once = BTreeSet::<KeychainKind>::new(); |
51 |
| - move |keychain, spk_i, _| { |
52 |
| - if once.insert(keychain) { |
53 |
| - print!("\nScanning keychain [{:?}]", keychain); |
54 |
| - } |
55 |
| - print!(" {:<3}", spk_i); |
56 |
| - stdout.flush().expect("must flush") |
57 |
| - } |
58 |
| - }); |
59 |
| - |
60 |
| - let update = client |
61 |
| - .full_scan(request, STOP_GAP, PARALLEL_REQUESTS) |
62 |
| - .await?; |
63 |
| - |
64 |
| - wallet.apply_update(update)?; |
65 |
| - wallet.persist(&mut conn)?; |
66 |
| - println!(); |
67 |
| - |
68 |
| - let balance = wallet.balance(); |
69 |
| - println!("Wallet balance after syncing: {}", balance.total()); |
70 |
| - |
71 |
| - if balance.total() < SEND_AMOUNT { |
72 |
| - println!( |
73 |
| - "Please send at least {} to the receiving address", |
74 |
| - SEND_AMOUNT |
75 |
| - ); |
76 |
| - std::process::exit(0); |
77 |
| - } |
78 |
| - |
79 |
| - let mut tx_builder = wallet.build_tx(); |
80 |
| - tx_builder.add_recipient(address.script_pubkey(), SEND_AMOUNT); |
81 |
| - |
82 |
| - let mut psbt = tx_builder.finish()?; |
83 |
| - let finalized = wallet.sign(&mut psbt, SignOptions::default())?; |
84 |
| - assert!(finalized); |
85 |
| - |
86 |
| - let tx = psbt.extract_tx()?; |
87 |
| - client.broadcast(&tx).await?; |
88 |
| - println!("Tx broadcasted! Txid: {}", tx.compute_txid()); |
| 30 | + // let mut conn = Connection::open(DB_PATH)?; |
| 31 | + let mut conn = Connection::open_in_memory()?; |
| 32 | + |
| 33 | + // Setup: Initialize Keyring from a list of descriptors |
| 34 | + let mut keyring = Keyring::new(NETWORK); |
| 35 | + let _ = keyring.add_descriptors([MULTIPATH_DESCRIPTOR, PK_DESCRIPTOR])?; |
| 36 | + |
| 37 | + // Test 1: Create wallet with keyring and params |
| 38 | + let mut wallet = Wallet::with_keyring(keyring.clone()) |
| 39 | + .network(NETWORK) |
| 40 | + .create_wallet(&mut conn)?; |
| 41 | + |
| 42 | + assert_eq!(wallet.keychains().count(), 3); |
| 43 | + let desc_id: DescriptorId = |
| 44 | + "ef8a67b77b83797a1ad56504cc79e8c6990408265f1afdce72990b8a5baf7d3b".parse()?; |
| 45 | + let (keychain, index, addr) = wallet.new_address(desc_id).expect("should reveal address"); |
| 46 | + println!("New address: {:?} {}", (keychain, index), addr); |
| 47 | + |
| 48 | + // Test 2: Persist the keyring first and then load wallet from changeset |
| 49 | + // let changeset = keyring.initial_changeset(); |
| 50 | + // let tx = conn.transaction()?; |
| 51 | + // ChangeSet::init_sqlite_tables(&tx)?; |
| 52 | + // changeset.persist_to_sqlite(&tx)?; |
| 53 | + // tx.commit()?; |
| 54 | + |
| 55 | + // let wallet = Wallet::load() |
| 56 | + // .load_wallet(&mut conn)? |
| 57 | + // .expect("should have persisted wallet"); |
| 58 | + |
| 59 | + // assert_eq!(wallet.keychains().count(), 3); |
| 60 | + |
| 61 | + // More example code |
| 62 | + |
| 63 | + // let wallet_opt = Wallet::load() |
| 64 | + // .descriptor(0, Some(EXTERNAL_DESC)) |
| 65 | + // .extract_keys() |
| 66 | + // .check_network(NETWORK) |
| 67 | + // .load_wallet(&mut conn)?; |
| 68 | + // let mut wallet = match wallet_opt { |
| 69 | + // Some(wallet) => wallet, |
| 70 | + // None => Wallet::create(EXTERNAL_DESC, INTERNAL_DESC) |
| 71 | + // .network(NETWORK) |
| 72 | + // .create_wallet(&mut conn)?, |
| 73 | + // }; |
| 74 | + |
| 75 | + // let address = wallet.next_unused_address(Keychain::ZERO); |
| 76 | + // wallet.persist(&mut conn)?; |
| 77 | + // println!("Next unused address: ({}) {}", address.index, address); |
| 78 | + |
| 79 | + // let balance = wallet.balance(); |
| 80 | + // println!("Wallet balance before syncing: {}", balance.total()); |
| 81 | + |
| 82 | + // print!("Syncing..."); |
| 83 | + // let client = esplora_client::Builder::new(ESPLORA_URL).build_async()?; |
| 84 | + |
| 85 | + // let request = wallet.start_full_scan().inspect({ |
| 86 | + // let mut stdout = std::io::stdout(); |
| 87 | + // let mut once = BTreeSet::<Keychain>::new(); |
| 88 | + // move |keychain, spk_i, _| { |
| 89 | + // if once.insert(keychain) { |
| 90 | + // print!("\nScanning keychain [{:?}]", keychain); |
| 91 | + // } |
| 92 | + // print!(" {:<3}", spk_i); |
| 93 | + // stdout.flush().expect("must flush") |
| 94 | + // } |
| 95 | + // }); |
| 96 | + |
| 97 | + // let update = client |
| 98 | + // .full_scan(request, STOP_GAP, PARALLEL_REQUESTS) |
| 99 | + // .await?; |
| 100 | + |
| 101 | + // wallet.apply_update(update)?; |
| 102 | + // wallet.persist(&mut conn)?; |
| 103 | + // println!(); |
| 104 | + |
| 105 | + // let balance = wallet.balance(); |
| 106 | + // println!("Wallet balance after syncing: {}", balance.total()); |
| 107 | + |
| 108 | + // if balance.total() < SEND_AMOUNT { |
| 109 | + // println!( |
| 110 | + // "Please send at least {} to the receiving address", |
| 111 | + // SEND_AMOUNT |
| 112 | + // ); |
| 113 | + // std::process::exit(0); |
| 114 | + // } |
| 115 | + |
| 116 | + // let mut tx_builder = wallet.build_tx(); |
| 117 | + // tx_builder.add_recipient(address.script_pubkey(), SEND_AMOUNT); |
| 118 | + |
| 119 | + // let mut psbt = tx_builder.finish()?; |
| 120 | + // let finalized = wallet.sign(&mut psbt, SignOptions::default())?; |
| 121 | + // assert!(finalized); |
| 122 | + |
| 123 | + // let tx = psbt.extract_tx()?; |
| 124 | + // client.broadcast(&tx).await?; |
| 125 | + // println!("Tx broadcasted! Txid: {}", tx.compute_txid()); |
89 | 126 |
|
90 | 127 | Ok(())
|
91 | 128 | }
|
0 commit comments