category-insertion.js

const pratilipisToAdd = require('./json-data/added_categories');
const pratilipisToUpdate = require('./json-data/updated_categories');
const pratilipisToDelete = require('./json-data/deleted_categories');
var parameterStoreAccessor = require('./helpers/ParameterStoreAccessor');
var CategoryService;
function startInsertion() {
    // CategoryService.updateNames(pratilipisToUpdate)
  // CategoryService.addNewSystemCategories(pratilipisToAdd)
    CategoryService.addNewSystemCategories(pratilipisToAdd)
    .then(() => {
        console.log('All categories successfully added.');
         return CategoryService.updateNames(pratilipisToUpdate);
    })
    .then(() => {
      console.log('All categories successfully updated.');
      return CategoryService.markSystemCategoriesAsSuggested(pratilipisToDelete);
    })
    .then(() => {
      console.log('All categories successfully deleted.');
      process.exit();
    })
    .catch((err) => {
      console.log(`[ERROR OCCURED] ${err}`);
      process.exit();
    })
    ;
}


parameterStoreAccessor.getMySqlDbCredentials()
  .then(config => {
    Object.assign(process.env, config);
    var models = require('./sequelize-models');
    CategoryService = require('./CategoryIngestionService');
    return models.sequelize.authenticate();
  })
  .then(() => {
    startInsertion();
  })
  ;