feat: update deps and stop using swarm directly

README.md

@@ -33,7 +33,7 @@ js-libp2p-floodsub
 ```JavaScript
 const FloodSub = require('libp2p-floodsub')
 
-const fsub = new FloodSub(libp2pNodeInstance)
+const fsub = new FloodSub(node)
 
 fsub.start((err) => {
   if (err) {

package.json

@@ -44,16 +44,16 @@
   "devDependencies": {
     "aegir": "^11.0.2",
     "benchmark": "^2.1.4",
-    "chai": "^4.0.2",
-    "dirty-chai": "^2.0.0",
-    "libp2p": "^0.10.0",
+    "chai": "^4.1.0",
+    "dirty-chai": "^2.0.1",
+    "libp2p": "^0.10.1",
     "libp2p-secio": "^0.6.8",
     "libp2p-spdy": "^0.10.6",
     "libp2p-tcp": "^0.10.1",
     "lodash.times": "^4.3.2",
     "multiaddr": "^2.3.0",
     "peer-id": "~0.8.7",
-    "peer-info": "~0.9.2",
+    "peer-info": "~0.9.3",
     "pre-commit": "^1.2.2"
   },
   "dependencies": {

src/index.js

@@ -214,14 +214,12 @@ class FloodSub extends EventEmitter {
     this.libp2p.handle(multicodec, this._onConnection)
 
     // Speed up any new peer that comes in my way
-    this.libp2p.swarm.on('peer-mux-established', this._dialPeer)
+    this.libp2p.on('peer:connect', this._dialPeer)
 
     // Dial already connected peers
     const peerInfos = values(this.libp2p.peerBook.getAll())
 
-    asyncEach(peerInfos, (peerInfo, cb) => {
-      this._dialPeer(peerInfo, cb)
-    }, (err) => {
+    asyncEach(peerInfos, (peer, cb) => this._dialPeer(peer, cb), (err) => {
       setImmediate(() => {
         this.started = true
         callback(err)
@@ -242,7 +240,7 @@ class FloodSub extends EventEmitter {
     }
 
     this.libp2p.unhandle(multicodec)
-    this.libp2p.swarm.removeListener('peer-mux-established', this._dialPeer)
+    this.libp2p.removeListener('peer:connect', this._dialPeer)
 
     asyncEach(this.peers.values(), (peer, cb) => peer.close(cb), (err) => {
       if (err) {