libp2p protocol setup

libp2p-protocol-setup.js

const Libp2p = require('libp2p')
const Mplex = require('libp2p-mplex')
const KickoffProtocol = require('./kickoff-protocol')

const node = await Libp2p.create({
  modules: {
    // … other required modules
    streamMuxer: [ Mplex ],
  }
})

node.handle(KickoffProtocol.PROTOCOL, KickoffProtocol.handler)
await node.start()

// Send message to other peers (connected) using the protocol
node.peerStore.peers.forEach(async (peer) => {
  if (!peer.protocols.includes(KickoffProtocol.PROTOCOL)) return
    const connection = node.connectionManager.get(peer.id)
    if (!connection) return

    try {
      const { stream } = await connection.newStream([KickoffProtocol.PROTOCOL])
      await KickoffProtocol.send(message, stream)
    } catch (err) {
      console.error('Could not negotiate kickoff protocol stream with peer', err)
    }
})