subs.js

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

const { spawnNodeWithId } = require('../utils/spawn')
const { getDescribe, getIt, expect } = require('../utils/mocha')

module.exports = (createCommon, options) => {
  const describe = getDescribe(options)
  const it = getIt(options)
  const common = createCommon()

  describe('.name.pubsub.subs', function () {
    let ipfs

    before(function (done) {
      // CI takes longer to instantiate the daemon, so we need to increase the
      // timeout for the before step
      this.timeout(60 * 1000)

      common.setup((err, factory) => {
        expect(err).to.not.exist()

        spawnNodeWithId(factory, (err, node) => {
          expect(err).to.not.exist()

          ipfs = node
          done()
        })
      })
    })

    after((done) => common.teardown(done))

    it('should get an empty array as a result of subscriptions before any resolve', function (done) {
      this.timeout(60 * 1000)

      ipfs.name.pubsub.subs((err, res) => {
        expect(err).to.not.exist()
        expect(res).to.exist()
        expect(res).to.eql([])

        done()
      })
    })

    it('should get the list of subscriptions updated after a resolve', function (done) {
      this.timeout(300 * 1000)
      const id = 'QmNP1ASen5ZREtiJTtVD3jhMKhoPb1zppET1tgpjHx2NGA'

      ipfs.name.pubsub.subs((err, res) => {
        expect(err).to.not.exist()
        expect(res).to.eql([]) // initally empty

        ipfs.name.resolve(id, (err) => {
          expect(err).to.exist()

          ipfs.name.pubsub.subs((err, res) => {
            expect(err).to.not.exist()
            expect(res).to.be.an('array').that.does.include(`/ipns/${id}`)

            done()
          })
        })
      })
    })
  })
}