chore: update deps (#155)

There's a new release of the `peer-id` module that uses the `CID` class from the
`multiformats` module instead of from `cids`.

This PR upgrades to the new version, along with all the supporting ecosystem modules

BREAKING CHANGE: the new `peer-id` module uses the new `CID` class and not the old one

package.json

@@ -44,8 +44,8 @@
     "denque": "^1.5.0",
     "err-code": "^3.0.1",
     "it-pipe": "^1.1.0",
-    "libp2p-interfaces": "^0.11.0",
-    "peer-id": "^0.14.8",
+    "libp2p-interfaces": "^1.0.1",
+    "peer-id": "^0.15.0",
     "protobufjs": "^6.11.2",
     "time-cache": "^0.3.0",
     "uint8arrays": "^2.1.5"
@@ -70,13 +70,14 @@
     "eslint-plugin-promise": "^4.2.1",
     "eslint-plugin-standard": "^4.0.1",
     "it-pair": "^1.0.0",
-    "libp2p": "^0.31.6",
-    "libp2p-floodsub": "^0.25.1",
+    "libp2p": "next",
+    "libp2p-floodsub": "^0.27.0",
+    "libp2p-interfaces-compliance-tests": "^1.0.1",
     "libp2p-mplex": "^0.10.3",
-    "libp2p-noise": "^2.0.0",
-    "libp2p-websockets": "^0.15.5",
+    "libp2p-noise": "^4.0.0",
+    "libp2p-websockets": "^0.16.1",
     "lodash": "^4.17.15",
-    "multiaddr": "^9.0.0",
+    "multiaddr": "^10.0.0",
     "os": "^0.1.1",
     "p-retry": "^4.2.0",
     "p-times": "^2.1.0",

test/compliance.spec.js

@@ -1,7 +1,7 @@
 /* eslint-env mocha */
 'use strict'
 
-const tests = require('libp2p-interfaces/src/pubsub/tests')
+const tests = require('libp2p-interfaces-compliance-tests/src/pubsub')
 
 const Gossipsub = require('../src')
 const { createPeers } = require('./utils/create-peer')

ts/index.ts

@@ -359,10 +359,10 @@ class Gossipsub extends Pubsub {
    * @param {String} idB58Str
    * @param {PeerStreams} peerStreams
    * @param {RPC} rpc
-   * @returns {boolean}
+   * @returns {Promise<boolean>}
    */
-  _processRpc (id: string, peerStreams: PeerStreams, rpc: RPC): boolean {
-    if (super._processRpc(id, peerStreams, rpc)) {
+  async _processRpc (id: string, peerStreams: PeerStreams, rpc: RPC): Promise<boolean> {
+    if (await super._processRpc(id, peerStreams, rpc)) {
       if (rpc.control) {
         this._processRpcControlMessage(id, rpc.control)
       }
@@ -403,7 +403,7 @@ class Gossipsub extends Pubsub {
    * @returns {Promise<void>}
    */
   async _processRpcMessage (msg: InMessage): Promise<void> {
-    const msgID = this.getMsgId(msg)
+    const msgID = await this.getMsgId(msg)
     const msgIdStr = messageIdToString(msgID)
 
     // Ignore if we've already seen the message
@@ -1017,7 +1017,7 @@ class Gossipsub extends Pubsub {
       this.gossipTracer.deliverMessage(msg)
     }
 
-    const msgID = this.getMsgId(msg)
+    const msgID = await this.getMsgId(msg)
     const msgIdStr = messageIdToString(msgID)
     // put in seen cache
     this.seenCache.put(msgIdStr)