chore: use libp2p 0.28.x

Author: vasco-santos

packages/interface-ipfs-core/src/swarm/addrs.js

@@ -31,15 +31,15 @@ module.exports = (common, options) => {
     after(() => common.clean())
 
     it('should get a list of node addresses', async () => {
-      const peerInfos = await ipfsA.swarm.addrs()
-      expect(peerInfos).to.not.be.empty()
-      expect(peerInfos).to.be.an('array')
+      const peers = await ipfsA.swarm.addrs()
+      expect(peers).to.not.be.empty()
+      expect(peers).to.be.an('array')
 
-      for (const peerInfo of peerInfos) {
-        expect(CID.isCID(new CID(peerInfo.id))).to.be.true()
-        expect(peerInfo).to.have.a.property('addrs').that.is.an('array')
+      for (const peer of peers) {
+        expect(CID.isCID(new CID(peer.id))).to.be.true()
+        expect(peer).to.have.a.property('addrs').that.is.an('array')
 
-        for (const ma of peerInfo.addrs) {
+        for (const ma of peer.addrs) {
           expect(Multiaddr.isMultiaddr(ma)).to.be.true()
         }
       }

packages/ipfs/package-lock.json

@@ -96,7 +96,7 @@
     "hapi-pino": "^6.1.0",
     "hashlru": "^2.3.0",
     "interface-datastore": "^0.8.0",
-    "ipfs-bitswap": "^0.27.1",
+    "ipfs-bitswap": "ipfs/js-ipfs-bitswap#chore/use-libp2p-0.28",
     "ipfs-block": "^0.8.1",
     "ipfs-block-service": "^0.16.0",
     "ipfs-core-utils": "^0.2.0",
@@ -131,21 +131,21 @@
     "iterable-ndjson": "^1.1.0",
     "jsondiffpatch": "^0.4.1",
     "just-safe-set": "^2.1.0",
-    "libp2p": "^0.27.2",
-    "libp2p-bootstrap": "^0.10.3",
+    "libp2p": "libp2p/js-libp2p#0.28.x",
+    "libp2p-bootstrap": "^0.11.0",
     "libp2p-crypto": "^0.17.1",
-    "libp2p-delegated-content-routing": "^0.4.4",
-    "libp2p-delegated-peer-routing": "^0.4.2",
-    "libp2p-floodsub": "^0.20.0",
-    "libp2p-gossipsub": "^0.2.3",
-    "libp2p-kad-dht": "^0.18.3",
+    "libp2p-delegated-content-routing": "^0.5.0",
+    "libp2p-delegated-peer-routing": "^0.5.0",
+    "libp2p-floodsub": "^0.21.0",
+    "libp2p-gossipsub": "^0.4.0",
+    "libp2p-kad-dht": "^0.19.1",
     "libp2p-keychain": "^0.6.0",
-    "libp2p-mdns": "^0.13.1",
+    "libp2p-mdns": "^0.14.1",
     "libp2p-mplex": "^0.9.3",
     "libp2p-record": "^0.7.0",
     "libp2p-secio": "^0.12.2",
     "libp2p-tcp": "^0.14.3",
-    "libp2p-webrtc-star": "^0.17.9",
+    "libp2p-webrtc-star": "^0.18.0",
     "libp2p-websockets": "^0.13.3",
     "mafmt": "^7.0.0",
     "merge-options": "^2.0.0",
@@ -160,7 +160,6 @@
     "p-queue": "^6.1.0",
     "parse-duration": "^0.1.2",
     "peer-id": "^0.13.5",
-    "peer-info": "^0.17.0",
     "pretty-bytes": "^5.3.0",
     "progress": "^2.0.1",
     "protons": "^1.0.1",

packages/ipfs/package.json

@@ -60,7 +60,7 @@ class Daemon {
   }
 }
 
-function getLibp2p ({ libp2pOptions, options, config, peerInfo }) {
+function getLibp2p ({ libp2pOptions, options, config, peerId }) {
   // Attempt to use any of the WebRTC versions available globally
   let electronWebRTC
   let wrtc
@@ -98,7 +98,7 @@ function getLibp2p ({ libp2pOptions, options, config, peerInfo }) {
     }
 
     libp2pOptions.modules.contentRouting = libp2pOptions.modules.contentRouting || []
-    libp2pOptions.modules.contentRouting.push(new DelegatedContentRouter(peerInfo.id, delegatedApiOptions))
+    libp2pOptions.modules.contentRouting.push(new DelegatedContentRouter(peerId, delegatedApiOptions))
 
     libp2pOptions.modules.peerRouting = libp2pOptions.modules.peerRouting || []
     libp2pOptions.modules.peerRouting.push(new DelegatedPeerRouter(delegatedApiOptions))

packages/ipfs/src/cli/daemon.js

@@ -75,10 +75,10 @@ module.exports = ({ libp2p, repo }) => {
         options.maxNumProviders = options.numProviders
       }
 
-      for await (const peerInfo of libp2p._dht.findProviders(key, options)) {
+      for await (const peer of libp2p._dht.findProviders(key, options)) {
         yield {
-          id: peerInfo.id.toB58String(),
-          addrs: peerInfo.multiaddrs.toArray()
+          id: peer.id.toB58String(),
+          addrs: peer.addrs
         }
       }
     },
@@ -94,11 +94,11 @@ module.exports = ({ libp2p, repo }) => {
         peerId = PeerId.createFromCID(peerId)
       }
 
-      const peerInfo = await libp2p._dht.findPeer(peerId)
+      const peer = await libp2p._dht.findPeer(peerId)
 
       return {
-        id: peerInfo.id.toB58String(),
-        addrs: peerInfo.multiaddrs.toArray()
+        id: peer.id.toB58String(),
+        addrs: peer.addrs
       }
     },
 

packages/ipfs/src/core/components/dht.js

@@ -3,9 +3,9 @@
 const pkgversion = require('../../../package.json').version
 const multiaddr = require('multiaddr')
 
-module.exports = ({ peerInfo, libp2p }) => {
+module.exports = ({ peerId, libp2p }) => {
   return async function id () { // eslint-disable-line require-await
-    const id = peerInfo.id.toB58String()
+    const id = peerId.toB58String()
     let addresses = []
 
     if (libp2p) {
@@ -15,7 +15,7 @@ module.exports = ({ peerInfo, libp2p }) => {
 
     return {
       id,
-      publicKey: peerInfo.id.pubKey.bytes.toString('base64'),
+      publicKey: peerId.pubKey.bytes.toString('base64'),
       addresses: addresses
         .map(ma => {
           const str = ma.toString()

packages/ipfs/src/core/components/id.js

@@ -2,7 +2,6 @@
 
 const log = require('debug')('ipfs:components:init')
 const PeerId = require('peer-id')
-const PeerInfo = require('peer-info')
 const mergeOptions = require('merge-options')
 const getDefaultConfig = require('../runtime/config-nodejs.js')
 const createRepo = require('../runtime/repo-nodejs')
@@ -79,7 +78,6 @@ module.exports = ({
       : await initNewRepo(repo, { ...options, print })
 
     log('peer created')
-    const peerInfo = new PeerInfo(peerId)
     const blockService = new BlockService(repo)
     const ipld = new Ipld(getDefaultIpldOptions(blockService, constructorOptions.ipld, log))
 
@@ -141,7 +139,7 @@ module.exports = ({
       // Setup the offline routing for IPNS.
       // This is primarily used for offline ipns modifications, such as the initializeKeyspace feature.
       const offlineDatastore = new OfflineDatastore(repo)
-      const ipns = new IPNS(offlineDatastore, repo.datastore, peerInfo, keychain, { pass: options.pass })
+      const ipns = new IPNS(offlineDatastore, repo.datastore, peerId, keychain, { pass: options.pass })
       await ipns.initializeKeyspace(peerId.privKey, emptyDirCid.toString())
     }
 
@@ -157,7 +155,7 @@ module.exports = ({
       ipld,
       keychain,
       object,
-      peerInfo,
+      peerId,
       pin,
       pinManager,
       preload,
@@ -302,7 +300,7 @@ function createApi ({
   ipld,
   keychain,
   object,
-  peerInfo,
+  peerId,
   pin,
   pinManager,
   preload,
@@ -336,7 +334,7 @@ function createApi ({
     dns: Components.dns(),
     files: Components.files({ ipld, block, blockService, repo, preload, options: constructorOptions }),
     get: Components.get({ ipld, preload }),
-    id: Components.id({ peerInfo }),
+    id: Components.id({ peerId }),
     init: async () => { throw new AlreadyInitializedError() }, // eslint-disable-line require-await
     isOnline: Components.isOnline({}),
     key: {
@@ -366,7 +364,7 @@ function createApi ({
       initOptions,
       ipld,
       keychain,
-      peerInfo,
+      peerId,
       pinManager,
       preload,
       print,
@@ -382,7 +380,7 @@ function createApi ({
       addrs: notStarted,
       connect: notStarted,
       disconnect: notStarted,
-      localAddrs: Components.swarm.localAddrs({ peerInfo }),
+      localAddrs: Components.swarm.localAddrs({ multiaddrs: [] }),
       peers: notStarted
     },
     version: Components.version({ repo })

packages/ipfs/src/core/components/init.js

@@ -7,26 +7,27 @@ const PubsubRouters = require('../runtime/libp2p-pubsub-routers-nodejs')
 
 module.exports = ({
   options,
-  peerInfo,
+  peerId,
+  multiaddrs = [],
   repo,
   config
 }) => {
   options = options || {}
   config = config || {}
 
   const { datastore } = repo
-  const libp2pOptions = getLibp2pOptions({ options, config, datastore, peerInfo })
+  const libp2pOptions = getLibp2pOptions({ options, config, datastore, peerId, multiaddrs })
 
   if (typeof options.libp2p === 'function') {
-    return options.libp2p({ libp2pOptions, options, config, datastore, peerInfo })
+    return options.libp2p({ libp2pOptions, options, config, datastore, peerId })
   }
 
   // Required inline to reduce startup time
   const Libp2p = require('libp2p')
   return new Libp2p(mergeOptions(libp2pOptions, get(options, 'libp2p', {})))
 }
 
-function getLibp2pOptions ({ options, config, datastore, peerInfo }) {
+function getLibp2pOptions ({ options, config, datastore, peerId, multiaddrs }) {
   const getPubsubRouter = () => {
     const router = get(config, 'Pubsub.Router') || 'gossipsub'
 
@@ -39,7 +40,7 @@ function getLibp2pOptions ({ options, config, datastore, peerInfo }) {
 
   const libp2pDefaults = {
     datastore,
-    peerInfo,
+    peerId: peerId,
     modules: {}
   }
 
@@ -80,6 +81,9 @@ function getLibp2pOptions ({ options, config, datastore, peerInfo }) {
           get(config, 'Pubsub.Enabled', true))
       }
     },
+    addresses: {
+      listen: multiaddrs
+    },
     connectionManager: get(options, 'connectionManager', {
       maxConnections: get(options, 'config.Swarm.ConnMgr.HighWater',
         get(config, 'Swarm.ConnMgr.HighWater')),

packages/ipfs/src/core/components/libp2p.js

@@ -21,10 +21,10 @@ const { resolvePath } = require('./utils')
  * @param {IPFS} self
  * @returns {Object}
  */
-module.exports = ({ ipns, dag, peerInfo, isOnline, keychain, options: constructorOptions }) => {
+module.exports = ({ ipns, dag, peerId, isOnline, keychain, options: constructorOptions }) => {
   const lookupKey = async keyName => {
     if (keyName === 'self') {
-      return peerInfo.id.privKey
+      return peerId.privKey
     }
 
     try {

packages/ipfs/src/core/components/name/publish.js

@@ -31,7 +31,7 @@ const appendRemainder = async (result, remainder) => {
  * @param {IPFS} self
  * @returns {Object}
  */
-module.exports = ({ dns, ipns, peerInfo, isOnline, options: constructorOptions }) => {
+module.exports = ({ dns, ipns, peerId, isOnline, options: constructorOptions }) => {
   /**
    * Given a key, query the DHT for its best value.
    *
@@ -57,7 +57,7 @@ module.exports = ({ dns, ipns, peerInfo, isOnline, options: constructorOptions }
 
     // Set node id as name for being resolved, if it is not received
     if (!name) {
-      name = peerInfo.id.toB58String()
+      name = peerId.toB58String()
     }
 
     if (!name.startsWith('/ipns/')) {

packages/ipfs/src/core/components/name/resolve.js

@@ -12,22 +12,21 @@ module.exports = ({ libp2p }) => {
       peerId = PeerId.createFromCID(peerId)
     }
 
-    let peerInfo
-    if (libp2p.peerStore.has(peerId)) {
-      peerInfo = libp2p.peerStore.get(peerId)
-    } else {
+    let peer = libp2p.peerStore.get(peerId)
+
+    if (!peer) {
       yield { ...basePacket, text: `Looking up peer ${peerId}` }
-      peerInfo = await libp2p.peerRouting.findPeer(peerId)
+      peer = await libp2p.peerRouting.findPeer(peerId)
     }
 
-    yield { ...basePacket, text: `PING ${peerInfo.id.toB58String()}` }
+    yield { ...basePacket, text: `PING ${peer.id.toB58String()}` }
 
     let packetCount = 0
     let totalTime = 0
 
     for (let i = 0; i < options.count; i++) {
       try {
-        const time = await libp2p.ping(peerInfo)
+        const time = await libp2p.ping(peer.id)
         totalTime += time
         packetCount++
         yield { ...basePacket, time }