@@ -4169,7 +4169,7 @@ mod tests {
4169
4169
let events = origin_node. node . get_and_clear_pending_events ( ) ;
4170
4170
assert_eq ! ( events. len( ) , 1 ) ;
4171
4171
match events[ 0 ] {
4172
- Event :: PaymentFailed { payment_hash, rejected_by_dest } => {
4172
+ Event :: PaymentFailed { payment_hash, rejected_by_dest, .. } => {
4173
4173
assert_eq ! ( payment_hash, our_payment_hash) ;
4174
4174
assert ! ( rejected_by_dest) ;
4175
4175
} ,
@@ -4899,20 +4899,37 @@ mod tests {
4899
4899
assert ! ( updates_2. update_fee. is_none( ) ) ;
4900
4900
4901
4901
nodes[ 0 ] . node . handle_update_fail_htlc ( & nodes[ 1 ] . node . get_our_node_id ( ) , & updates_2. update_fail_htlcs [ 0 ] ) . unwrap ( ) ;
4902
+
4902
4903
commitment_signed_dance ! ( nodes[ 0 ] , nodes[ 1 ] , updates_2. commitment_signed, false , true ) ;
4903
4904
4904
4905
let events = nodes[ 0 ] . node . get_and_clear_pending_events ( ) ;
4905
4906
assert_eq ! ( events. len( ) , 1 ) ;
4906
4907
match events[ 0 ] {
4907
- Event :: PaymentFailed { ref payment_hash, ref rejected_by_dest } => {
4908
+ Event :: PaymentFailed { ref payment_hash, ref rejected_by_dest, .. } => {
4908
4909
assert_eq ! ( our_payment_hash, * payment_hash) ;
4909
4910
assert ! ( !rejected_by_dest) ;
4910
4911
} ,
4911
4912
_ => panic ! ( "Unexpected event" ) ,
4912
4913
}
4913
4914
4915
+ let msg_events = nodes[ 0 ] . node . get_and_clear_pending_msg_events ( ) ;
4916
+ assert_eq ! ( msg_events. len( ) , 2 ) ;
4917
+ let node_0_closing_signed = match msg_events[ 0 ] {
4918
+ MessageSendEvent :: SendClosingSigned { ref node_id, ref msg } => {
4919
+ assert_eq ! ( * node_id, nodes[ 1 ] . node. get_our_node_id( ) ) ;
4920
+ ( * msg) . clone ( )
4921
+ } ,
4922
+ _ => panic ! ( "Unexpected event" ) ,
4923
+ } ;
4924
+ match msg_events[ 1 ] {
4925
+ MessageSendEvent :: PaymentFailureNetworkUpdate { update : msgs:: HTLCFailChannelUpdate :: NodeFailure { ref node_id, ref is_permanent } } => {
4926
+ assert ! ( is_permanent) ;
4927
+ assert_eq ! ( * node_id, nodes[ 1 ] . node. get_our_node_id( ) ) ;
4928
+ } ,
4929
+ _ => panic ! ( "Unexpected event" ) ,
4930
+ }
4931
+
4914
4932
assert ! ( nodes[ 1 ] . node. get_and_clear_pending_msg_events( ) . is_empty( ) ) ;
4915
- let node_0_closing_signed = get_event_msg ! ( nodes[ 0 ] , MessageSendEvent :: SendClosingSigned , nodes[ 1 ] . node. get_our_node_id( ) ) ;
4916
4933
nodes[ 1 ] . node . handle_closing_signed ( & nodes[ 0 ] . node . get_our_node_id ( ) , & node_0_closing_signed) . unwrap ( ) ;
4917
4934
let ( _, node_1_closing_signed) = get_closing_signed_broadcast ! ( nodes[ 1 ] . node, nodes[ 0 ] . node. get_our_node_id( ) ) ;
4918
4935
nodes[ 0 ] . node . handle_closing_signed ( & nodes[ 1 ] . node . get_our_node_id ( ) , & node_1_closing_signed. unwrap ( ) ) . unwrap ( ) ;
@@ -6439,7 +6456,7 @@ mod tests {
6439
6456
_ => panic ! ( "Unexpected event" ) ,
6440
6457
}
6441
6458
match events[ 1 ] {
6442
- Event :: PaymentFailed { payment_hash, rejected_by_dest } => {
6459
+ Event :: PaymentFailed { payment_hash, rejected_by_dest, .. } => {
6443
6460
assert_eq ! ( payment_hash, payment_hash_5) ;
6444
6461
assert ! ( rejected_by_dest) ;
6445
6462
} ,
0 commit comments