cleanup

src/core/components/go-online.js

@@ -20,8 +20,11 @@ module.exports = (self) => {
         self._peerInfoBook
       )
 
-      self._pubsub = new FloodSub(self._libp2pNode)
+      const pubsub = self._configOpts.EXPERIMENTAL.pubsub
 
+      if (pubsub) {
+        self._pubsub = new FloodSub(self._libp2pNode)
+      }
       series([
         (cb) => {
           self._bitswap.start()
@@ -32,7 +35,7 @@ module.exports = (self) => {
           cb()
         },
         (cb) => {
-          if (self._configOpts.EXPERIMENTAL.pubsub) {
+          if (pubsub) {
             self._pubsub.start(cb)
           } else {
             cb()

test/interop/daemons/js.js

@@ -49,7 +49,10 @@ class JsDaemon {
     } else {
       const repo = new IPFSRepo(this.path, {stores: require('fs-pull-blob-store')})
       this.ipfs = new IPFS({
-        repo: repo
+        repo: repo,
+        EXPERIMENTAL: {
+          pubsub: true
+        }
       })
     }
     this.node = null

test/interop/index.js

@@ -19,7 +19,6 @@ const sizes = [
   1024 * 512,
   1024 * 768,
   1024 * 1023,
-  // starts failing with multiplex
   1024 * 1024,
   1024 * 1024 * 4,
   1024 * 1024 * 8
@@ -78,7 +77,7 @@ describe('basic', () => {
     ], done)
   })
 
-  it.skip('connect js <-> js', (done) => {
+  it('connect js <-> js', (done) => {
     let jsId
     let js2Id
 
@@ -133,7 +132,7 @@ describe('basic', () => {
       })
     })
 
-    it.skip(`js -> js: ${size}bytes`, (done) => {
+    it(`js -> js: ${size}bytes`, (done) => {
       const data = crypto.randomBytes(size)
       waterfall([
         (cb) => js2Daemon.api.add(data, cb),