chore: initial analsys start

apps/peer_exchange_tester/peer_exchange_tester.nim

@@ -1,39 +1,55 @@
 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"
  elif len(switch.connectedPeers(Direction.In)) > 0:
  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()