@@ -31,7 +31,7 @@ use crate::routing::test_utils::{add_channel, add_or_update_node};
31
31
use crate :: sign:: { NodeSigner , Recipient } ;
32
32
use crate :: types:: features:: { ChannelFeatures , InitFeatures } ;
33
33
use crate :: util:: ser:: { FixedLengthReader , LengthReadable , Writeable , Writer } ;
34
- use crate :: util:: test_utils;
34
+ use crate :: util:: test_utils:: { TestChainSource , TestKeysInterface , TestLogger , TestNodeSigner } ;
35
35
36
36
use bitcoin:: hex:: FromHex ;
37
37
use bitcoin:: network:: Network ;
@@ -45,35 +45,26 @@ use core::ops::Deref;
45
45
46
46
use crate :: prelude:: * ;
47
47
48
+ type NetGraph = NetworkGraph < Arc < TestLogger > > ;
49
+ type MessageRouter = DefaultMessageRouter < Arc < NetGraph > , Arc < TestLogger > , Arc < TestKeysInterface > > ;
50
+
48
51
struct MessengerNode {
49
52
node_id : PublicKey ,
50
53
privkey : SecretKey ,
51
- entropy_source : Arc < test_utils :: TestKeysInterface > ,
54
+ entropy_source : Arc < TestKeysInterface > ,
52
55
messenger : OnionMessenger <
53
- Arc < test_utils :: TestKeysInterface > ,
54
- Arc < test_utils :: TestNodeSigner > ,
55
- Arc < test_utils :: TestLogger > ,
56
+ Arc < TestKeysInterface > ,
57
+ Arc < TestNodeSigner > ,
58
+ Arc < TestLogger > ,
56
59
Arc < EmptyNodeIdLookUp > ,
57
- Arc <
58
- DefaultMessageRouter <
59
- Arc < NetworkGraph < Arc < test_utils:: TestLogger > > > ,
60
- Arc < test_utils:: TestLogger > ,
61
- Arc < test_utils:: TestKeysInterface > ,
62
- > ,
63
- > ,
60
+ Arc < MessageRouter > ,
64
61
Arc < TestOffersMessageHandler > ,
65
62
Arc < TestAsyncPaymentsMessageHandler > ,
66
63
Arc < TestDNSResolverMessageHandler > ,
67
64
Arc < TestCustomMessageHandler > ,
68
65
> ,
69
66
custom_message_handler : Arc < TestCustomMessageHandler > ,
70
- gossip_sync : Arc <
71
- P2PGossipSync <
72
- Arc < NetworkGraph < Arc < test_utils:: TestLogger > > > ,
73
- Arc < test_utils:: TestChainSource > ,
74
- Arc < test_utils:: TestLogger > ,
75
- > ,
76
- > ,
67
+ gossip_sync : Arc < P2PGossipSync < Arc < NetGraph > , Arc < TestChainSource > , Arc < TestLogger > > > ,
77
68
}
78
69
79
70
impl Drop for MessengerNode {
@@ -278,18 +269,18 @@ impl MessengerCfg {
278
269
}
279
270
280
271
fn create_nodes_using_cfgs ( cfgs : Vec < MessengerCfg > ) -> Vec < MessengerNode > {
281
- let gossip_logger = Arc :: new ( test_utils :: TestLogger :: with_id ( "gossip" . to_string ( ) ) ) ;
272
+ let gossip_logger = Arc :: new ( TestLogger :: with_id ( "gossip" . to_string ( ) ) ) ;
282
273
let network_graph = Arc :: new ( NetworkGraph :: new ( Network :: Testnet , gossip_logger. clone ( ) ) ) ;
283
274
let gossip_sync = Arc :: new ( P2PGossipSync :: new ( network_graph. clone ( ) , None , gossip_logger) ) ;
284
275
285
276
let mut nodes = Vec :: new ( ) ;
286
277
for ( i, cfg) in cfgs. into_iter ( ) . enumerate ( ) {
287
278
let secret_key =
288
279
cfg. secret_override . unwrap_or ( SecretKey :: from_slice ( & [ ( i + 1 ) as u8 ; 32 ] ) . unwrap ( ) ) ;
289
- let logger = Arc :: new ( test_utils :: TestLogger :: with_id ( format ! ( "node {}" , i) ) ) ;
280
+ let logger = Arc :: new ( TestLogger :: with_id ( format ! ( "node {}" , i) ) ) ;
290
281
let seed = [ i as u8 ; 32 ] ;
291
- let entropy_source = Arc :: new ( test_utils :: TestKeysInterface :: new ( & seed, Network :: Testnet ) ) ;
292
- let node_signer = Arc :: new ( test_utils :: TestNodeSigner :: new ( secret_key) ) ;
282
+ let entropy_source = Arc :: new ( TestKeysInterface :: new ( & seed, Network :: Testnet ) ) ;
283
+ let node_signer = Arc :: new ( TestNodeSigner :: new ( secret_key) ) ;
293
284
294
285
let node_id_lookup = Arc :: new ( EmptyNodeIdLookUp { } ) ;
295
286
let message_router =
0 commit comments