feat: all pubsub tests passing with libp2p pubsub

src/core/components/pubsub.js

@@ -13,36 +13,36 @@ module.exports = function pubsub (self) {
 
       if (!callback) {
         return new Promise((resolve, reject) => {
-          self.libp2p.pubsub.subscribe(topic, options, handler, (err) => {
+          self._libp2pNode.pubsub.subscribe(topic, options, handler, (err) => {
             if (err) {
               return reject(err)
             }
             resolve()
           })
         })
       } else {
-        self.libp2p.pubsub.subscribe(topic, options, handler, callback)
+        self._libp2pNode.pubsub.subscribe(topic, options, handler, callback)
       }
     },
 
     unsubscribe: (topic, handler) => {
-      self.libp2p.pubsub.unsubscribe(topic, handler)
+      self._libp2pNode.pubsub.unsubscribe(topic, handler)
     },
 
     publish: promisify((topic, data, callback) => {
-      self.libp2p.pubsub.publish(topic, data, callback)
+      self._libp2pNode.pubsub.publish(topic, data, callback)
     }),
 
     ls: promisify((callback) => {
-      self.libp2p.pubsub.ls(callback)
+      self._libp2pNode.pubsub.ls(callback)
     }),
 
     peers: promisify((topic, callback) => {
-      self.libp2p.pubsub.peers(topic, callback)
+      self._libp2pNode.pubsub.peers(topic, callback)
     }),
 
     setMaxListeners (n) {
-      self.libp2p.pubsub.setMaxListeners(n)
+      self._libp2pNode.pubsub.setMaxListeners(n)
     }
   }
 }

test/core/bitswap.spec.js

@@ -88,7 +88,7 @@ function addNode (inProcNode, callback) {
   })
 }
 
-describe.only('bitswap', function () {
+describe('bitswap', function () {
   this.timeout(80 * 1000)
 
   let inProcNode // Node spawned inside this process
@@ -136,7 +136,7 @@ describe.only('bitswap', function () {
     })
   })
 
-  describe.only('transfer a block between', () => {
+  describe('transfer a block between', () => {
     it('2 peers', function (done) {
       this.timeout(80 * 1000)