From 1193b69d6cfc8ec203d74489f67c49922a59c204 Mon Sep 17 00:00:00 2001 From: Dean Eigenmann <7621705+decanus@users.noreply.github.com> Date: Fri, 20 Nov 2020 14:59:29 +0100 Subject: [PATCH] enhancement/cleanup-warnings (#290) --- tests/v2/test_message_store.nim | 2 +- tests/v2/test_waku_filter.nim | 4 +--- tests/v2/test_waku_store.nim | 4 ---- tests/v2/test_wakunode.nim | 2 +- tests/v2/utils.nim | 5 +---- waku/v2/node/wakunode2.nim | 4 ++-- waku/v2/protocol/waku_store.nim | 2 +- waku/v2/protocol/waku_swap.nim | 4 ++-- 8 files changed, 9 insertions(+), 18 deletions(-) diff --git a/tests/v2/test_message_store.nim b/tests/v2/test_message_store.nim index 741c40f3c..a2072159b 100644 --- a/tests/v2/test_message_store.nim +++ b/tests/v2/test_message_store.nim @@ -3,7 +3,7 @@ import std/[unittest, options, tables, sets], chronos, chronicles, ../../waku/v2/node/message_store, - ../test_helpers, ./utils, + ./utils, ../../waku/v2/waku_types suite "Message Store": diff --git a/tests/v2/test_waku_filter.nim b/tests/v2/test_waku_filter.nim index 01ac7a9b2..11ab325db 100644 --- a/tests/v2/test_waku_filter.nim +++ b/tests/v2/test_waku_filter.nim @@ -8,9 +8,7 @@ import libp2p/stream/[bufferstream, connection], libp2p/crypto/crypto, libp2p/multistream, - libp2p/transports/transport, - libp2p/transports/tcptransport, - ../../waku/v2/protocol/[waku_relay, waku_filter, message_notifier], + ../../waku/v2/protocol/[waku_filter, message_notifier], ../../waku/v2/waku_types, ../test_helpers, ./utils diff --git a/tests/v2/test_waku_store.nim b/tests/v2/test_waku_store.nim index 840972362..06ac20e44 100644 --- a/tests/v2/test_waku_store.nim +++ b/tests/v2/test_waku_store.nim @@ -8,15 +8,11 @@ import libp2p/stream/[bufferstream, connection], libp2p/crypto/crypto, libp2p/protocols/pubsub/rpc/message, - libp2p/multistream, - libp2p/transports/transport, - libp2p/transports/tcptransport, ../../waku/v2/protocol/[waku_store, message_notifier], ../../waku/v2/node/message_store, ../test_helpers, ./utils, ../../waku/v2/waku_types - procSuite "Waku Store": asyncTest "handle query": let diff --git a/tests/v2/test_wakunode.nim b/tests/v2/test_wakunode.nim index 611efb70c..c412467bf 100644 --- a/tests/v2/test_wakunode.nim +++ b/tests/v2/test_wakunode.nim @@ -112,7 +112,7 @@ procSuite "WakuNode": await sleepAsync(2000.millis) # Connect peers by dialing from node2 to node1 - let conn = await node2.switch.dial(node1.peerInfo, WakuRelayCodec) + let conn = await node2.switch.dial(node1.peerInfo.peerId, node1.peerInfo.addrs, WakuRelayCodec) # We need to sleep to allow the subscription to go through info "Going to sleep to allow subscribe to go through" diff --git a/tests/v2/utils.nim b/tests/v2/utils.nim index 9ec2740e3..f4a7bee5b 100644 --- a/tests/v2/utils.nim +++ b/tests/v2/utils.nim @@ -7,11 +7,8 @@ import random import chronos import libp2p/[standard_setup, protocols/pubsub/pubsub, - protocols/pubsub/floodsub, - protocols/pubsub/gossipsub, protocols/secure/secure] -import ../../waku/v2/protocol/waku_relay, - ../../waku/v2/waku_types +import ../../waku/v2/waku_types export standard_setup diff --git a/waku/v2/node/wakunode2.nim b/waku/v2/node/wakunode2.nim index d1041336d..bae6ca588 100644 --- a/waku/v2/node/wakunode2.nim +++ b/waku/v2/node/wakunode2.nim @@ -312,7 +312,7 @@ proc dialPeer*(n: WakuNode, address: string) {.async.} = # TODO Keep track of conn and connected state somewhere (WakuRelay?) #p.conn = await p.switch.dial(remotePeer, WakuRelayCodec) #p.connected = true - discard await n.switch.dial(remotePeer, WakuRelayCodec) + discard await n.switch.dial(remotePeer.peerId, remotePeer.addrs, WakuRelayCodec) info "Post switch dial" proc setStorePeer*(n: WakuNode, address: string) = @@ -346,7 +346,7 @@ proc connectToNodes*(n: WakuNode, nodes: seq[string]) {.async.} = proc connectToNodes*(n: WakuNode, nodes: seq[PeerInfo]) {.async.} = for peerInfo in nodes: info "connectToNodes", peer = peerInfo - discard await n.switch.dial(peerInfo, WakuRelayCodec) + discard await n.switch.dial(peerInfo.peerId, peerInfo.addrs, WakuRelayCodec) # The issue seems to be around peers not being fully connected when # trying to subscribe. So what we do is sleep to guarantee nodes are diff --git a/waku/v2/protocol/waku_store.nim b/waku/v2/protocol/waku_store.nim index 5b4026abb..f672f64d9 100644 --- a/waku/v2/protocol/waku_store.nim +++ b/waku/v2/protocol/waku_store.nim @@ -1,5 +1,5 @@ import - std/[tables, sequtils, future, algorithm, options], + std/[tables, sequtils, algorithm, options], bearssl, chronos, chronicles, metrics, stew/[results,byteutils], libp2p/switch, diff --git a/waku/v2/protocol/waku_swap.nim b/waku/v2/protocol/waku_swap.nim index a0f64063c..0676ab263 100644 --- a/waku/v2/protocol/waku_swap.nim +++ b/waku/v2/protocol/waku_swap.nim @@ -22,9 +22,9 @@ ## import - std/[tables, sequtils, future, algorithm, options], + std/[tables, options], bearssl, - chronos, chronicles, metrics, stew/[results,byteutils], + chronos, chronicles, metrics, stew/results, libp2p/switch, libp2p/crypto/crypto, libp2p/protocols/protocol,