pulsar/spec/state-store-spec.js

/** @babel */
import { it } from './async-spec-helpers'

const StateStore = require('../src/state-store.js')

describe('StateStore', () => {
  let databaseName = `test-database-${Date.now()}`
  let version = 1

  it('can save, load, and delete states', () => {
    const store = new StateStore(databaseName, version)
    return store
      .save('key', { foo: 'bar' })
      .then(() => store.load('key'))
      .then(state => {
        expect(state).toEqual({ foo: 'bar' })
      })
      .then(() => store.delete('key'))
      .then(() => store.load('key'))
      .then(value => {
        expect(value).toBeNull()
      })
      .then(() => store.count())
      .then(count => {
        expect(count).toBe(0)
      })
  })

  it('resolves with null when a non-existent key is loaded', () => {
    const store = new StateStore(databaseName, version)
    return store.load('no-such-key').then(value => {
      expect(value).toBeNull()
    })
  })

  it('can clear the state object store', () => {
    const store = new StateStore(databaseName, version)
    return store
      .save('key', { foo: 'bar' })
      .then(() => store.count())
      .then(count => expect(count).toBe(1))
      .then(() => store.clear())
      .then(() => store.count())
      .then(count => {
        expect(count).toBe(0)
      })
  })

  describe('when there is an error reading from the database', () => {
    it('rejects the promise returned by load', () => {
      const store = new StateStore(databaseName, version)

      const fakeErrorEvent = { target: { errorCode: 'Something bad happened' } }

      spyOn(IDBObjectStore.prototype, 'get').andCallFake(key => {
        let request = {}
        process.nextTick(() => request.onerror(fakeErrorEvent))
        return request
      })

      return store
        .load('nonexistentKey')
        .then(() => {
          throw new Error('Promise should have been rejected')
        })
        .catch(event => {
          expect(event).toBe(fakeErrorEvent)
        })
    })
  })
})