f check tx broadcasted events in test

Author: TheBlueMatt

lightning/src/ln/reorg_tests.rs

@@ -260,6 +260,12 @@ fn do_test_unconf_chan(reload_node: bool, reorg_after_reload: bool, use_funding_
 		};
 		nodes[0].node = &nodes_0_deserialized;
 		assert!(nodes_0_read.is_empty());
+		if !reorg_after_reload {
+			// If the channel is already closed when we reload the node, we'll broadcast a closing
+			// transaction via the ChannelMonitor which is missing a corresponding channel.
+			assert_eq!(nodes[0].tx_broadcaster.txn_broadcasted.lock().unwrap().len(), 1);
+			nodes[0].tx_broadcaster.txn_broadcasted.lock().unwrap().clear();
+		}
 
 		nodes[0].chain_monitor.watch_channel(chan_0_monitor.get_funding_txo().0.clone(), chan_0_monitor).unwrap();
 		check_added_monitors!(nodes[0], 1);
@@ -290,6 +296,8 @@ fn do_test_unconf_chan(reload_node: bool, reorg_after_reload: bool, use_funding_
 	*nodes[0].chain_monitor.expect_channel_force_closed.lock().unwrap() = Some((chan.2, true));
 	nodes[0].node.test_process_background_events(); // Required to free the pending background monitor update
 	check_added_monitors!(nodes[0], 1);
+	assert_eq!(nodes[0].tx_broadcaster.txn_broadcasted.lock().unwrap().len(), 1);
+	nodes[0].tx_broadcaster.txn_broadcasted.lock().unwrap().clear();
 
 	// Now check that we can create a new channel
 	create_announced_chan_between_nodes(&nodes, 0, 1, InitFeatures::known(), InitFeatures::known());