test.js

const createReduxListen = require('./index')

const REDUX_LISTEN_RESOLVE = 'REDUX_LISTEN_RESOLVE'

describe('Redux Listen', () => {
  describe('#getListeners', () => {
    test('should be an array', () => {
      const rl = createReduxListen()
      expect(rl.getListeners()).toEqual([])
    })
  })

  describe('#addListener', () => {
    test('should add a listener', () => {
      const rl = createReduxListen()
      const fn = jest.fn()
      const type = 'TYPE'
      rl.addListener(type, fn)
      expect(rl.getListeners()).toHaveLength(1)
      expect(rl.getListeners()[0]).toEqual({ type, fn, isRegExp: false })
      rl.removeListeners()
    })

    test('should add a RegExp listener', () => {
      const rl = createReduxListen()
      const fn = jest.fn()
      const type = /TYPE_./
      rl.addListener(type, fn)
      expect(rl.getListeners()).toHaveLength(1)
      expect(rl.getListeners()[0]).toEqual({ type, fn, isRegExp: true })
      const next = jest.fn()
      rl.middleware({})(next)({ type: 'TYPE_A' })
      expect(next).toBeCalled()
      rl.removeListeners()
    })
  })

  describe('#addListeners', () => {
    test('should add many listeners', () => {
      const rl = createReduxListen()
      const listenerA = jest.fn()
      const listenerB = jest.fn()
      const typeA = 'TYPE_A'
      const typeB = 'TYPE_B'
      rl.addListeners({
        [typeA]: listenerA,
        [typeB]: listenerB,
      })
      expect(rl.getListeners()).toHaveLength(2)
      expect(rl.getListeners()[0]).toEqual({ type: typeA, fn: listenerA, isRegExp: false })
      expect(rl.getListeners()[1]).toEqual({ type: typeB, fn: listenerB, isRegExp: false })
      rl.removeListeners()
    })
  })

  describe('#removeListeners', () => {
    let rl
    let listenerA
    let listenerB
    let typeA
    let typeB

    beforeEach(() => {
      rl = createReduxListen()
      listenerA = jest.fn()
      listenerB = jest.fn()
      typeA = 'TYPE_A'
      typeB = 'TYPE_B'
      rl.addListeners({
        [typeA]: listenerA,
        [typeB]: listenerB,
      })
    })

    afterEach(() => {
      rl.removeListeners()
    })

    test('should remove all listeners', () => {
      expect(rl.getListeners()).toHaveLength(2)
      rl.removeListeners()
      expect(rl.getListeners()).toHaveLength(0)
    })

    test('should remove listeners by type', () => {
      expect(rl.getListeners()).toHaveLength(2)
      rl.removeListeners({ type: typeB })
      expect(rl.getListeners()).toHaveLength(1)
      expect(rl.getListeners()[0]).toEqual({ type: typeA, fn: listenerA, isRegExp: false })
    })

    test('should remove listeners by fn', () => {
      expect(rl.getListeners()).toHaveLength(2)
      rl.removeListeners({ fn: listenerB })
      expect(rl.getListeners()).toHaveLength(1)
      expect(rl.getListeners()[0]).toEqual({ type: typeA, fn: listenerA, isRegExp: false })
    })

    test('should remove listeners by type and fn', () => {
      expect(rl.getListeners()).toHaveLength(2)
      rl.removeListeners({ type: typeB, fn: listenerB })
      expect(rl.getListeners()).toHaveLength(1)
      expect(rl.getListeners()[0]).toEqual({ type: typeA, fn: listenerA, isRegExp: false })
    })
  })

  describe('#isPending', () => {
    test('should be false if nothing', () => {
      const rl = createReduxListen()
      expect(rl.isPending()).toBe(false)
    })

    test('should be true if waiting', done => {
      const rl = createReduxListen()
      const store = { getState: () => ({}), dispatch: a => a }
      const next = jest.fn()
      const action = { type: 'FOO' }
      rl.addListener('FOO', (x, _) => {
        setTimeout(() => {
          _()
          expect(rl.isPending()).toBe(false)
          rl.removeListeners()
          done()
        })
      })
      expect(rl.isPending()).toBe(false)
      rl.middleware(store)(next)(action)
      expect(rl.isPending()).toBe(true)
    })
  })

  describe('#decrementPendingCount', () => {
    test('should not decrement pending count', () => {
      const rl = createReduxListen()
      expect(rl.isPending()).toEqual(false)
      rl.decrementPendingCount(() => {}, () => {})()
      expect(rl.isPending()).toEqual(false)
    })

    test('should decrement pending count and should call resolve listeners', done => {
      const rl = createReduxListen()
      const next = jest.fn()
      const store = { getState: () => ({}), dispatch: action => rl.middleware(store)(next)(action) }
      const resolver = jest.fn()
      rl.addListener('FOO', (x, _) => {
        setTimeout(() => {
          expect(rl.isPending()).toEqual(true)
          _()
          expect(rl.isPending()).toEqual(true)
          _() // should have no effect
          expect(resolver).not.toBeCalled()
        }, 10)
      })
      rl.addListener('FOO', (x, _) => {
        setTimeout(() => {
          expect(rl.isPending()).toEqual(true)
          _()
          expect(rl.isPending()).toEqual(false)
          expect(resolver).toBeCalled()
          rl.removeListeners()
          done()
        }, 20)
      })
      rl.addListener(REDUX_LISTEN_RESOLVE, () => resolver())
      rl.middleware(store)(next)({ type: 'FOO' })
      expect(rl.isPending()).toEqual(true)
    })
  })

  describe('#middleware', () => {
    test('should fire matching listeners', () => {
      const rl = createReduxListen()
      const state = {}
      const store = {
        getState() {
          return state
        },
        dispatch: jest.fn(),
      }
      const next = jest.fn()
      const action = { type: 'TYPE' }
      const listener = jest.fn()
      rl.addListener('TYPE', listener)
      rl.middleware(store)(next)(action)
      expect(next).toBeCalled()
      expect(listener).toBeCalled()
      rl.removeListeners()
    })

    test('should log error', () => {
      const rl = createReduxListen()
      const spy = jest.spyOn(global.console, 'error')
      function fn() {
        throw new Error('FOO')
      }
      const store = {
        getState() {
          return {}
        },
      }
      const next = jest.fn()
      const action = { type: 'FOO' }
      rl.addListener('FOO', fn)
      rl.middleware(store)(next)(action)
      expect(spy).toBeCalled()
      rl.removeListeners()
      spy.mockRestore()
    })
  })
})