logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-21 15:23:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: finally successfully build app

Browse Source
This commit is contained in:
DarshanBPatel 2024-08-08 03:33:22 +05:30
parent f136ffd53d
commit d56c30338c
1 changed files with 17 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
apps/peer_exchange_tester/peer_exchange_tester.nim
View File

@ -1,10 +1,10 @@
# import random, strutils, asyncdispatch, chronos, chronicles, stew/byteutils, waku/[waku_peer_exchange, node/peer_manager], tests/testlib/wakucore
import random, chronicles, stew/byteutils
import random, chronos, chronicles, stew/byteutils, os
import waku/[waku_peer_exchange, node/peer_manager]
import tests/testlib/wakucore
import asyncdispatch
proc createSwitch(): Switch =
echo "switch created"
let addrs = MultiAddress.init("/ip4/0.0.0.0/tcp/0").tryGet()
return newStandardSwitch(addrs = addrs)
@ -13,18 +13,27 @@ proc connectToPeer(sw: Switch, peerAddr: string) {.async.} =
let str = "16Uiu2HAkykgaECHswi3YKJ5dMLbq2kPVCo89fcyTd38UcQD6ej5W"
let peerIdData = cast[seq[byte]](str)
let peerId = PeerId(data: peerIdData)
await sw.connect(peerId, @[ma])
echo "trying to connect with peer"
# await sw.connect(peerId, @[ma])
# discard sw.dial(peerId, "/vac/waku/peer-exchange/2.0.0-alpha1")
echo "Connected to peer with address: ", peerAddr
proc main() {.async.} =
let addrs = "/dns4/node-01.do-ams3.waku.test.status.im/tcp/30303/p2p"
echo "main started"
let addrs = "/ip4/178.128.141.171/tcp/30303"
let switch = createSwitch()
await connectToPeer(switch, addrs)
let connectedPeers = switch.connectedPeers()
if connectedPeers > 0:
echo "Successfully connected with Waku test fleet"
if len(switch.connectedPeers(Direction.Out)) > 0:
sleep(10000)
echo "Successfully out connected with Waku test fleet"
elif len(switch.connectedPeers(Direction.In)) > 0:
sleep(10000)
echo "Successfully in connected with Waku test fleet"
else:
sleep(10000)
echo "Not connected to any peers"
let peerManager = PeerManager.new(switch)
let wakuPx = WakuPeerExchange(peerManager: peerManager)
when isMainModule:
waitFor main()
waitFor main()