logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-03-07 05:03:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: initial analsys start

Browse Source
This commit is contained in:
DarshanBPatel 2024-08-09 01:50:00 +05:30
parent 495985254c
commit ff21a7d248
1 changed files with 28 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
apps/peer_exchange_tester/peer_exchange_tester.nim
View File

@ -1,24 +1,23 @@
import random, chronos, chronicles, stew/byteutils, os
import libp2p/peerId
import waku/[waku_peer_exchange, node/peer_manager]
import tests/testlib/wakucore
proc connectToPeer(sw: Switch, peerAddr: string) {.async.} =
let ma = MultiAddress.init(peerAddr).tryGet()
let str = "16Uiu2HAkykgaECHswi3YKJ5dMLbq2kPVCo89fcyTd38UcQD6ej5W"
let peerIdData = cast[seq[byte]](str)
let peerId = PeerId(data: peerIdData)
echo "2) ---------------> trying to connect with peer"
# let peerIdData = cast[seq[byte]](str)
let peerId = PeerId.init(str).tryGet()
await sw.connect(peerId, @[ma])
# discard sw.dial(peerId, @[ma], "/vac/waku/peer-exchange/2.0.0-alpha1")
discard sw.dial(peerId, @[ma], "/vac/waku/peer-exchange/2.0.0-alpha1")
echo "Connected to peer with address: ", peerAddr
proc main() {.async.} =
echo "main started"
let addrs =
"/ip4/178.128.141.171/tcp/30303/16Uiu2HAkykgaECHswi3YKJ5dMLbq2kPVCo89fcyTd38UcQD6ej5W"
let addrs = "/ip4/178.128.141.171/tcp/30303/"
let switch = newStandardSwitch()
discard switch.start()
echo "\n ---------------------------------- switch started ----------------------------------------- \n"
await connectToPeer(switch, addrs)
if len(switch.connectedPeers(Direction.Out)) > 0:
echo "Successfully out connected with Waku test fleet"
@ -26,14 +25,31 @@ proc main() {.async.} =
echo "Successfully in connected with Waku test fleet"
else:
echo "Not connected to any peers"
echo "\n ---------------------------------- connection completed -------------------------------- \n"
let peerManager = PeerManager.new(switch)
let wakuPx = WakuPeerExchange(peerManager: peerManager)
echo "----------------------------------------------------------------------------------------------"
for i in 1 .. 20:
sleep(1000000)
let response = await wakuPx.request(5)
# check how many peerid arn't stale
echo "Seq No :- " & $i & " ---> "
echo $wakuPx.enrCache
sleep(120000)
# let res1 = await wakuPx.request(1)
# echo "\n -------------------------------- response -------------------------------------\n"
# if res1.isOk:
# echo "response count :- " & $res1.get().peerInfos.len
# echo "\n -------------- requested 4 peer through px protocol ------------------------------------\n"
# echo res1
# for i in 1 .. 20:
# echo "Request no :- " & $i & " ------> "
# let res1 = await wakuPx.request(5)
# if res1.get().peerInfos.len == 5:
# echo "It's 5 peers"
# else:
# echo "it isn't 5 peers"
# sleep(300000)
echo "---------------------------- Done ------------------------------- "
when isMainModule:
waitFor main()