chore: added hybrid tests

package.json

@@ -34,7 +34,7 @@
     "cross-env": "^5.2.0",
     "dirty-chai": "^2.0.1",
     "go-libp2p-dep": "~0.1.0",
-    "libp2p-daemon": "libp2p/js-libp2p-daemon#feat/integrate-gossipsub-by-default",
+    "libp2p-daemon": "~0.2.3",
     "libp2p-daemon-client": "~0.2.1",
     "multiaddr": "^6.0.6",
     "rimraf": "^2.6.3"

test/pubsub/floodsub/go2go.js

@@ -26,7 +26,7 @@ describe('pubsub - floodsub', () => {
   })
 
   it('go publish to go subscriber', function () {
-    this.timeout(10 * 1000)
+    this.timeout(20 * 1000)
 
     return pubsubTest(daemons)
   })

test/pubsub/floodsub/go2js.js

@@ -26,7 +26,7 @@ describe('pubsub - floodsub', () => {
   })
 
   it('go publish to js subscriber', function () {
-    this.timeout(10 * 1000)
+    this.timeout(20 * 1000)
 
     return pubsubTest(daemons)
   })

test/pubsub/floodsub/js2go.js

@@ -26,7 +26,7 @@ describe('pubsub - floodsub', () => {
   })
 
   it('js publish to go subscriber', function () {
-    this.timeout(10 * 1000)
+    this.timeout(20 * 1000)
 
     return pubsubTest(daemons)
   })

test/pubsub/floodsub/js2js.js

@@ -26,7 +26,7 @@ describe('pubsub - floodsub', () => {
   })
 
   it('js publish to js subscriber', function () {
-    this.timeout(10 * 1000)
+    this.timeout(30 * 1000)
 
     return pubsubTest(daemons)
   })

test/pubsub/gossipsub/go2go.js

@@ -26,7 +26,7 @@ describe('pubsub - gossipsub', () => {
   })
 
   it('go publish to go subscriber', function () {
-    this.timeout(10 * 1000)
+    this.timeout(20 * 1000)
 
     return pubsubTest(daemons)
   })

test/pubsub/gossipsub/go2js.js

@@ -26,7 +26,7 @@ describe('pubsub - gossipsub', () => {
   })
 
   it('go publish to js subscriber', function () {
-    this.timeout(10 * 1000)
+    this.timeout(20 * 1000)
 
     return pubsubTest(daemons)
   })

test/pubsub/gossipsub/js2go.js

@@ -26,7 +26,7 @@ describe('pubsub - gossipsub', () => {
   })
 
   it('js publish to go subscriber', function () {
-    this.timeout(10 * 1000)
+    this.timeout(20 * 1000)
 
     return pubsubTest(daemons)
   })

test/pubsub/gossipsub/js2js.js

@@ -26,7 +26,7 @@ describe('pubsub - gossipsub', () => {
   })
 
   it('js publish to js subscriber', function () {
-    this.timeout(10 * 1000)
+    this.timeout(30 * 1000)
 
     return pubsubTest(daemons)
   })

test/pubsub/hybrid/go2go.js

@@ -0,0 +1,38 @@
+/* eslint-env mocha */
+'use strict'
+
+const spawnDaemons = require('../../utils/spawnDaemons')
+const { pubsubTest } = require('../test')
+
+describe('pubsub - hybrid', () => {
+  let daemons
+
+  // Start daemons
+  before(async function () {
+    this.timeout(20 * 1000)
+
+    const daemonOptions = [
+      { pubsub: true, pubsubRouter: 'floodsub' },
+      { pubsub: true, pubsubRouter: 'gossipsub' }
+    ]
+
+    daemons = await spawnDaemons(2, 'go', daemonOptions)
+
+    // connect them
+    const identify0 = await daemons[0].client.identify()
+    await daemons[1].client.connect(identify0.peerId, identify0.addrs)
+  })
+
+  // Stop daemons
+  after(async function () {
+    await Promise.all(
+      daemons.map((daemon) => daemon.stop())
+    )
+  })
+
+  it('go floodsub publish to go gossipsub subscriber', function () {
+    this.timeout(20 * 1000)
+
+    return pubsubTest(daemons)
+  })
+})

test/pubsub/hybrid/go2js.js

@@ -0,0 +1,38 @@
+/* eslint-env mocha */
+'use strict'
+
+const spawnDaemons = require('../../utils/spawnDaemons')
+const { pubsubTest } = require('../test')
+
+describe('pubsub - hybrid', () => {
+  let daemons
+
+  // Start daemons
+  before(async function () {
+    this.timeout(20 * 1000)
+
+    const daemonOptions = [
+      { pubsub: true, pubsubRouter: 'floodsub' },
+      { pubsub: true, pubsubRouter: 'gossipsub' }
+    ]
+
+    daemons = await spawnDaemons(2, ['go', 'js'], daemonOptions)
+
+    // connect them
+    const identify0 = await daemons[0].client.identify()
+    await daemons[1].client.connect(identify0.peerId, identify0.addrs)
+  })
+
+  // Stop daemons
+  after(async function () {
+    await Promise.all(
+      daemons.map((daemon) => daemon.stop())
+    )
+  })
+
+  it('go floodsub publish to js gossipsub subscriber', function () {
+    this.timeout(20 * 1000)
+
+    return pubsubTest(daemons)
+  })
+})

test/pubsub/hybrid/index.js

@@ -0,0 +1,6 @@
+'use strict'
+
+require('./go2go')
+require('./go2js')
+require('./js2go')
+require('./js2js')

test/pubsub/hybrid/js2go.js

@@ -0,0 +1,38 @@
+/* eslint-env mocha */
+'use strict'
+
+const spawnDaemons = require('../../utils/spawnDaemons')
+const { pubsubTest } = require('../test')
+
+describe('pubsub - hybrid', () => {
+  let daemons
+
+  // Start daemons
+  before(async function () {
+    this.timeout(20 * 1000)
+
+    const daemonOptions = [
+      { pubsub: true, pubsubRouter: 'floodsub' },
+      { pubsub: true, pubsubRouter: 'gossipsub' }
+    ]
+
+    daemons = await spawnDaemons(2, ['js', 'go'], daemonOptions)
+
+    // connect them
+    const identify0 = await daemons[0].client.identify()
+    await daemons[1].client.connect(identify0.peerId, identify0.addrs)
+  })
+
+  // Stop daemons
+  after(async function () {
+    await Promise.all(
+      daemons.map((daemon) => daemon.stop())
+    )
+  })
+
+  it('js floodsub publish to go gossipsub subscriber', function () {
+    this.timeout(20 * 1000)
+
+    return pubsubTest(daemons)
+  })
+})

test/pubsub/hybrid/js2js.js

@@ -0,0 +1,38 @@
+/* eslint-env mocha */
+'use strict'
+
+const spawnDaemons = require('../../utils/spawnDaemons')
+const { pubsubTest } = require('../test')
+
+describe('pubsub - hybrid', () => {
+  let daemons
+
+  // Start daemons
+  before(async function () {
+    this.timeout(20 * 1000)
+
+    const daemonOptions = [
+      { pubsub: true, pubsubRouter: 'floodsub' },
+      { pubsub: true, pubsubRouter: 'gossipsub' }
+    ]
+
+    daemons = await spawnDaemons(2, 'js', daemonOptions)
+
+    // connect them
+    const identify0 = await daemons[0].client.identify()
+    await daemons[1].client.connect(identify0.peerId, identify0.addrs)
+  })
+
+  // Stop daemons
+  after(async function () {
+    await Promise.all(
+      daemons.map((daemon) => daemon.stop())
+    )
+  })
+
+  it('js floodsub publish to js gossipsub subscriber', function () {
+    this.timeout(30 * 1000)
+
+    return pubsubTest(daemons)
+  })
+})

test/pubsub/index.js

@@ -2,3 +2,4 @@
 
 require('./gossipsub')
 require('./floodsub')
+require('./hybrid')

test/pubsub/test.js

@@ -21,7 +21,7 @@ exports.pubsubTest = async (daemons) => {
 
   const publisher = async () => {
     // wait for subscription stream
-    await new Promise(resolve => setTimeout(resolve, 200))
+    await new Promise(resolve => setTimeout(resolve, 800))
     daemons[0].client.pubsub.publish(topic, data)
   }