@@ -23,7 +23,9 @@ use crate::ln::msgs::{
23
23
} ;
24
24
use crate :: ln:: offers_tests;
25
25
use crate :: ln:: onion_utils:: LocalHTLCFailureReason ;
26
- use crate :: ln:: outbound_payment:: { PendingOutboundPayment , Retry , TEST_ASYNC_PAYMENT_TIMEOUT_RELATIVE_EXPIRY } ;
26
+ use crate :: ln:: outbound_payment:: {
27
+ PendingOutboundPayment , Retry , TEST_ASYNC_PAYMENT_TIMEOUT_RELATIVE_EXPIRY ,
28
+ } ;
27
29
use crate :: offers:: async_receive_offer_cache:: {
28
30
TEST_MAX_CACHED_OFFERS_TARGET , TEST_MAX_UPDATE_ATTEMPTS ,
29
31
TEST_MIN_OFFER_PATHS_RELATIVE_EXPIRY_SECS , TEST_OFFER_REFRESH_THRESHOLD ,
@@ -696,7 +698,8 @@ fn timeout_unreleased_payment() {
696
698
let recipient = & nodes[ 2 ] ;
697
699
698
700
let recipient_id = vec ! [ 42 ; 32 ] ;
699
- let inv_server_paths = server. node . blinded_paths_for_async_recipient ( recipient_id. clone ( ) , None ) . unwrap ( ) ;
701
+ let inv_server_paths =
702
+ server. node . blinded_paths_for_async_recipient ( recipient_id. clone ( ) , None ) . unwrap ( ) ;
700
703
recipient. node . set_paths_to_static_invoice_server ( inv_server_paths) . unwrap ( ) ;
701
704
702
705
let static_invoice =
@@ -711,10 +714,8 @@ fn timeout_unreleased_payment() {
711
714
. pay_for_offer ( & offer, None , Some ( amt_msat) , None , payment_id, Retry :: Attempts ( 0 ) , params)
712
715
. unwrap ( ) ;
713
716
714
- let invreq_om = sender
715
- . onion_messenger
716
- . next_onion_message_for_peer ( server. node . get_our_node_id ( ) )
717
- . unwrap ( ) ;
717
+ let invreq_om =
718
+ sender. onion_messenger . next_onion_message_for_peer ( server. node . get_our_node_id ( ) ) . unwrap ( ) ;
718
719
server. onion_messenger . handle_onion_message ( sender. node . get_our_node_id ( ) , & invreq_om) ;
719
720
720
721
let mut events = server. node . get_and_clear_pending_events ( ) ;
@@ -725,21 +726,17 @@ fn timeout_unreleased_payment() {
725
726
} ;
726
727
727
728
server. node . send_static_invoice ( static_invoice. clone ( ) , reply_path) . unwrap ( ) ;
728
- let static_invoice_om = server
729
- . onion_messenger
730
- . next_onion_message_for_peer ( sender. node . get_our_node_id ( ) )
731
- . unwrap ( ) ;
729
+ let static_invoice_om =
730
+ server. onion_messenger . next_onion_message_for_peer ( sender. node . get_our_node_id ( ) ) . unwrap ( ) ;
732
731
733
732
// We handle the static invoice to held the pending HTLC
734
- sender
735
- . onion_messenger
736
- . handle_onion_message ( sender. node . get_our_node_id ( ) , & static_invoice_om) ;
733
+ sender. onion_messenger . handle_onion_message ( sender. node . get_our_node_id ( ) , & static_invoice_om) ;
737
734
738
735
// We advance enough time to expire the payment.
739
736
// We add 2 hours as is the margin added to remove stale payments in non-std implementation.
740
737
let timeout_time_expiry = TEST_ASYNC_PAYMENT_TIMEOUT_RELATIVE_EXPIRY
741
- + Duration :: from_secs ( 7200 )
742
- + Duration :: from_secs ( 1 ) ;
738
+ + Duration :: from_secs ( 7200 )
739
+ + Duration :: from_secs ( 1 ) ;
743
740
advance_time_by ( timeout_time_expiry, sender) ;
744
741
sender. node . timer_tick_occurred ( ) ;
745
742
let events = sender. node . get_and_clear_pending_events ( ) ;
0 commit comments