From 8089defcada74d35d699e2880e9b27aedbadf3d8 Mon Sep 17 00:00:00 2001 From: al8n Date: Thu, 22 Dec 2022 04:40:06 +1300 Subject: [PATCH] try to fix discv5 test case --- waku-bindings/src/node/mod.rs | 5 +++++ waku-bindings/tests/node.rs | 8 ++++---- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/waku-bindings/src/node/mod.rs b/waku-bindings/src/node/mod.rs index 1af00fc..957ac18 100644 --- a/waku-bindings/src/node/mod.rs +++ b/waku-bindings/src/node/mod.rs @@ -119,6 +119,11 @@ impl WakuNodeHandle { stop_node() } + /// Starts the DiscoveryV5 service to discover and connect to new peers + pub fn discv5_start(&self) -> Result { + discv5::waku_discv5_start() + } + /// Stops the DiscoveryV5 service pub fn discv5_stop(&self) -> Result { discv5::waku_discv5_stop() diff --git a/waku-bindings/tests/node.rs b/waku-bindings/tests/node.rs index 9b8c816..f45ccfe 100644 --- a/waku-bindings/tests/node.rs +++ b/waku-bindings/tests/node.rs @@ -29,17 +29,17 @@ pub fn main() -> Result<(), String> { min_peers_to_publish: None, filter: None, log_level: Some(WakuLogLevel::Error), - discv5: Some(false), + discv5: Some(true), discv5_udp_port: Some(9000), discv5_bootstrap_nodes: Vec::new(), }; let node = waku_new(Some(config))?; - let result = node.discv5_start()?; - println!("Discv5 started: {}", result); - let node = node.start()?; println!("Node peer id: {}", node.peer_id()?); + let result = node.discv5_start()?; + println!("Discv5 started: {}", result); + for node_address in NODES { let address: Multiaddr = node_address.parse().unwrap(); let peer_id = node.add_peer(&address, ProtocolId::Relay)?;