@@ -845,26 +845,24 @@ pub fn get_updates_and_revoke<CM: AChannelManager, H: NodeHolder<CM=CM>>(node: &
845
845
macro_rules! get_revoke_commit_msgs {
846
846
( $node: expr, $node_id: expr) => {
847
847
$crate:: ln:: functional_test_utils:: get_revoke_commit_msgs( & $node, & $node_id)
848
- }
848
+ } ;
849
849
}
850
850
851
851
/// Get an specific event message from the pending events queue.
852
852
#[ macro_export]
853
853
#[ rustfmt:: skip]
854
854
macro_rules! get_event_msg {
855
- ( $node: expr, $event_type: path, $node_id: expr) => {
856
- {
857
- let events = $node. node. get_and_clear_pending_msg_events( ) ;
858
- assert_eq!( events. len( ) , 1 ) ;
859
- match events[ 0 ] {
860
- $event_type { ref node_id, ref msg } => {
861
- assert_eq!( * node_id, $node_id) ;
862
- ( * msg) . clone( )
863
- } ,
864
- _ => panic!( "Unexpected event {:?}" , events[ 0 ] ) ,
865
- }
855
+ ( $node: expr, $event_type: path, $node_id: expr) => { {
856
+ let events = $node. node. get_and_clear_pending_msg_events( ) ;
857
+ assert_eq!( events. len( ) , 1 ) ;
858
+ match events[ 0 ] {
859
+ $event_type { ref node_id, ref msg } => {
860
+ assert_eq!( * node_id, $node_id) ;
861
+ ( * msg) . clone( )
862
+ } ,
863
+ _ => panic!( "Unexpected event {:?}" , events[ 0 ] ) ,
866
864
}
867
- }
865
+ } } ;
868
866
}
869
867
870
868
/// Get an error message from the pending events queue.
@@ -929,7 +927,7 @@ pub fn get_htlc_update_msgs(node: &Node, recipient: &PublicKey) -> msgs::Commitm
929
927
macro_rules! get_htlc_update_msgs {
930
928
( $node: expr, $node_id: expr) => {
931
929
$crate:: ln:: functional_test_utils:: get_htlc_update_msgs( & $node, & $node_id)
932
- }
930
+ } ;
933
931
}
934
932
935
933
/// Fetches the first `msg_event` to the passed `node_id` in the passed `msg_events` vec.
@@ -1105,22 +1103,19 @@ macro_rules! get_channel_type_features {
1105
1103
#[ macro_export]
1106
1104
#[ rustfmt:: skip]
1107
1105
macro_rules! get_monitor {
1108
- ( $node: expr, $channel_id: expr) => {
1109
- {
1110
- $node. chain_monitor. chain_monitor. get_monitor( $channel_id) . unwrap( )
1111
- }
1112
- }
1106
+ ( $node: expr, $channel_id: expr) => { {
1107
+ $node. chain_monitor. chain_monitor. get_monitor( $channel_id) . unwrap( )
1108
+ } } ;
1113
1109
}
1114
1110
1115
1111
/// Returns any local commitment transactions for the channel.
1116
1112
#[ macro_export]
1117
1113
#[ rustfmt:: skip]
1118
1114
macro_rules! get_local_commitment_txn {
1119
- ( $node: expr, $channel_id: expr) => {
1120
- {
1121
- $crate:: get_monitor!( $node, $channel_id) . unsafe_get_latest_holder_commitment_txn( & $node. logger)
1122
- }
1123
- }
1115
+ ( $node: expr, $channel_id: expr) => { {
1116
+ $crate:: get_monitor!( $node, $channel_id)
1117
+ . unsafe_get_latest_holder_commitment_txn( & $node. logger)
1118
+ } } ;
1124
1119
}
1125
1120
1126
1121
/// Check the error from attempting a payment.
@@ -1176,7 +1171,7 @@ pub fn check_added_monitors<CM: AChannelManager, H: NodeHolder<CM=CM>>(node: &H,
1176
1171
macro_rules! check_added_monitors {
1177
1172
( $node: expr, $count: expr) => {
1178
1173
$crate:: ln:: functional_test_utils:: check_added_monitors( & $node, $count) ;
1179
- }
1174
+ } ;
1180
1175
}
1181
1176
1182
1177
#[ rustfmt:: skip]
@@ -1822,7 +1817,7 @@ pub fn check_closed_broadcast(node: &Node, num_channels: usize, with_error_msg:
1822
1817
macro_rules! check_closed_broadcast {
1823
1818
( $node: expr, $with_error_msg: expr) => {
1824
1819
$crate:: ln:: functional_test_utils:: check_closed_broadcast( & $node, 1 , $with_error_msg) . pop( )
1825
- }
1820
+ } ;
1826
1821
}
1827
1822
1828
1823
#[ derive( Default ) ]
@@ -1918,12 +1913,25 @@ pub fn check_closed_event(node: &Node, events_count: usize, expected_reason: Clo
1918
1913
#[ rustfmt:: skip]
1919
1914
macro_rules! check_closed_event {
1920
1915
( $node: expr, $events: expr, $reason: expr, $counterparty_node_ids: expr, $channel_capacity: expr) => {
1921
- check_closed_event!( $node, $events, $reason, false , $counterparty_node_ids, $channel_capacity) ;
1916
+ check_closed_event!(
1917
+ $node,
1918
+ $events,
1919
+ $reason,
1920
+ false ,
1921
+ $counterparty_node_ids,
1922
+ $channel_capacity
1923
+ ) ;
1922
1924
} ;
1923
1925
( $node: expr, $events: expr, $reason: expr, $is_check_discard_funding: expr, $counterparty_node_ids: expr, $channel_capacity: expr) => {
1924
- $crate:: ln:: functional_test_utils:: check_closed_event( & $node, $events, $reason,
1925
- $is_check_discard_funding, & $counterparty_node_ids, $channel_capacity) ;
1926
- }
1926
+ $crate:: ln:: functional_test_utils:: check_closed_event(
1927
+ & $node,
1928
+ $events,
1929
+ $reason,
1930
+ $is_check_discard_funding,
1931
+ & $counterparty_node_ids,
1932
+ $channel_capacity,
1933
+ ) ;
1934
+ } ;
1927
1935
}
1928
1936
1929
1937
#[ rustfmt:: skip]
@@ -2301,7 +2309,11 @@ macro_rules! get_payment_preimage_hash {
2301
2309
crate :: get_payment_preimage_hash!( $dest_node, $min_value_msat, None )
2302
2310
} ;
2303
2311
( $dest_node: expr, $min_value_msat: expr, $min_final_cltv_expiry_delta: expr) => {
2304
- $crate:: ln:: functional_test_utils:: get_payment_preimage_hash( & $dest_node, $min_value_msat, $min_final_cltv_expiry_delta)
2312
+ $crate:: ln:: functional_test_utils:: get_payment_preimage_hash(
2313
+ & $dest_node,
2314
+ $min_value_msat,
2315
+ $min_final_cltv_expiry_delta,
2316
+ )
2305
2317
} ;
2306
2318
}
2307
2319
@@ -2347,21 +2359,39 @@ macro_rules! get_route {
2347
2359
#[ rustfmt:: skip]
2348
2360
macro_rules! get_route_and_payment_hash {
2349
2361
( $send_node: expr, $recv_node: expr, $recv_value: expr) => { {
2350
- let payment_params = $crate:: routing:: router:: PaymentParameters :: from_node_id( $recv_node. node. get_our_node_id( ) , TEST_FINAL_CLTV )
2351
- . with_bolt11_features( $recv_node. node. bolt11_invoice_features( ) ) . unwrap( ) ;
2362
+ let payment_params = $crate:: routing:: router:: PaymentParameters :: from_node_id(
2363
+ $recv_node. node. get_our_node_id( ) ,
2364
+ TEST_FINAL_CLTV ,
2365
+ )
2366
+ . with_bolt11_features( $recv_node. node. bolt11_invoice_features( ) )
2367
+ . unwrap( ) ;
2352
2368
$crate:: get_route_and_payment_hash!( $send_node, $recv_node, payment_params, $recv_value)
2353
2369
} } ;
2354
2370
( $send_node: expr, $recv_node: expr, $payment_params: expr, $recv_value: expr) => { {
2355
- $crate:: get_route_and_payment_hash!( $send_node, $recv_node, $payment_params, $recv_value, None )
2371
+ $crate:: get_route_and_payment_hash!(
2372
+ $send_node,
2373
+ $recv_node,
2374
+ $payment_params,
2375
+ $recv_value,
2376
+ None
2377
+ )
2356
2378
} } ;
2357
2379
( $send_node: expr, $recv_node: expr, $payment_params: expr, $recv_value: expr, $max_total_routing_fee_msat: expr) => { {
2358
- let mut route_params = $crate:: routing:: router:: RouteParameters :: from_payment_params_and_value( $payment_params, $recv_value) ;
2380
+ let mut route_params =
2381
+ $crate:: routing:: router:: RouteParameters :: from_payment_params_and_value(
2382
+ $payment_params,
2383
+ $recv_value,
2384
+ ) ;
2359
2385
route_params. max_total_routing_fee_msat = $max_total_routing_fee_msat;
2360
2386
let ( payment_preimage, payment_hash, payment_secret) =
2361
- $crate:: ln:: functional_test_utils:: get_payment_preimage_hash( & $recv_node, Some ( $recv_value) , None ) ;
2387
+ $crate:: ln:: functional_test_utils:: get_payment_preimage_hash(
2388
+ & $recv_node,
2389
+ Some ( $recv_value) ,
2390
+ None ,
2391
+ ) ;
2362
2392
let route = $crate:: ln:: functional_test_utils:: get_route( & $send_node, & route_params) ;
2363
2393
( route. unwrap( ) , payment_hash, payment_preimage, payment_secret)
2364
- } }
2394
+ } } ;
2365
2395
}
2366
2396
2367
2397
#[ rustfmt:: skip]
@@ -2480,12 +2510,22 @@ macro_rules! expect_payment_sent {
2480
2510
$crate:: expect_payment_sent!( $node, $expected_payment_preimage, None :: <u64 >, true )
2481
2511
} ;
2482
2512
( $node: expr, $expected_payment_preimage: expr, $expected_fee_msat_opt: expr) => {
2483
- $crate:: expect_payment_sent!( $node, $expected_payment_preimage, $expected_fee_msat_opt, true )
2513
+ $crate:: expect_payment_sent!(
2514
+ $node,
2515
+ $expected_payment_preimage,
2516
+ $expected_fee_msat_opt,
2517
+ true
2518
+ )
2484
2519
} ;
2485
2520
( $node: expr, $expected_payment_preimage: expr, $expected_fee_msat_opt: expr, $expect_paths: expr) => {
2486
- $crate:: ln:: functional_test_utils:: expect_payment_sent( & $node, $expected_payment_preimage,
2487
- $expected_fee_msat_opt. map( |o| Some ( o) ) , $expect_paths, true )
2488
- }
2521
+ $crate:: ln:: functional_test_utils:: expect_payment_sent(
2522
+ & $node,
2523
+ $expected_payment_preimage,
2524
+ $expected_fee_msat_opt. map( |o| Some ( o) ) ,
2525
+ $expect_paths,
2526
+ true ,
2527
+ )
2528
+ } ;
2489
2529
}
2490
2530
2491
2531
#[ macro_export]
@@ -2498,7 +2538,7 @@ macro_rules! expect_payment_path_successful {
2498
2538
$crate:: events:: Event :: PaymentPathSuccessful { .. } => { } ,
2499
2539
_ => panic!( "Unexpected event" ) ,
2500
2540
}
2501
- }
2541
+ } ;
2502
2542
}
2503
2543
2504
2544
/// Returns the total fee earned by this HTLC forward, in msat.
0 commit comments