chore: peer-discovery not using peer-info

BREAKING CHANGE: peer event emitted with id and multiaddrs properties instead of peer-info

package.json

@@ -45,8 +45,7 @@
     "debug": "^4.1.1",
     "multiaddr": "^7.1.0",
     "multicast-dns": "^7.2.0",
-    "peer-id": "~0.13.3",
-    "peer-info": "~0.17.0"
+    "peer-id": "~0.13.3"
   },
   "contributors": [
     "David Dias <[email protected]>",

src/compat/index.js

@@ -7,10 +7,11 @@ const Responder = require('./responder')
 const Querier = require('./querier')
 
 class GoMulticastDNS extends EE {
-  constructor (peerInfo) {
+  constructor (peerId, multiaddrs) {
     super()
     this._started = false
-    this._peerInfo = peerInfo
+    this._peerId = peerId
+    this._multiaddrs = multiaddrs
     this._onPeer = this._onPeer.bind(this)
   }
 
@@ -20,8 +21,8 @@ class GoMulticastDNS extends EE {
     }
 
     this._started = true
-    this._responder = new Responder(this._peerInfo)
-    this._querier = new Querier(this._peerInfo.id)
+    this._responder = new Responder(this._peerId, this._multiaddrs)
+    this._querier = new Querier(this._peerId)
 
     this._querier.on('peer', this._onPeer)
 

src/compat/querier.js

@@ -3,7 +3,6 @@
 const EE = require('events')
 const MDNS = require('multicast-dns')
 const Multiaddr = require('multiaddr')
-const PeerInfo = require('peer-info')
 const PeerId = require('peer-id')
 const debug = require('debug')
 const log = debug('libp2p:mdns:compat:querier')
@@ -13,9 +12,11 @@ const { SERVICE_TAG_LOCAL, MULTICAST_IP, MULTICAST_PORT } = require('./constants
 class Querier extends EE {
   constructor (peerId, options) {
     super()
+
     if (!peerId) {
       throw new Error('missing peerId parameter')
     }
+
     options = options || {}
     this._peerIdStr = peerId.toB58String()
     // Re-query every 60s, in leu of network change detection
@@ -57,7 +58,7 @@ class Querier extends EE {
     })
   }
 
-  async _onResponse (event, info) {
+  _onResponse (event, info) {
     const answers = event.answers || []
     const ptrRecord = answers.find(a => a.type === 'PTR' && a.name === SERVICE_TAG_LOCAL)
 
@@ -87,13 +88,6 @@ class Querier extends EE {
       return log('failed to create peer ID from TXT record data', peerIdStr, err)
     }
 
-    let peerInfo
-    try {
-      peerInfo = await PeerInfo.create(peerId)
-    } catch (err) {
-      return log.error('failed to create peer info from peer ID', peerId, err)
-    }
-
     const srvRecord = answers.find(a => a.type === 'SRV')
     if (!srvRecord) return log('missing SRV record in response')
 
@@ -115,8 +109,10 @@ class Querier extends EE {
         return addrs
       }, [])
 
-    multiaddrs.forEach(addr => peerInfo.multiaddrs.add(addr))
-    this.emit('peer', peerInfo)
+    this.emit('peer', {
+      id: peerId,
+      multiaddrs
+    })
   }
 
   stop () {

src/compat/responder.js

@@ -6,13 +6,14 @@ const log = require('debug')('libp2p:mdns:compat:responder')
 const { SERVICE_TAG_LOCAL } = require('./constants')
 
 class Responder {
-  constructor (peerInfo) {
-    if (!peerInfo) {
-      throw new Error('missing peerInfo parameter')
+  constructor (peerId, multiaddrs) {
+    if (!peerId) {
+      throw new Error('missing peerId parameter')
     }
 
-    this._peerInfo = peerInfo
-    this._peerIdStr = peerInfo.id.toB58String()
+    this._peerId = peerId
+    this._peerIdStr = peerId.toB58String()
+    this._multiaddrs = multiaddrs
     this._onQuery = this._onQuery.bind(this)
   }
 
@@ -22,7 +23,7 @@ class Responder {
   }
 
   _onQuery (event, info) {
-    const addresses = this._peerInfo.multiaddrs.toArray().map(ma => ma.toOptions())
+    const addresses = this._multiaddrs.map(ma => ma.toOptions())
     // Only announce TCP for now
     if (!addresses.length) return
 

src/index.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const multicastDNS = require('multicast-dns')
-const EventEmitter = require('events').EventEmitter
+const { EventEmitter } = require('events')
 const debug = require('debug')
 const log = debug('libp2p:mdns')
 const query = require('./query')
@@ -10,20 +10,22 @@ const GoMulticastDNS = require('./compat')
 class MulticastDNS extends EventEmitter {
   constructor (options = {}) {
     super()
-    if (!options.peerInfo) {
-      throw new Error('needs a PeerInfo to work')
+
+    if (!options.peerId) {
+      throw new Error('needs own PeerId to work')
     }
 
     this.broadcast = options.broadcast !== false
     this.interval = options.interval || (1e3 * 10)
     this.serviceTag = options.serviceTag || 'ipfs.local'
     this.port = options.port || 5353
-    this.peerInfo = options.peerInfo
+    this.peerId = options.peerId
+    this.peerMultiaddrs = options.multiaddrs || []
     this._queryInterval = null
     this._onPeer = this._onPeer.bind(this)
 
     if (options.compat !== false) {
-      this._goMdns = new GoMulticastDNS(options.peerInfo, {
+      this._goMdns = new GoMulticastDNS(options.peerId, this.peerMultiaddrs, {
         queryPeriod: options.compatQueryPeriod,
         queryInterval: options.compatQueryInterval
       })
@@ -51,12 +53,12 @@ class MulticastDNS extends EventEmitter {
   }
 
   _onMdnsQuery (event) {
-    query.gotQuery(event, this.mdns, this.peerInfo, this.serviceTag, this.broadcast)
+    query.gotQuery(event, this.mdns, this.peerId, this.peerMultiaddrs, this.serviceTag, this.broadcast)
   }
 
   async _onMdnsResponse (event) {
     try {
-      const foundPeer = await query.gotResponse(event, this.peerInfo, this.serviceTag)
+      const foundPeer = await query.gotResponse(event, this.peerId, this.serviceTag)
 
       if (foundPeer) {
         this.emit('peer', foundPeer)

src/query.js

@@ -1,6 +1,5 @@
 'use strict'
 
-const Peer = require('peer-info')
 const os = require('os')
 const debug = require('debug')
 const log = debug('libp2p:mdns')
@@ -26,7 +25,7 @@ module.exports = {
     return setInterval(query, interval)
   },
 
-  gotResponse: async function (rsp, peerInfo, serviceTag) {
+  gotResponse: function (rsp, localPeerId, serviceTag) {
     if (!rsp.answers) { return }
 
     const answers = {
@@ -57,33 +56,37 @@ module.exports = {
     const multiaddrs = []
 
     answers.a.forEach((a) => {
-      multiaddrs.push(new Multiaddr('/ip4/' + a.data + '/tcp/' + port))
+      const ma = new Multiaddr('/ip4/' + a.data + '/tcp/' + port)
+
+      if (!multiaddrs.some((m) => m.equals(ma))) {
+        multiaddrs.push(ma)
+      }
     })
+
     answers.aaaa.forEach((a) => {
-      multiaddrs.push(new Multiaddr('/ip6/' + a.data + '/tcp/' + port))
+      const ma = new Multiaddr('/ip6/' + a.data + '/tcp/' + port)
+
+      if (!multiaddrs.some((m) => m.equals(ma))) {
+        multiaddrs.push(ma)
+      }
     })
 
-    if (peerInfo.id.toB58String() === b58Id) {
+    if (localPeerId.toB58String() === b58Id) {
       return // replied to myself, ignore
     }
 
     log('peer found -', b58Id)
 
-    const peerId = Id.createFromB58String(b58Id)
-
-    try {
-      const peerFound = await Peer.create(peerId)
-      multiaddrs.forEach((addr) => peerFound.multiaddrs.add(addr))
-      return peerFound
-    } catch (err) {
-      log.error('Error creating PeerInfo from new found peer', err)
+    return {
+      id: Id.createFromB58String(b58Id),
+      multiaddrs
     }
   },
 
-  gotQuery: function (qry, mdns, peerInfo, serviceTag, broadcast) {
+  gotQuery: function (qry, mdns, peerId, multiaddrs, serviceTag, broadcast) {
     if (!broadcast) { return }
 
-    const addresses = peerInfo.multiaddrs.toArray().map(ma => ma.toOptions())
+    const addresses = multiaddrs.map(ma => ma.toOptions())
     // Only announce TCP for now
     if (addresses.length === 0) { return }
 
@@ -95,14 +98,14 @@ module.exports = {
         type: 'PTR',
         class: 'IN',
         ttl: 120,
-        data: peerInfo.id.toB58String() + '.' + serviceTag
+        data: peerId.toB58String() + '.' + serviceTag
       })
 
       // Only announce TCP multiaddrs for now
       const port = addresses[0].port
 
       answers.push({
-        name: peerInfo.id.toB58String() + '.' + serviceTag,
+        name: peerId.toB58String() + '.' + serviceTag,
         type: 'SRV',
         class: 'IN',
         ttl: 120,
@@ -115,11 +118,11 @@ module.exports = {
       })
 
       answers.push({
-        name: peerInfo.id.toB58String() + '.' + serviceTag,
+        name: peerId.toB58String() + '.' + serviceTag,
         type: 'TXT',
         class: 'IN',
         ttl: 120,
-        data: peerInfo.id.toB58String()
+        data: peerId.toB58String()
       })
 
       addresses.forEach((addr) => {

test/compat/go-multicast-dns.spec.js

@@ -5,38 +5,36 @@ const chai = require('chai')
 const dirtyChai = require('dirty-chai')
 const expect = chai.expect
 chai.use(dirtyChai)
-const PeerInfo = require('peer-info')
+
+const multiaddr = require('multiaddr')
+const PeerId = require('peer-id')
 const pDefer = require('p-defer')
 
 const GoMulticastDNS = require('../../src/compat')
 
 describe('GoMulticastDNS', () => {
   const peerAddrs = [
-    '/ip4/127.0.0.1/tcp/20001',
-    '/ip4/127.0.0.1/tcp/20002'
+    multiaddr('/ip4/127.0.0.1/tcp/20001'),
+    multiaddr('/ip4/127.0.0.1/tcp/20002')
   ]
-  let peerInfos
+  let peerIds
 
   before(async () => {
-    peerInfos = await Promise.all([
-      PeerInfo.create(),
-      PeerInfo.create()
+    peerIds = await Promise.all([
+      PeerId.create(),
+      PeerId.create()
     ])
-
-    peerInfos.forEach((peer, index) => {
-      peer.multiaddrs.add(peerAddrs[index])
-    })
   })
 
   it('should start and stop', async () => {
-    const mdns = new GoMulticastDNS(peerInfos[0])
+    const mdns = new GoMulticastDNS(peerIds[0], [peerAddrs[0]])
 
     await mdns.start()
     return mdns.stop()
   })
 
   it('should ignore multiple start calls', async () => {
-    const mdns = new GoMulticastDNS(peerInfos[0])
+    const mdns = new GoMulticastDNS(peerIds[0], [peerAddrs[0]])
 
     await mdns.start()
     await mdns.start()
@@ -45,18 +43,19 @@ describe('GoMulticastDNS', () => {
   })
 
   it('should ignore unnecessary stop calls', async () => {
-    const mdns = new GoMulticastDNS(peerInfos[0])
+    const mdns = new GoMulticastDNS(peerIds[0], [peerAddrs[0]])
     await mdns.stop()
   })
 
   it('should emit peer info when peer is discovered', async () => {
-    const mdnsA = new GoMulticastDNS(peerInfos[0])
-    const mdnsB = new GoMulticastDNS(peerInfos[1])
+    const mdnsA = new GoMulticastDNS(peerIds[0], [peerAddrs[0]])
+    const mdnsB = new GoMulticastDNS(peerIds[1], [peerAddrs[1]])
     const defer = pDefer()
 
-    mdnsA.on('peer', info => {
-      if (!info.id.isEqual(peerInfos[1].id)) return
-      expect(info.multiaddrs.has(peerAddrs[1])).to.be.true()
+    mdnsA.on('peer', ({ id, multiaddrs }) => {
+      if (!id.isEqual(peerIds[1])) return
+
+      expect(multiaddrs.some((m) => m.equals(peerAddrs[1]))).to.be.true()
       defer.resolve()
     })