3
3
4
4
use chain:: chaininterface;
5
5
use chain:: transaction:: OutPoint ;
6
- use chain:: keysinterface:: KeysInterface ;
7
6
use ln:: channelmanager:: { ChannelManager , ChannelManagerReadArgs , RAACommitmentOrder , PaymentPreimage , PaymentHash , PaymentSecret , PaymentSendFailure } ;
8
7
use ln:: channelmonitor:: { ChannelMonitor , ManyChannelMonitor } ;
9
8
use routing:: router:: { Route , get_route} ;
@@ -29,7 +28,6 @@ use bitcoin::hashes::sha256::Hash as Sha256;
29
28
use bitcoin:: hashes:: Hash ;
30
29
use bitcoin:: hash_types:: BlockHash ;
31
30
32
- use bitcoin:: secp256k1:: Secp256k1 ;
33
31
use bitcoin:: secp256k1:: key:: PublicKey ;
34
32
35
33
use rand:: { thread_rng, Rng } ;
@@ -84,7 +82,6 @@ pub struct Node<'a, 'b: 'a, 'c: 'b> {
84
82
pub keys_manager : & ' b test_utils:: TestKeysInterface ,
85
83
pub node : & ' a ChannelManager < EnforcingChannelKeys , & ' b TestChannelMonitor < ' c > , & ' c test_utils:: TestBroadcaster , & ' b test_utils:: TestKeysInterface , & ' c test_utils:: TestFeeEstimator > ,
86
84
pub net_graph_msg_handler : NetGraphMsgHandler ,
87
- pub our_node_id : PublicKey ,
88
85
pub node_seed : [ u8 ; 32 ] ,
89
86
pub network_payment_count : Rc < RefCell < u8 > > ,
90
87
pub network_chan_count : Rc < RefCell < u32 > > ,
@@ -955,7 +952,7 @@ pub const TEST_FINAL_CLTV: u32 = 32;
955
952
pub fn route_payment < ' a , ' b , ' c > ( origin_node : & Node < ' a , ' b , ' c > , expected_route : & [ & Node < ' a , ' b , ' c > ] , recv_value : u64 ) -> ( PaymentPreimage , PaymentHash ) {
956
953
let net_graph_msg_handler = & origin_node. net_graph_msg_handler ;
957
954
let logger = Arc :: new ( test_utils:: TestLogger :: new ( ) ) ;
958
- let route = get_route ( & origin_node. our_node_id , net_graph_msg_handler, & expected_route. last ( ) . unwrap ( ) . node . get_our_node_id ( ) , None , & Vec :: new ( ) , recv_value, TEST_FINAL_CLTV , logger. clone ( ) ) . unwrap ( ) ;
955
+ let route = get_route ( & origin_node. node . get_our_node_id ( ) , net_graph_msg_handler, & expected_route. last ( ) . unwrap ( ) . node . get_our_node_id ( ) , None , & Vec :: new ( ) , recv_value, TEST_FINAL_CLTV , logger. clone ( ) ) . unwrap ( ) ;
959
956
assert_eq ! ( route. paths. len( ) , 1 ) ;
960
957
assert_eq ! ( route. paths[ 0 ] . len( ) , expected_route. len( ) ) ;
961
958
for ( node, hop) in expected_route. iter ( ) . zip ( route. paths [ 0 ] . iter ( ) ) {
@@ -968,7 +965,7 @@ pub fn route_payment<'a, 'b, 'c>(origin_node: &Node<'a, 'b, 'c>, expected_route:
968
965
pub fn route_over_limit < ' a , ' b , ' c > ( origin_node : & Node < ' a , ' b , ' c > , expected_route : & [ & Node < ' a , ' b , ' c > ] , recv_value : u64 ) {
969
966
let logger = Arc :: new ( test_utils:: TestLogger :: new ( ) ) ;
970
967
let net_graph_msg_handler = & origin_node. net_graph_msg_handler ;
971
- let route = get_route ( & origin_node. our_node_id , net_graph_msg_handler, & expected_route. last ( ) . unwrap ( ) . node . get_our_node_id ( ) , None , & Vec :: new ( ) , recv_value, TEST_FINAL_CLTV , logger. clone ( ) ) . unwrap ( ) ;
968
+ let route = get_route ( & origin_node. node . get_our_node_id ( ) , net_graph_msg_handler, & expected_route. last ( ) . unwrap ( ) . node . get_our_node_id ( ) , None , & Vec :: new ( ) , recv_value, TEST_FINAL_CLTV , logger. clone ( ) ) . unwrap ( ) ;
972
969
assert_eq ! ( route. paths. len( ) , 1 ) ;
973
970
assert_eq ! ( route. paths[ 0 ] . len( ) , expected_route. len( ) ) ;
974
971
for ( node, hop) in expected_route. iter ( ) . zip ( route. paths [ 0 ] . iter ( ) ) {
@@ -1101,7 +1098,6 @@ pub fn create_node_chanmgrs<'a, 'b>(node_count: usize, cfgs: &'a Vec<NodeCfg<'b>
1101
1098
}
1102
1099
1103
1100
pub fn create_network < ' a , ' b : ' a , ' c : ' b > ( node_count : usize , cfgs : & ' b Vec < NodeCfg < ' c > > , chan_mgrs : & ' a Vec < ChannelManager < EnforcingChannelKeys , & ' b TestChannelMonitor < ' c > , & ' c test_utils:: TestBroadcaster , & ' b test_utils:: TestKeysInterface , & ' c test_utils:: TestFeeEstimator > > ) -> Vec < Node < ' a , ' b , ' c > > {
1104
- let secp_ctx = Secp256k1 :: new ( ) ;
1105
1101
let mut nodes = Vec :: new ( ) ;
1106
1102
let chan_count = Rc :: new ( RefCell :: new ( 0 ) ) ;
1107
1103
let payment_count = Rc :: new ( RefCell :: new ( 0 ) ) ;
@@ -1112,11 +1108,10 @@ pub fn create_network<'a, 'b: 'a, 'c: 'b>(node_count: usize, cfgs: &'b Vec<NodeC
1112
1108
block_notifier. register_listener ( & chan_mgrs[ i] as & chaininterface:: ChainListener ) ;
1113
1109
let net_graph_msg_handler = NetGraphMsgHandler :: new ( cfgs[ i] . chain_monitor . clone ( ) , cfgs[ i] . logger . clone ( ) as Arc < Logger > ) ;
1114
1110
nodes. push ( Node { chain_monitor : cfgs[ i] . chain_monitor . clone ( ) , block_notifier,
1115
- tx_broadcaster : cfgs[ i] . tx_broadcaster , chan_monitor : & cfgs[ i] . chan_monitor ,
1116
- keys_manager : & cfgs[ i] . keys_manager , node : & chan_mgrs[ i] , net_graph_msg_handler,
1117
- node_seed : cfgs[ i] . node_seed , network_chan_count : chan_count. clone ( ) ,
1118
- network_payment_count : payment_count. clone ( ) , logger : cfgs[ i] . logger . clone ( ) ,
1119
- our_node_id : PublicKey :: from_secret_key ( & secp_ctx, & cfgs[ i] . keys_manager . get_node_secret ( ) ) ,
1111
+ tx_broadcaster : cfgs[ i] . tx_broadcaster , chan_monitor : & cfgs[ i] . chan_monitor ,
1112
+ keys_manager : & cfgs[ i] . keys_manager , node : & chan_mgrs[ i] , net_graph_msg_handler,
1113
+ node_seed : cfgs[ i] . node_seed , network_chan_count : chan_count. clone ( ) ,
1114
+ network_payment_count : payment_count. clone ( ) , logger : cfgs[ i] . logger . clone ( ) ,
1120
1115
} )
1121
1116
}
1122
1117
0 commit comments