@@ -114,19 +114,9 @@ fn mpp_retry() {
114
114
115
115
// Add the HTLC along the first hop.
116
116
let fail_path_msgs_1 = remove_first_msg_event_to_node ( & nodes[ 2 ] . node . get_our_node_id ( ) , & mut events) ;
117
- let ( update_add, commitment_signed) = match fail_path_msgs_1 {
118
- MessageSendEvent :: UpdateHTLCs { node_id : _, updates : msgs:: CommitmentUpdate { ref update_add_htlcs, ref update_fulfill_htlcs, ref update_fail_htlcs, ref update_fail_malformed_htlcs, ref update_fee, ref commitment_signed } } => {
119
- assert_eq ! ( update_add_htlcs. len( ) , 1 ) ;
120
- assert ! ( update_fail_htlcs. is_empty( ) ) ;
121
- assert ! ( update_fulfill_htlcs. is_empty( ) ) ;
122
- assert ! ( update_fail_malformed_htlcs. is_empty( ) ) ;
123
- assert ! ( update_fee. is_none( ) ) ;
124
- ( update_add_htlcs[ 0 ] . clone ( ) , commitment_signed. clone ( ) )
125
- } ,
126
- _ => panic ! ( "Unexpected event" ) ,
127
- } ;
128
- nodes[ 2 ] . node . handle_update_add_htlc ( & nodes[ 0 ] . node . get_our_node_id ( ) , & update_add) ;
129
- commitment_signed_dance ! ( nodes[ 2 ] , nodes[ 0 ] , commitment_signed, false ) ;
117
+ let send_event = SendEvent :: from_event ( fail_path_msgs_1) ;
118
+ nodes[ 2 ] . node . handle_update_add_htlc ( & nodes[ 0 ] . node . get_our_node_id ( ) , & send_event. msgs [ 0 ] ) ;
119
+ commitment_signed_dance ! ( nodes[ 2 ] , nodes[ 0 ] , & send_event. commitment_msg, false ) ;
130
120
131
121
// Attempt to forward the payment and complete the 2nd path's failure.
132
122
expect_pending_htlcs_forwardable ! ( & nodes[ 2 ] ) ;
@@ -225,25 +215,9 @@ fn mpp_retry_overpay() {
225
215
226
216
// Add the HTLC along the first hop.
227
217
let fail_path_msgs_1 = remove_first_msg_event_to_node ( & nodes[ 2 ] . node . get_our_node_id ( ) , & mut events) ;
228
- let ( update_add, commitment_signed) = match fail_path_msgs_1 {
229
- MessageSendEvent :: UpdateHTLCs {
230
- node_id : _,
231
- updates : msgs:: CommitmentUpdate {
232
- ref update_add_htlcs, ref update_fulfill_htlcs, ref update_fail_htlcs,
233
- ref update_fail_malformed_htlcs, ref update_fee, ref commitment_signed
234
- }
235
- } => {
236
- assert_eq ! ( update_add_htlcs. len( ) , 1 ) ;
237
- assert ! ( update_fail_htlcs. is_empty( ) ) ;
238
- assert ! ( update_fulfill_htlcs. is_empty( ) ) ;
239
- assert ! ( update_fail_malformed_htlcs. is_empty( ) ) ;
240
- assert ! ( update_fee. is_none( ) ) ;
241
- ( update_add_htlcs[ 0 ] . clone ( ) , commitment_signed. clone ( ) )
242
- } ,
243
- _ => panic ! ( "Unexpected event" ) ,
244
- } ;
245
- nodes[ 2 ] . node . handle_update_add_htlc ( & nodes[ 0 ] . node . get_our_node_id ( ) , & update_add) ;
246
- commitment_signed_dance ! ( nodes[ 2 ] , nodes[ 0 ] , commitment_signed, false ) ;
218
+ let send_event = SendEvent :: from_event ( fail_path_msgs_1) ;
219
+ nodes[ 2 ] . node . handle_update_add_htlc ( & nodes[ 0 ] . node . get_our_node_id ( ) , & send_event. msgs [ 0 ] ) ;
220
+ commitment_signed_dance ! ( nodes[ 2 ] , nodes[ 0 ] , & send_event. commitment_msg, false ) ;
247
221
248
222
// Attempt to forward the payment and complete the 2nd path's failure.
249
223
expect_pending_htlcs_forwardable ! ( & nodes[ 2 ] ) ;
0 commit comments