v0 sniffer

cryptarchia_sniffer.nim

import
  chronos,
  libp2p,
  libp2p/protocols/pubsub/rpc/messages,
  libp2p/crypto/crypto,
  libp2p/crypto/ed25519/ed25519

proc main() {.async.} =
  let
    rng = newRng()
    privKey = PrivateKey.random(PKScheme.Ed25519, rng[]).expect("a key")
    local = @[MultiAddress.init("/ip4/0.0.0.0/udp/0/quic-v1").expect("valid addr")]
    switch = SwitchBuilder
      .new()
      .withRng(rng)
      .withPrivateKey(privKey)
      .withQuicTransport()
      .withAddresses(local)
      .build()

    gossip = GossipSub.init(switch = switch, triggerSelf = true)

  proc printer(topic: string, message: Message): Future[ValidationResult] {.async.} =
    echo topic, ": ", message
    ValidationResult.Accept

  gossip.addValidator(["/cryptarchia/proto", "mantle", "da"], printer)

  gossip.subscribe("/cryptarchia/proto", nil)
  gossip.subscribe("mantle", nil)
  gossip.subscribe("da", nil)

  switch.mount(gossip)
  await switch.start()

  let
    remote = MultiAddress.init("/ip4/0.0.0.0/udp/3000/quic-v1").expect("valid id")
    remoteId = await switch.connect(remote, allowUnknownPeerId = true)
  echo "Connected to ", remoteId

  await waitSignal(SIGINT) or waitSignal(SIGTERM)

waitFor(main())