test: all pubsub tests passing (#1094)

* all pubsub tests passing
* config.replace is not supported anymore

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())
-  }
 }

test/cli/config.js

@@ -72,7 +72,7 @@ describe('config', () => runOnAndOff((thing) => {
     })
   })
 
-  describe('replace', () => {
+  describe.skip('replace', () => {
     it('replace config with file', () => {
       const filePath = 'test/fixtures/test-data/otherconfig'
       const expectedConfig = JSON.parse(fs.readFileSync(filePath, 'utf8'))

test/http-api/over-ipfs-api/config.js

@@ -72,7 +72,7 @@ module.exports = (ctl) => {
 
     // This one is one stale mode till go-ipfs decides
     // what to do with the .replace command
-    describe('.replace', () => {
+    describe.skip('.replace', () => {
       it('returns error if the config is invalid', (done) => {
         const filePath = 'test/fixtures/test-data/badconfig'
 

test/http-api/spec/config.js

@@ -153,7 +153,7 @@ module.exports = (http) => {
       })
     })
 
-    describe('/config/replace', () => {
+    describe.skip('/config/replace', () => {
       it('returns 400 if no config is provided', (done) => {
         const form = new FormData()
         const headers = form.getHeaders()