nxus-searcher-environment.js

const NxusEnvironment = require('./nxus-environment')
const tester = require('nxus-tester')

class NxusSearcherEnvironment extends NxusEnvironment {
  constructor(config) {
    if (!config.testEnvironmentOptions) {
      config.testEnvironmentOptions = {}
    }
    if (!config.testEnvironmentOptions.serverEnv) {
      config.testEnvironmentOptions.serverEnv = {}
    }
    if (!config.testEnvironmentOptions.serverEnv.nxus_storage__connections__searcher__index) {
      config.testEnvironmentOptions.serverEnv.nxus_storage__connections__searcher__index = process.env.nxus_storage__connections__searcher__index || 'searcher-jest-test'
    }
    if (!config.testEnvironmentOptions.serverEnv.nxus_storage__connections__searcher__host) {
      config.testEnvironmentOptions.serverEnv.nxus_storage__connections__searcher__host = process.env.nxus_storage__connections__searcher__host || 'http://localhost:9200'
    }
    super(config)

    this.searcherHost = config.testEnvironmentOptions.serverEnv.nxus_storage__connections__searcher__host
    this.searcherIndexName = config.testEnvironmentOptions.serverEnv.nxus_storage__connections__searcher__index
    this.searcherIndex = this.searcherHost+'/'+this.searcherIndexName
  }

  async setup() {
    console.log("Setting up searcher index at", this.searcherIndex)
    // But let nxus startup actually create the index with settings
    await super.setup()
    
    this.global.tester.searcherRefresh = async () => {
      await tester.request.post({url:this.searcherIndex+"/_refresh", baseUrl: null})
    }
  }
  async teardown() {
    console.log("Tearing down searcher index", this.searcherIndex)
    try {
      await tester.request.delete({url:this.searcherIndex, baseUrl: null, json: true})
    } catch (e) {
      // If the index wasn't used at all, not existing isn't an error
      if (! (e.response && e.response.body && e.response.body.error.type == 'index_not_found_exception')) {
        console.log("Teardown ES error", e.message)
      }
    }
    return super.teardown()
  }
}

module.exports = NxusSearcherEnvironment