fix: ci tests

Author: vasco-santos

package.json

@@ -72,7 +72,7 @@
     "form-data": "^2.3.3",
     "hat": "0.0.3",
     "interface-ipfs-core": "~0.96.0",
-    "ipfsd-ctl": "~0.40.1",
+    "ipfsd-ctl": "~0.40.2",
     "ncp": "^2.0.0",
     "qs": "^6.5.2",
     "rimraf": "^2.6.2",
@@ -128,7 +128,7 @@
     "joi": "^14.3.0",
     "joi-browser": "^13.4.0",
     "joi-multiaddr": "^4.0.0",
-    "libp2p": "~0.24.1",
+    "libp2p": "~0.24.3",
     "libp2p-bootstrap": "~0.9.3",
     "libp2p-crypto": "~0.16.0",
     "libp2p-kad-dht": "~0.14.4",
@@ -140,7 +140,7 @@
     "libp2p-tcp": "~0.13.0",
     "libp2p-webrtc-star": "~0.15.5",
     "libp2p-websocket-star-multi": "~0.4.0",
-    "libp2p-websockets": "~0.12.0",
+    "libp2p-websockets": "~0.12.2",
     "lodash": "^4.17.11",
     "mafmt": "^6.0.2",
     "mime-types": "^2.1.21",

src/cli/commands/dht/find-peer.js

@@ -9,15 +9,12 @@ module.exports = {
 
   builder: {},
 
-  handler (argv) {
-    argv.ipfs.dht.findPeer(argv.peerID, (err, result) => {
-      if (err) {
-        throw err
-      }
-
-      const addresses = result.multiaddrs.toArray().map((ma) => ma.toString())
+  handler ({ ipfs, peerID, resolve }) {
+    resolve((async () => {
+      const peers = await ipfs.dht.findPeer(peerID)
+      const addresses = peers.multiaddrs.toArray().map((ma) => ma.toString())
 
       print(addresses)
-    })
+    })())
   }
 }

src/cli/commands/dht/find-providers.js

@@ -16,18 +16,17 @@ module.exports = {
   },
 
   handler (argv) {
+    const { ipfs, key, resolve } = argv
     const opts = {
       maxNumProviders: argv['num-providers']
     }
 
-    argv.ipfs.dht.findProvs(argv.key, opts, (err, result) => {
-      if (err) {
-        throw err
-      }
+    resolve((async () => {
+      const provs = await ipfs.dht.findProvs(key, opts)
 
-      result.forEach((element) => {
+      provs.forEach((element) => {
         print(element.id.toB58String())
       })
-    })
+    })())
   }
 }

src/cli/commands/dht/get.js

@@ -9,13 +9,11 @@ module.exports = {
 
   builder: {},
 
-  handler (argv) {
-    argv.ipfs.dht.get(argv.key, (err, result) => {
-      if (err) {
-        throw err
-      }
+  handler ({ ipfs, key, resolve }) {
+    resolve((async () => {
+      const value = await ipfs.dht.get(key)
 
-      print(result)
-    })
+      print(value)
+    })())
   }
 }

src/cli/commands/dht/provide.js

@@ -13,11 +13,11 @@ module.exports = {
     }
   },
 
-  handler (argv) {
-    argv.ipfs.dht.provide(argv.key, (err, result) => {
-      if (err) {
-        throw err
-      }
-    })
+  handler ({ ipfs, key, resolve }) {
+    // TODO add recursive option
+
+    resolve((async () => {
+      await ipfs.dht.provide(key)
+    })())
   }
 }

src/cli/commands/dht/put.js

@@ -7,11 +7,9 @@ module.exports = {
 
   builder: {},
 
-  handler (argv) {
-    argv.ipfs.dht.put(argv.key, argv.value, (err) => {
-      if (err) {
-        throw err
-      }
-    })
+  handler ({ ipfs, key, value, resolve }) {
+    resolve((async () => {
+      await ipfs.dht.put(key, value)
+    })())
   }
 }

src/cli/commands/dht/query.js

@@ -9,15 +9,13 @@ module.exports = {
 
   builder: {},
 
-  handler (argv) {
-    argv.ipfs.dht.query(argv.peerID, (err, result) => {
-      if (err) {
-        throw err
-      }
+  handler ({ ipfs, peerID, resolve }) {
+    resolve((async () => {
+      const result = await ipfs.dht.query(peerID)
 
       result.forEach((peerID) => {
         print(peerID.id.toB58String())
       })
-    })
+    })())
   }
 }

src/core/components/libp2p.js

@@ -47,37 +47,37 @@ module.exports = function libp2p (self, config) {
 
 function defaultBundle ({ datastore, peerInfo, peerBook, options, config }) {
   const libp2pDefaults = {
-    datastore: opts.datastore,
-    peerInfo: opts.peerInfo,
-    peerBook: opts.peerBook,
+    datastore,
+    peerInfo,
+    peerBook,
     config: {
       peerDiscovery: {
         mdns: {
-          enabled: get(opts.options, 'config.Discovery.MDNS.Enabled',
-            get(opts.config, 'Discovery.MDNS.Enabled', true))
+          enabled: get(options, 'config.Discovery.MDNS.Enabled',
+            get(config, 'Discovery.MDNS.Enabled', true))
         },
         webRTCStar: {
-          enabled: get(opts.options, 'config.Discovery.webRTCStar.Enabled',
-            get(opts.config, 'Discovery.webRTCStar.Enabled', true))
+          enabled: get(options, 'config.Discovery.webRTCStar.Enabled',
+            get(config, 'Discovery.webRTCStar.Enabled', true))
         },
         bootstrap: {
-          list: get(opts.options, 'config.Bootstrap',
-            get(opts.config, 'Bootstrap', []))
+          list: get(options, 'config.Bootstrap',
+            get(config, 'Bootstrap', []))
         }
       },
       relay: {
-        enabled: get(opts.options, 'relay.enabled',
-          get(opts.config, 'relay.enabled', false)),
+        enabled: get(options, 'relay.enabled',
+          get(config, 'relay.enabled', false)),
         hop: {
-          enabled: get(opts.options, 'relay.hop.enabled',
-            get(opts.config, 'relay.hop.enabled', false)),
-          active: get(opts.options, 'relay.hop.active',
-            get(opts.config, 'relay.hop.active', false))
+          enabled: get(options, 'relay.hop.enabled',
+            get(config, 'relay.hop.enabled', false)),
+          active: get(options, 'relay.hop.active',
+            get(config, 'relay.hop.active', false))
         }
       },
       dht: {
-        kBucketSize: get(opts.options, 'dht.kBucketSize', 20),
-        enabledDiscovery: get(opts.options, 'dht.enabledDiscovery', true),
+        kBucketSize: get(options, 'dht.kBucketSize', 20),
+        enabledDiscovery: get(options, 'dht.enabledDiscovery', true),
         validators: {
           ipns: ipnsUtils.validator
         },
@@ -86,12 +86,12 @@ function defaultBundle ({ datastore, peerInfo, peerBook, options, config }) {
         }
       },
       EXPERIMENTAL: {
-        dht: true,
-        pubsub: get(opts.options, 'EXPERIMENTAL.pubsub', false)
+        dht: !(get(options, 'local', false)),
+        pubsub: get(options, 'EXPERIMENTAL.pubsub', false)
       }
     },
-    connectionManager: get(opts.options, 'connectionManager',
-      get(opts.config, 'connectionManager', {}))
+    connectionManager: get(options, 'connectionManager',
+      get(config, 'connectionManager', {}))
   }
 
   const libp2pOptions = defaultsDeep(get(options, 'libp2p', {}), libp2pDefaults)

src/core/components/pin-set.js

@@ -6,8 +6,8 @@ const protobuf = require('protons')
 const fnv1a = require('fnv1a')
 const varint = require('varint')
 const { DAGNode, DAGLink } = require('ipld-dag-pb')
-const some = require('async/some')
-const eachOf = require('async/eachOf')
+const someSeries = require('async/someSeries')
+const eachOfSeries = require('async/eachOfSeries')
 
 const pbSchema = require('./pin.proto')
 
@@ -69,7 +69,7 @@ exports = module.exports = function (dag) {
       return searchChildren(root, callback)
 
       function searchChildren (root, cb) {
-        some(root.links, ({ cid }, done) => {
+        someSeries(root.links, ({ cid }, done) => {
           const bs58Link = toB58String(cid)
 
           if (bs58Link === childhash) {
@@ -174,7 +174,7 @@ exports = module.exports = function (dag) {
             return bins
           }, {})
 
-          eachOf(bins, (bin, idx, eachCb) => {
+          eachOfSeries(bins, (bin, idx, eachCb) => {
             storePins(
               bin,
               depth + 1,
@@ -233,7 +233,7 @@ exports = module.exports = function (dag) {
         return callback(err)
       }
 
-      eachOf(node.links, (link, idx, eachCb) => {
+      eachOfSeries(node.links, (link, idx, eachCb) => {
         if (idx < pbh.header.fanout) {
           // the first pbh.header.fanout links are fanout bins
           // if a fanout bin is not 'empty', dig into and walk its DAGLinks

src/core/components/start.js

@@ -67,9 +67,8 @@ module.exports = (self) => {
           ipnsStores.push(pubsubDs)
         }
 
-        // DHT should be added as routing if we are not running with offline flag
-        // TODO: Need to change this logic once DHT is enabled by default, for now fallback to Offline datastore
-        if (get(self._options, 'EXPERIMENTAL.dht', false) && !self._options.offline) {
+        // DHT should be added as routing if we are not running with local flag
+        if (!self._options.offline) {
           ipnsStores.push(self.libp2p.dht)
         } else {
           const offlineDatastore = new OfflineDatastore(self._repo)