add-index.spec.js

/*eslint-env es6*/
const Bluebird                  = require('bluebird')
const debug                     = require('debug')('got-couch')

const CONFIG                    = require('./config/_index.js')
const { initCouchDb, initTest } = require('./_test-base.js')

const DB_NAME = 'couch-add-index-test'

const CREATED = 201

const couchdb = initCouchDb(CONFIG)
const test    = initTest(couchdb, DB_NAME)


test('::addIndex should create an index that is used when a query is ' +
'executed by the ::query (find) function', t =>

  couchdb.then((connection) => {
    let index = null

    Bluebird.all([
      connection.create(DB_NAME, 'index1', { test: 'INDEX', moo: 'Elsie' })
    , connection.create(DB_NAME, 'index2', { test: 'INDEX', moo: 'Clara' })
    , connection.create(DB_NAME, 'index3', { test: 'INDEX', moo: 'Bessie' })
    , connection.create(DB_NAME, 'index4', { test: 'INDEX', moo: 'Babe' })
    ])

    .then(() => connection.ensureFullCommit(DB_NAME))

    .tap ((response) => {
      t.is(
        CREATED, response.statusCode,
        'ensure documents created for index test'
      )
    })

    .then(() => connection.addIndex(DB_NAME, {
      index: { fields: ["test", "moo"] }
    , name: "test-moo-index"
    }, {}))

    .tap ((response) => {
      index = response.body
    })

    .then(() => connection.ensureFullCommit(DB_NAME))

    .tap ((response) => {
      t.is(
        CREATED, response.statusCode,
        'ensure full commit after index create is 201'
      )
    })

    .then(() => connection.query(DB_NAME, {
      selector: { test: 'INDEX', moo: 'Babe' }
    }, {}))

    .then((result) => {

      const expected_count = 1

      const expected_rows = [
        { id: 'index4', test: 'INDEX', moo: 'Babe' }
      ]

      const _rowMap = (x) => ({ id: x._id, test: x.test, moo: x.moo })

      const actual_rows = result
        .body
        .docs
        .map(_rowMap)

      const has_warning = result.body.hasOwnProperty('warning')

      t.is(actual_rows.length, expected_count, 'list count is not 1')
      t.deepEqual(actual_rows, expected_rows, 'list not what I expected')
      t.falsy(has_warning, 'query generated an unexpected warning message')

    })

    .then(() => {
      index.type = 'json'
      index.ddoc = index.id
      return connection.deleteIndex(DB_NAME, index)
    })

    .then((result) => {
      t.is(result.ok, true, "deleting index failed miserably")
    })
    .catch((err) => {
      t.fail(err)
    })

  })
  .catch((err) => {
    debug("ADD INDEX: %o", err)
    t.fail(err)
    throw err
  })

)