@@ -949,7 +949,7 @@ mod tests {
949
949
CHANNEL_MANAGER_PERSISTENCE_PRIMARY_NAMESPACE , CHANNEL_MANAGER_PERSISTENCE_SECONDARY_NAMESPACE , CHANNEL_MANAGER_PERSISTENCE_KEY ,
950
950
NETWORK_GRAPH_PERSISTENCE_PRIMARY_NAMESPACE , NETWORK_GRAPH_PERSISTENCE_SECONDARY_NAMESPACE , NETWORK_GRAPH_PERSISTENCE_KEY ,
951
951
SCORER_PERSISTENCE_PRIMARY_NAMESPACE , SCORER_PERSISTENCE_SECONDARY_NAMESPACE , SCORER_PERSISTENCE_KEY } ;
952
- use lightning:: util:: sweep:: { OutputSweeper , OutputSpendStatus , SpendingDelay } ;
952
+ use lightning:: util:: sweep:: { OutputSweeper , OutputSpendStatus } ;
953
953
use lightning_persister:: fs_store:: FilesystemStore ;
954
954
use std:: collections:: VecDeque ;
955
955
use std:: { fs, env} ;
@@ -1665,21 +1665,22 @@ mod tests {
1665
1665
. expect ( "Events not handled within deadline" ) ;
1666
1666
match event {
1667
1667
Event :: SpendableOutputs { outputs, channel_id } => {
1668
- nodes[ 0 ] . sweeper . track_spendable_outputs ( outputs, channel_id, false , Some ( SpendingDelay :: Relative { num_blocks : 3 } ) ) ;
1668
+ nodes[ 0 ] . sweeper . track_spendable_outputs ( outputs, channel_id, false , Some ( 153 ) ) ;
1669
1669
} ,
1670
1670
_ => panic ! ( "Unexpected event: {:?}" , event) ,
1671
1671
}
1672
1672
1673
1673
// Check we don't generate an initial sweeping tx until we reach the required height.
1674
1674
assert_eq ! ( nodes[ 0 ] . sweeper. tracked_spendable_outputs( ) . len( ) , 1 ) ;
1675
1675
let tracked_output = nodes[ 0 ] . sweeper . tracked_spendable_outputs ( ) . first ( ) . unwrap ( ) . clone ( ) ;
1676
- let sweep_tx_0 = nodes[ 0 ] . tx_broadcaster . txn_broadcasted . lock ( ) . unwrap ( ) . pop ( ) . unwrap ( ) ;
1677
- assert ! ( !tracked_output. is_spent_in( & sweep_tx_0) ) ;
1678
- match tracked_output. status {
1679
- OutputSpendStatus :: PendingInitialBroadcast { delayed_until_height } => {
1680
- assert_eq ! ( delayed_until_height, Some ( 153 ) ) ;
1676
+ if let Some ( sweep_tx_0) = nodes[ 0 ] . tx_broadcaster . txn_broadcasted . lock ( ) . unwrap ( ) . pop ( ) {
1677
+ assert ! ( !tracked_output. is_spent_in( & sweep_tx_0) ) ;
1678
+ match tracked_output. status {
1679
+ OutputSpendStatus :: PendingInitialBroadcast { delayed_until_height } => {
1680
+ assert_eq ! ( delayed_until_height, Some ( 153 ) ) ;
1681
+ }
1682
+ _ => panic ! ( "Unexpected status" ) ,
1681
1683
}
1682
- _ => panic ! ( "Unexpected status" ) ,
1683
1684
}
1684
1685
1685
1686
advance_chain ( & mut nodes[ 0 ] , 3 ) ;
0 commit comments