X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Futil%2Ftest_utils.rs;h=2577bc9f9badae0f6bd2acbb89f2011424cf1e4e;hb=3bcd911fcb112551525521dc3d16b88e07314318;hp=8ab02b2674a60ed68c06ebc67ee3561ad19077be;hpb=65b23d8d8a936ad5047eb1ec0115a9679ae5eca1;p=rust-lightning diff --git a/src/util/test_utils.rs b/src/util/test_utils.rs index 8ab02b26..2577bc9f 100644 --- a/src/util/test_utils.rs +++ b/src/util/test_utils.rs @@ -38,12 +38,14 @@ impl chaininterface::FeeEstimator for TestFeeEstimator { pub struct TestChannelMonitor { pub added_monitors: Mutex>, pub simple_monitor: Arc>, + pub update_ret: Mutex>, } impl TestChannelMonitor { pub fn new(chain_monitor: Arc, broadcaster: Arc) -> Self { Self { added_monitors: Mutex::new(Vec::new()), simple_monitor: channelmonitor::SimpleManyChannelMonitor::new(chain_monitor, broadcaster), + update_ret: Mutex::new(Ok(())), } } } @@ -57,7 +59,8 @@ impl channelmonitor::ManyChannelMonitor for TestChannelMonitor { w.0.clear(); monitor.write_for_watchtower(&mut w).unwrap(); // This at least shouldn't crash... self.added_monitors.lock().unwrap().push((funding_txo, monitor.clone())); - self.simple_monitor.add_update_monitor(funding_txo, monitor) + assert!(self.simple_monitor.add_update_monitor(funding_txo, monitor).is_ok()); + self.update_ret.lock().unwrap().clone() } }