@@ -3672,7 +3672,7 @@ mod tests {
3672
3672
}
3673
3673
}
3674
3674
3675
- fn close_channel ( outbound_node : & Node , inbound_node : & Node , channel_id : & [ u8 ; 32 ] , funding_tx : Transaction , close_inbound_first : bool ) -> ( msgs:: ChannelUpdate , msgs:: ChannelUpdate ) {
3675
+ fn close_channel ( outbound_node : & Node , inbound_node : & Node , channel_id : & [ u8 ; 32 ] , funding_tx : Transaction , close_inbound_first : bool ) -> ( msgs:: ChannelUpdate , msgs:: ChannelUpdate , Transaction ) {
3676
3676
let ( node_a, broadcaster_a, struct_a) = if close_inbound_first { ( & inbound_node. node , & inbound_node. tx_broadcaster , inbound_node) } else { ( & outbound_node. node , & outbound_node. tx_broadcaster , outbound_node) } ;
3677
3677
let ( node_b, broadcaster_b) = if close_inbound_first { ( & outbound_node. node , & outbound_node. tx_broadcaster ) } else { ( & inbound_node. node , & inbound_node. tx_broadcaster ) } ;
3678
3678
let ( tx_a, tx_b) ;
@@ -3735,7 +3735,7 @@ mod tests {
3735
3735
assert_eq ! ( tx_a, tx_b) ;
3736
3736
check_spends ! ( tx_a, funding_tx) ;
3737
3737
3738
- ( as_update, bs_update)
3738
+ ( as_update, bs_update, tx_a )
3739
3739
}
3740
3740
3741
3741
struct SendEvent {
@@ -7944,4 +7944,25 @@ mod tests {
7944
7944
check_spends ! ( spend_txn[ 0 ] , local_txn[ 0 ] . clone( ) ) ;
7945
7945
check_spends ! ( spend_txn[ 1 ] , node_txn[ 0 ] . clone( ) ) ;
7946
7946
}
7947
+
7948
+ #[ test]
7949
+ fn test_static_output_closing_tx ( ) {
7950
+ let nodes = create_network ( 2 ) ;
7951
+
7952
+ let chan = create_announced_chan_between_nodes ( & nodes, 0 , 1 ) ;
7953
+
7954
+ send_payment ( & nodes[ 0 ] , & vec ! ( & nodes[ 1 ] ) [ ..] , 8000000 ) ;
7955
+ let closing_tx = close_channel ( & nodes[ 0 ] , & nodes[ 1 ] , & chan. 2 , chan. 3 , true ) . 2 ;
7956
+
7957
+ let header = BlockHeader { version : 0x20000000 , prev_blockhash : Default :: default ( ) , merkle_root : Default :: default ( ) , time : 42 , bits : 42 , nonce : 42 } ;
7958
+ nodes[ 0 ] . chain_monitor . block_connected_with_filtering ( & Block { header, txdata : vec ! [ closing_tx. clone( ) ] } , 1 ) ;
7959
+ let events = nodes[ 0 ] . chan_monitor . simple_monitor . get_and_clear_pending_events ( ) ;
7960
+ let spend_tx = check_static_output ! ( events, nodes, 0 , 0 , 2 , 0 ) ;
7961
+ check_spends ! ( spend_tx, closing_tx. clone( ) ) ;
7962
+
7963
+ nodes[ 1 ] . chain_monitor . block_connected_with_filtering ( & Block { header, txdata : vec ! [ closing_tx. clone( ) ] } , 1 ) ;
7964
+ let events = nodes[ 1 ] . chan_monitor . simple_monitor . get_and_clear_pending_events ( ) ;
7965
+ let spend_tx = check_static_output ! ( events, nodes, 0 , 0 , 2 , 1 ) ;
7966
+ check_spends ! ( spend_tx, closing_tx) ;
7967
+ }
7947
7968
}
0 commit comments