all pubsub tests passing

Author: daviddias

package.json

@@ -76,7 +76,7 @@
     "form-data": "^2.3.1",
     "gulp": "^3.9.1",
     "hat": "0.0.3",
-    "interface-ipfs-core": "~0.36.6",
+    "interface-ipfs-core": "~0.36.7",
     "ipfsd-ctl": "~0.24.1",
     "left-pad": "^1.2.0",
     "lodash": "^4.17.4",
@@ -121,7 +121,7 @@
     "joi": "^13.0.2",
     "libp2p": "~0.13.1",
     "libp2p-circuit": "~0.1.4",
-    "libp2p-floodsub": "~0.11.1",
+    "libp2p-floodsub": "~0.12.1",
     "libp2p-kad-dht": "~0.6.0",
     "libp2p-mdns": "~0.9.1",
     "libp2p-multiplex": "~0.5.0",

src/core/components/pubsub.js

@@ -18,27 +18,34 @@ module.exports = function pubsub (self) {
         options = {}
       }
 
+      function subscribe (cb) {
+        if (self._pubsub.listenerCount(topic) === 0) {
+          self._pubsub.subscribe(topic)
+        }
+
+        self._pubsub.on(topic, handler)
+        setImmediate(() => callback())
+      }
+
       if (!callback) {
         return new Promise((resolve, reject) => {
-          subscribe(topic, options, handler, (err) => {
+          subscribe((err) => {
             if (err) {
               return reject(err)
             }
             resolve()
           })
         })
+      } else {
+        subscribe(callback)
       }
-
-      subscribe(topic, options, handler, callback)
     },
 
     unsubscribe: (topic, handler) => {
-      const ps = self._pubsub
-
-      ps.removeListener(topic, handler)
+      self._pubsub.removeListener(topic, handler)
 
-      if (ps.listenerCount(topic) === 0) {
-        ps.unsubscribe(topic)
+      if (self._pubsub.listenerCount(topic) === 0) {
+        self._pubsub.unsubscribe(topic)
       }
     },
 
@@ -60,9 +67,7 @@ module.exports = function pubsub (self) {
         return setImmediate(() => callback(new Error(OFFLINE_ERROR)))
       }
 
-      const subscriptions = Array.from(
-        self._pubsub.subscriptions
-      )
+      const subscriptions = Array.from(self._pubsub.subscriptions)
 
       setImmediate(() => callback(null, subscriptions))
     }),
@@ -83,15 +88,4 @@ module.exports = function pubsub (self) {
       return self._pubsub.setMaxListeners(n)
     }
   }
-
-  function subscribe (topic, options, handler, callback) {
-    const ps = self._pubsub
-
-    if (ps.listenerCount(topic) === 0) {
-      ps.subscribe(topic)
-    }
-
-    ps.on(topic, handler)
-    setImmediate(() => callback())
-  }
 }