ipfs-pubsub-room/test/same-node.spec.js

/* eslint-env mocha */
/* eslint max-nested-callbacks: ["error", 5] */
'use strict'

const chai = require('chai')
chai.use(require('dirty-chai'))
const expect = chai.expect

const PubSubRoom = require('../')
const createLibp2p = require('./utils/create-libp2p')

const topic = 'pubsub-same-node-test-' + Date.now() + '-' + Math.random()

describe('same node', function () {
  this.timeout(30000)
  let node
  const rooms = []

  before(async () => {
    node = await createLibp2p()
  })

  before(() => {
    for (let i = 0; i < 2; i++) {
      rooms.push(new PubSubRoom(node, topic))
    }
  })

  after(() => {
    return Promise.all(
      rooms.map(room => room.leave())
    )
  })

  after(() => node.stop())

  it('mirrors broadcast', (done) => {
    rooms[0].once('message', (message) => {
      expect(message.data.toString()).to.equal('message 1')
      rooms[0].once('message', (message) => {
        expect(message.data.toString()).to.equal('message 2')
        done()
      })
    })
    rooms[1].broadcast('message 1')
    rooms[1].broadcast('message 2')
  })
})