@@ -1494,10 +1494,8 @@ pub fn sign_funding_transaction<'a, 'b, 'c>(
1494
1494
}
1495
1495
expect_channel_pending_event ( & node_b, & node_a_id) ;
1496
1496
1497
- node_a. node . handle_funding_signed (
1498
- node_b_id,
1499
- & get_event_msg ! ( node_b, MessageSendEvent :: SendFundingSigned , node_a_id) ,
1500
- ) ;
1497
+ let bs_funding_signed = get_event_msg ! ( node_b, MessageSendEvent :: SendFundingSigned , node_a_id) ;
1498
+ node_a. node . handle_funding_signed ( node_b_id, & bs_funding_signed) ;
1501
1499
{
1502
1500
let mut added_monitors = node_a. chain_monitor . added_monitors . lock ( ) . unwrap ( ) ;
1503
1501
assert_eq ! ( added_monitors. len( ) , 1 ) ;
@@ -1723,14 +1721,12 @@ pub fn create_chan_between_nodes_with_value_confirm_first<'a, 'b, 'c, 'd>(
1723
1721
) {
1724
1722
confirm_transaction_at ( node_conf, tx, conf_height) ;
1725
1723
connect_blocks ( node_conf, CHAN_CONFIRM_DEPTH - 1 ) ;
1726
- node_recv. node . handle_channel_ready (
1727
- node_conf. node . get_our_node_id ( ) ,
1728
- & get_event_msg ! (
1729
- node_conf,
1730
- MessageSendEvent :: SendChannelReady ,
1731
- node_recv. node. get_our_node_id( )
1732
- ) ,
1724
+ let channel_ready = get_event_msg ! (
1725
+ node_conf,
1726
+ MessageSendEvent :: SendChannelReady ,
1727
+ node_recv. node. get_our_node_id( )
1733
1728
) ;
1729
+ node_recv. node . handle_channel_ready ( node_conf. node . get_our_node_id ( ) , & channel_ready) ;
1734
1730
}
1735
1731
1736
1732
pub fn create_chan_between_nodes_with_value_confirm_second < ' a , ' b , ' c > (
@@ -1904,14 +1900,9 @@ pub fn create_unannounced_chan_between_nodes_with_value<'a, 'b, 'c, 'd>(
1904
1900
tx. clone ( ) ,
1905
1901
)
1906
1902
. unwrap ( ) ;
1907
- nodes[ b] . node . handle_funding_created (
1908
- node_a_id,
1909
- & get_event_msg ! (
1910
- nodes[ a] ,
1911
- MessageSendEvent :: SendFundingCreated ,
1912
- node_b_id
1913
- ) ,
1914
- ) ;
1903
+ let as_funding_created =
1904
+ get_event_msg ! ( nodes[ a] , MessageSendEvent :: SendFundingCreated , node_b_id) ;
1905
+ nodes[ b] . node . handle_funding_created ( node_a_id, & as_funding_created) ;
1915
1906
check_added_monitors ! ( nodes[ b] , 1 ) ;
1916
1907
1917
1908
let cs_funding_signed = get_event_msg ! (
@@ -1940,14 +1931,8 @@ pub fn create_unannounced_chan_between_nodes_with_value<'a, 'b, 'c, 'd>(
1940
1931
MessageSendEvent :: SendChannelReady ,
1941
1932
node_b_id
1942
1933
) ;
1943
- nodes[ a] . node . handle_channel_ready (
1944
- node_b_id,
1945
- & get_event_msg ! (
1946
- nodes[ b] ,
1947
- MessageSendEvent :: SendChannelReady ,
1948
- node_a_id
1949
- ) ,
1950
- ) ;
1934
+ let bs_channel_ready = get_event_msg ! ( nodes[ b] , MessageSendEvent :: SendChannelReady , node_a_id) ;
1935
+ nodes[ a] . node . handle_channel_ready ( node_b_id, & bs_channel_ready) ;
1951
1936
expect_channel_ready_event ( & nodes[ a] , & node_b_id) ;
1952
1937
let as_update = get_event_msg ! (
1953
1938
nodes[ a] ,
@@ -2317,10 +2302,9 @@ pub fn close_channel<'a, 'b, 'c>(
2317
2302
let ( tx_a, tx_b) ;
2318
2303
2319
2304
node_a. close_channel ( channel_id, & node_b. get_our_node_id ( ) ) . unwrap ( ) ;
2320
- node_b. handle_shutdown (
2321
- node_a. get_our_node_id ( ) ,
2322
- & get_event_msg ! ( struct_a, MessageSendEvent :: SendShutdown , node_b. get_our_node_id( ) ) ,
2323
- ) ;
2305
+ let as_shutdown =
2306
+ get_event_msg ! ( struct_a, MessageSendEvent :: SendShutdown , node_b. get_our_node_id( ) ) ;
2307
+ node_b. handle_shutdown ( node_a. get_our_node_id ( ) , & as_shutdown) ;
2324
2308
2325
2309
let events_1 = node_b. get_and_clear_pending_msg_events ( ) ;
2326
2310
assert ! ( events_1. len( ) >= 1 ) ;
@@ -2350,14 +2334,12 @@ pub fn close_channel<'a, 'b, 'c>(
2350
2334
assert ! ( node_a. get_and_clear_pending_msg_events( ) . is_empty( ) ) ;
2351
2335
node_a. handle_closing_signed ( node_b. get_our_node_id ( ) , & closing_signed_b. unwrap ( ) ) ;
2352
2336
2353
- node_b. handle_closing_signed (
2354
- node_a. get_our_node_id ( ) ,
2355
- & get_event_msg ! (
2356
- struct_a,
2357
- MessageSendEvent :: SendClosingSigned ,
2358
- node_b. get_our_node_id( )
2359
- ) ,
2337
+ let as_closing_signed = get_event_msg ! (
2338
+ struct_a,
2339
+ MessageSendEvent :: SendClosingSigned ,
2340
+ node_b. get_our_node_id( )
2360
2341
) ;
2342
+ node_b. handle_closing_signed ( node_a. get_our_node_id ( ) , & as_closing_signed) ;
2361
2343
assert_eq ! ( broadcaster_b. txn_broadcasted. lock( ) . unwrap( ) . len( ) , 1 ) ;
2362
2344
tx_b = broadcaster_b. txn_broadcasted . lock ( ) . unwrap ( ) . remove ( 0 ) ;
2363
2345
let ( bs_update, closing_signed_b) =
@@ -2372,16 +2354,14 @@ pub fn close_channel<'a, 'b, 'c>(
2372
2354
} else {
2373
2355
let closing_signed_a =
2374
2356
get_event_msg ! ( struct_a, MessageSendEvent :: SendClosingSigned , node_b. get_our_node_id( ) ) ;
2375
-
2376
2357
node_b. handle_closing_signed ( node_a. get_our_node_id ( ) , & closing_signed_a) ;
2377
- node_a. handle_closing_signed (
2378
- node_b. get_our_node_id ( ) ,
2379
- & get_event_msg ! (
2380
- struct_b,
2381
- MessageSendEvent :: SendClosingSigned ,
2382
- node_a. get_our_node_id( )
2383
- ) ,
2358
+
2359
+ let closing_signed_b =get_event_msg ! (
2360
+ struct_b,
2361
+ MessageSendEvent :: SendClosingSigned ,
2362
+ node_a. get_our_node_id( )
2384
2363
) ;
2364
+ node_a. handle_closing_signed ( node_b. get_our_node_id ( ) , & closing_signed_b) ;
2385
2365
2386
2366
assert_eq ! ( broadcaster_a. txn_broadcasted. lock( ) . unwrap( ) . len( ) , 1 ) ;
2387
2367
tx_a = broadcaster_a. txn_broadcasted . lock ( ) . unwrap ( ) . remove ( 0 ) ;
0 commit comments