Remove init scripts

Author: callmekatootie

README.md

@@ -89,7 +89,7 @@ Configuration for the tests is at `config/test.js`, only add such new configurat
     docker-compose up -d
     ```
 
-3. initialize Elasticsearch, create configured Elasticsearch index: `npm run init-es force`
+3. initialize Elasticsearch. Execute the `insert-data` script in the [API repository](https://github.com/topcoder-platform/u-bahn-api) to set it up and then clear only the data
 
 ## Local deployment
 

package.json

@@ -7,7 +7,6 @@
     "start": "node src/app.js",
     "lint": "standard",
     "lint:fix": "standard --fix",
-    "init-es": "node test/common/init-es.js",
     "view-data": "node test/common/view-data.js",
     "test": "mocha test/unit/test.js --require test/unit/prepare.js --timeout 20000 --exit",
     "test:cov": "nyc --reporter=html --reporter=text mocha test/unit/test.js --require test/unit/prepare.js --timeout 20000 --exit",

test/common/init-es.js

@@ -11,159 +11,12 @@
  * node src/init-es
  * node src/init-es force
  */
-
-const _ = require('lodash')
 const logger = require('../../src/common/logger')
 const helper = require('../../src/common/helper')
-const { topResources, userResources } = require('../../src/common/constants')
+const { topResources } = require('../../src/common/constants')
 
 let client
 
-let needsNestedTypes = ['user']
-const enrichedFields = ['attributegroup', 'skillprovider']
-
-/**
- * Initialize elastic search index
- * @param {Boolean} isForce boolean flag indicate it is forced operation
- */
-const init = async (isForce) => {
-  if (!client) {
-    client = await helper.getESClient()
-  }
-  if (isForce) {
-    await clearES()
-  }
-  const processors = {}
-  for (const key in topResources) {
-    const exists = await client.indices.exists({ index: topResources[key].index })
-    const top = topResources[key]
-    if (exists.body) {
-      logger.info(`The index ${top.index} exists.`)
-    } else {
-      logger.info(`The index ${top.index} will be created.`)
-      await client.indices.create({
-        index: top.index,
-        body: {
-          mappings: {
-            properties: _(_.get(top, 'enrich.enrichFields', [])).map(p => [p, { type: _.includes(enrichedFields, p) ? 'nested' : 'keyword' }]).fromPairs()
-          }
-        }
-      })
-      if (needsNestedTypes.includes(key)) {
-        for (const childKey in userResources) {
-          if (userResources[childKey].isNested) {
-            await client.indices.putMapping({
-              index: topResources[key].index,
-              type: topResources[key].type,
-              include_type_name: true,
-              body: {
-                properties: {
-                  [userResources[childKey].propertyName]: {
-                    type: 'nested'
-                  }
-                }
-              }
-            })
-          }
-        }
-      }
-    }
-    if (top['enrich']) {
-      logger.info(`The enrich policy ${top.enrich.policyName} will be created.`)
-      await client.enrich.putPolicy({
-        name: top.enrich.policyName,
-        body: {
-          match: {
-            indices: top.index,
-            match_field: top.enrich.matchField,
-            enrich_fields: top.enrich.enrichFields
-          }
-        }
-      })
-      await client.enrich.executePolicy({ name: top.enrich.policyName })
-    }
-    if (top.pipeline) {
-      if (top.pipeline.processors) {
-        processors[top.pipeline.id] = []
-        _.each(top.pipeline.processors, processor => {
-          processors[top.pipeline.id].push({
-            foreach: {
-              field: processor.referenceField,
-              ignore_missing: true,
-              processor: {
-                enrich: {
-                  policy_name: processor.enrichPolicyName,
-                  ignore_missing: true,
-                  field: processor.field,
-                  target_field: processor.targetField,
-                  max_matches: processor.maxMatches
-                }
-              }
-            }
-          })
-        })
-      } else {
-        processors[top.pipeline.id] = [{
-          enrich: {
-            policy_name: top.enrich.policyName,
-            ignore_missing: true,
-            field: top.pipeline.field,
-            target_field: top.pipeline.targetField,
-            max_matches: top.pipeline.maxMatches
-          }
-        }]
-      }
-    }
-  }
-
-  for (const key in processors) {
-    logger.info(`The pipeline ${key} will be created.`)
-    await client.ingest.putPipeline({
-      id: key,
-      body: {
-        processors: processors[key]
-      }
-    })
-  }
-}
-
-/**
- * Delete elastic search index
- */
-const clearES = async () => {
-  for (const key in topResources) {
-    if (topResources[key].pipeline) {
-      try {
-        logger.info(`Delete pipeline ${topResources[key].pipeline.id} if any.`)
-        await client.ingest.deletePipeline({ id: topResources[key].pipeline.id })
-      } catch (err) {
-        // ignore
-      }
-    }
-  }
-  for (const key in topResources) {
-    if (topResources[key].enrich) {
-      try {
-        const policyName = topResources[key].enrich.policyName
-        logger.info(`Delete enrich policy ${policyName} if any.`)
-        await client.enrich.deletePolicy({
-          name: policyName
-        })
-      } catch (err) {
-      // ignore
-      }
-    }
-  }
-  for (const key in topResources) {
-    logger.info(`Delete index ${topResources[key].index} if any.`)
-    try {
-      await client.indices.delete({ index: topResources[key].index })
-    } catch (err) {
-    // ignore
-    }
-  }
-}
-
 /**
  * Check if elastic search is empty
  */
@@ -202,21 +55,7 @@ const clearData = async () => {
   }
 }
 
-if (!module.parent) {
-  const isForce = process.argv.length === 3 && process.argv[2] === 'force'
-
-  init(isForce).then(() => {
-    logger.info('done')
-    process.exit()
-  }).catch((e) => {
-    logger.logFullError(e)
-    process.exit()
-  })
-}
-
 module.exports = {
-  init,
-  clearES,
   checkEmpty,
   clearData
 }