使用MDN发现对等点的配置

我正在努力让这个例子起作用。它应该创建两个支持MDN的节点。Mdns应该每秒宣布一个对等点,每个对等点被设置为在找到对等点后打印一条语句。

运行它时,控制台输出只是空的。它打印出了我担心的一些垃圾错误: (node:51841) ExperimentalWarning: Readable[Symbol.asyncIterator] is an experimental feature. This feature could change at any time

如何启用调试日志,以便尝试了解引擎盖下发生了什么? 我想验证MDN公告包是否已发出,是否可能已收到。

或者,我尝试使用引导模块在wan对等点上开始,尽管我预计它会慢得多,因此我更喜欢使用MDN。

我试图添加各种配置和模块,但没有取得多大成功。如果我只想在dht上发布一些数据,我不清楚是否需要使用八卦模块。诸如此类。

感谢您的帮助。

const Libp2p = require('libp2p')
const MulticastDNS = require('libp2p-mdns')
const KadDHT = require('libp2p-kad-dht')
const Bootstrap = require('libp2p-bootstrap')
const TCP = require('libp2p-tcp')
const Mplex = require('libp2p-mplex')
const { NOISE } = require('libp2p-noise')
const GossipSub = require('libp2p-gossipsub')
const { FaultTolerance } = require('libp2p/src/transport-manager')

const CID = require('cids')
const all = require('it-all')
const delay = require('delay')

const bootstrapers = [
  '/ip4/104.131.131.82/tcp/4001/p2p/QmaCpDMGvV2BGHeYERUEnRQAwe3N8SzbUtfsmvsqQLuvuJ',
  '/ip4/104.236.176.52/tcp/4001/p2p/QmSoLnSGccFuZQJzRadHn95W2CrSFmZuTdDWP8HXaHca9z',
  '/ip4/104.236.179.241/tcp/4001/p2p/QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM',
  '/ip4/162.243.248.213/tcp/4001/p2p/QmSoLueR4xBeUbY9WZ9xGUUxunbKWcrNFTDAadQJmocnWm',
  '/ip4/128.199.219.111/tcp/4001/p2p/QmSoLSafTMBsPKadTEgaXctDQVcqN88CNLHXMkTNwMKPnu',
  '/ip4/104.236.76.40/tcp/4001/p2p/QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64',
  '/ip4/178.62.158.247/tcp/4001/p2p/QmSoLer265NRgSp2LA3dPaeykiS1J6DifTC88f5uVQKNAd',
  '/ip4/178.62.61.185/tcp/4001/p2p/QmSoLMeWqB7YGVLJN3pNLQpmmEk35v6wYtsMGLzSr5QBU3',
  '/ip4/104.236.151.122/tcp/4001/p2p/QmSoLju6m7xTh3DuokvT3886QRYqxAzb1kShaanJgW36yx'
]

const createNode = () => {
  return Libp2p.create({
    addresses: {
      listen: ['/ip4/0.0.0.0/tcp/0']
    },
    modules: {
      transport: [ TCP ],
      streamMuxer: [ Mplex ],
      connEncryption: [ NOISE ],
      // peerDiscovery: [ MulticastDNS ],
      // peerDiscovery: [ MulticastDNS ],
      peerDiscovery: [ Bootstrap, MulticastDNS ],
      dht: KadDHT,
      pubsub: GossipSub
    },
    transportManager: {
      faultTolerance: FaultTolerance.NO_FATAL
    },
    config: {
      peerDiscovery: {
        autoDial: true,
        [MulticastDNS.tag]: {
          broadcast: true,
          interval: 1000,
          enabled: true
        },
        [Bootstrap.tag]: {
          interval: 1000,
          enabled: true,
          list: bootstrapers
        },
        [GossipSub.tag]: {
          enabled: true,
          emitSelf: true,
          signMessages: true,
          strictSigning: true
        },
        mdns: {
          broadcast: true,
          interval: 1000,
          enabled: true
        },
        bootstrap: {
          interval: 1000,
          enabled: true,
          list: bootstrapers
        },
        pubsub: {
          enabled: true,
          emitSelf: true,
          signMessages: true,
          strictSigning: true
        },
      },
      dht: {
        enabled: true
      }
    }
  })
}

( async () => {

  const [node1, node2] = await Promise.all([
    createNode(),
    createNode()
  ])

  node1.on('peer:discovery', (peer) => console.log('Discovered:', peer.id.toB58String()))
  node2.on('peer:discovery', (peer) => console.log('Discovered:', peer.id.toB58String()))

  await Promise.all([
    node1.start(),
    node2.start()
  ])

  // const cid = new CID('QmTp9VkYvnHyrqKQuFPiuZkiX9gPcqj6x5LJ1rmWuSySnL')
  // await node1.contentRouting.provide(cid)
  // await delay(3000)
  // console.log("looking for providers...")
  // const providers = await all(node2.contentRouting.findProviders(cid, { timeout: 5000 }))
  // console.log('Found provider:', providers[0].id.toB58String())
})()

编辑:发现我可以使用调试环境变量来打印调试语句,尽管我仍然有事件系统的问题。