- // Check we pick up on new best blocks
- assert_eq!(confirmable.best_block.lock().unwrap().1, 0);
-
- tx_sync.sync(vec![&confirmable]).await.unwrap();
- assert_eq!(confirmable.best_block.lock().unwrap().1, 102);
-
- let events = std::mem::take(&mut *confirmable.events.lock().unwrap());
- assert_eq!(events.len(), 1);
-
- // Check registered confirmed transactions are marked confirmed
- let new_address = bitcoind.client.get_new_address(Some("test"),
- Some(AddressType::Legacy)).unwrap().assume_checked();
- let txid = bitcoind.client.send_to_address(&new_address, Amount::from_sat(5000), None, None,
- None, None, None, None).unwrap();
- let second_txid = bitcoind.client.send_to_address(&new_address, Amount::from_sat(5000), None,
- None, None, None, None, None).unwrap();
- tx_sync.register_tx(&txid, &new_address.script_pubkey());
-
- tx_sync.sync(vec![&confirmable]).await.unwrap();
-
- let events = std::mem::take(&mut *confirmable.events.lock().unwrap());
- assert_eq!(events.len(), 0);
- assert!(confirmable.confirmed_txs.lock().unwrap().is_empty());
- assert!(confirmable.unconfirmed_txs.lock().unwrap().is_empty());
-
- generate_blocks_and_wait(&bitcoind, &electrsd, 1);
- tx_sync.sync(vec![&confirmable]).await.unwrap();
-
- let events = std::mem::take(&mut *confirmable.events.lock().unwrap());
- assert_eq!(events.len(), 2);
- assert!(confirmable.confirmed_txs.lock().unwrap().contains_key(&txid));
- assert!(confirmable.unconfirmed_txs.lock().unwrap().is_empty());
-
- // Now take an arbitrary output of the second transaction and check we'll confirm its spend.
- let tx_res = bitcoind.client.get_transaction(&second_txid, None).unwrap();
- let block_hash = tx_res.info.blockhash.unwrap();
- let tx = tx_res.transaction().unwrap();
- let prev_outpoint = tx.input.first().unwrap().previous_output;
- let prev_tx = bitcoind.client.get_transaction(&prev_outpoint.txid, None).unwrap().transaction()
- .unwrap();
- let prev_script_pubkey = prev_tx.output[prev_outpoint.vout as usize].script_pubkey.clone();
- let output = WatchedOutput {
- block_hash: Some(block_hash),
- outpoint: OutPoint { txid: prev_outpoint.txid, index: prev_outpoint.vout as u16 },
- script_pubkey: prev_script_pubkey
- };
-
- tx_sync.register_output(output);
- tx_sync.sync(vec![&confirmable]).await.unwrap();
-
- let events = std::mem::take(&mut *confirmable.events.lock().unwrap());
- assert_eq!(events.len(), 1);
- assert!(confirmable.confirmed_txs.lock().unwrap().contains_key(&second_txid));
- assert_eq!(confirmable.confirmed_txs.lock().unwrap().len(), 2);
- assert!(confirmable.unconfirmed_txs.lock().unwrap().is_empty());
-
- // Check previously confirmed transactions are marked unconfirmed when they are reorged.
- let best_block_hash = bitcoind.client.get_best_block_hash().unwrap();
- bitcoind.client.invalidate_block(&best_block_hash).unwrap();
-
- // We're getting back to the previous height with a new tip, but best block shouldn't change.
- generate_blocks_and_wait(&bitcoind, &electrsd, 1);
- assert_ne!(bitcoind.client.get_best_block_hash().unwrap(), best_block_hash);
- tx_sync.sync(vec![&confirmable]).await.unwrap();
- let events = std::mem::take(&mut *confirmable.events.lock().unwrap());
- assert_eq!(events.len(), 0);
-
- // Now we're surpassing previous height, getting new tip.
- generate_blocks_and_wait(&bitcoind, &electrsd, 1);
- assert_ne!(bitcoind.client.get_best_block_hash().unwrap(), best_block_hash);
- tx_sync.sync(vec![&confirmable]).await.unwrap();
-
- // Transactions still confirmed but under new tip.
- assert!(confirmable.confirmed_txs.lock().unwrap().contains_key(&txid));
- assert!(confirmable.confirmed_txs.lock().unwrap().contains_key(&second_txid));
- assert!(confirmable.unconfirmed_txs.lock().unwrap().is_empty());
-
- // Check we got unconfirmed, then reconfirmed in the meantime.
- let mut seen_txids = HashSet::new();
- let events = std::mem::take(&mut *confirmable.events.lock().unwrap());
- assert_eq!(events.len(), 5);
-
- match events[0] {
- TestConfirmableEvent::Unconfirmed(t) => {
- assert!(t == txid || t == second_txid);
- assert!(seen_txids.insert(t));
- },
- _ => panic!("Unexpected event"),
- }
-
- match events[1] {
- TestConfirmableEvent::Unconfirmed(t) => {
- assert!(t == txid || t == second_txid);
- assert!(seen_txids.insert(t));
- },
- _ => panic!("Unexpected event"),
- }
-
- match events[2] {
- TestConfirmableEvent::BestBlockUpdated(..) => {},
- _ => panic!("Unexpected event"),
- }
-
- match events[3] {
- TestConfirmableEvent::Confirmed(t, _, _) => {
- assert!(t == txid || t == second_txid);
- assert!(seen_txids.remove(&t));
- },
- _ => panic!("Unexpected event"),
- }
-
- match events[4] {
- TestConfirmableEvent::Confirmed(t, _, _) => {
- assert!(t == txid || t == second_txid);
- assert!(seen_txids.remove(&t));
- },
- _ => panic!("Unexpected event"),
- }