From 42e6a5a6bdef5c6c69b91273dd54cfcbbcf5de5d Mon Sep 17 00:00:00 2001
From: DarshanBPatel <darshan@status.im>
Date: Tue, 30 Jul 2024 16:15:14 +0530
Subject: [PATCH] test: connect remote peers

---
 Makefile                                      |  2 +-
 .../peer_exchange_tester.nim                  | 29 ++++++++++++-------
 2 files changed, 20 insertions(+), 11 deletions(-)

diff --git a/Makefile b/Makefile
index 6f53fc7eec..ec28da1f91 100644
--- a/Makefile
+++ b/Makefile
@@ -229,7 +229,7 @@ test/%: | build deps librln
 ################
 ## Waku tools ##
 ################
-.PHONY: tools wakucanary networkmonitor peerexchangetester
+.PHONY: tools wakucanary networkmonitor peer_exchange_tester
 
 tools: networkmonitor wakucanary
 
diff --git a/apps/peer_exchange_tester/peer_exchange_tester.nim b/apps/peer_exchange_tester/peer_exchange_tester.nim
index efc0e0ab26..ff2d9998e0 100644
--- a/apps/peer_exchange_tester/peer_exchange_tester.nim
+++ b/apps/peer_exchange_tester/peer_exchange_tester.nim
@@ -1,15 +1,24 @@
-import
-  std/[options, sequtils, random],
-  chronos, chronicles, stew/byteutils
-  
-import 
-  waku/[waku_peer_exchange, node/peer_manager]
+# import random, strutils, asyncdispatch, chronos, chronicles, stew/byteutils, waku/[waku_peer_exchange, node/peer_manager], tests/testlib/wakucore
+import random, chronos, chronicles, stew/byteutils
+import waku/[waku_peer_exchange, node/peer_manager]
+import tests/testlib/wakucore
+import asyncdispatch as asyncd
 
-# import chronicles, chronos, stew/byteutils, results
-# import waku/[common/logging, node/peer_manager, waku_core, waku_filter_v2/client]
+proc createSwitch(): Switch =
+  let addrs = MultiAddress.init("/ip4/0.0.0.0/tcp/0").tryGet()
+  newStandardSwitch(addrs = addrs)
+
+proc connectToPeer(sw: Switch, peerAddr: string) {.async.} =
+  let ma = MultiAddress.init(peerAddr).tryGet()
+  let str = "16Uiu2HAm2uZtDK3T4zgseP16uGB6s2q2i8zpviLBmXyukjU5BPVT"
+  let peerIdData = str.mapIt(cast[byte](it))
+  let peerId = PeerId(data: peerIdData)
+  let connection = await sw.dial(peerId, @[ma], @["defaultProto"])
 
 proc main() {.async.} =
-  let switch = newStandardSwitch()
+  let addrs = "/ip4/139.99.173.27/tcp/30304"
+  let switch = createSwitch()
+  await switch.connectToPeer(addrs)
   let peerManager = PeerManager.new(switch)
   let wakuPx = WakuPeerExchange(peerManager: peerManager)
 
@@ -24,4 +33,4 @@ proc main() {.async.} =
     echo "Error requesting peers: ", res.error
 
 when isMainModule:
-  waitFor main()
\ No newline at end of file
+  asyncMain(main)