configure.js

/**
 * Created by Eabasir on 31/01/2017.
 */
const models = require('./mongo/models.mongo');
const db = require('./mongo/index');
const _const = require('./lib/const.list');
const env = require('./env');
const fs = require('fs');
const appPages = {feed: true, my_shop: true};
const copydir = require('copy-dir');
const warehouses = require('./warehouses');
const offlineWarehouses = require('./offlineWarehouses');
const deliveryDurationInfo = require('./deliveryDurationInfo');
const helpers = require('./lib/helpers')

let PLACEMENTS = null;
let pKeys = [];
let _hash;

db.dbIsReady()
  .then(async () => {
    try {
      await modelIsReady();
      copydir.sync('assets', 'public/assets');

      let res = await models()['Warehouse'].find().lean();
      if (!res || res.length === 0) {
        await models()['Warehouse'].insertMany(warehouses);
        console.log('-> ', 'warehouses are added');
      }
      
      res = await models()['OfflineWarehouse'].find().lean();
      if (!res || res.length === 0) {
        await models()['OfflineWarehouse'].insertMany(offlineWarehouses);
        console.log('-> ', 'offline warehouses are added');
      }

      res = await models()['DeliveryDurationInfo'].find().lean();
      if (!res || res.length === 0) {
        await models()['DeliveryDurationInfo'].insertMany(deliveryDurationInfo);
        console.log('-> ', 'delivery duaraion info are added');
      }

      const defulatPassHash = await helpers.makeHash('admin@123');

      return Promise.resolve(defulatPassHash);

    } catch (err) {
      console.log('-> ', err);
      process.exit();
    }

  })
  .then(hash => {
    _hash = hash;
    return models()['Agent'].find().lean();

  })
  .then(res => {
    if (!res || res.length === 0) {
      let agents = [{
        username: 'admin@persianmode.com',
        secret: _hash,
        access_level: _const.ACCESS_LEVEL.ContentManager,
        first_name: 'Content',
        surname: 'Manager',
      }, {
        username: 'sm@persianmode.com',
        secret: _hash,
        access_level: _const.ACCESS_LEVEL.SalesManager,
        first_name: 'Sales',
        surname: 'Manager',
      }, {
        username: 'hc@persianmode.com',
        secret: _hash,
        access_level: _const.ACCESS_LEVEL.HubClerk,
        first_name: 'hub',
        surname: 'clerck',
      }, {
        username: 'shop@persianmode.com',
        secret: _hash,
        access_level: _const.ACCESS_LEVEL.ShopClerk,
        first_name: 'shop',
        surname: 'clerck',
      },
      {
        username: 'idelivery@persianmode.com',
        secret: _hash,
        access_level: _const.ACCESS_LEVEL.InternalDeliveryAgent,
        first_name: 'internal delivery',
        surname: 'agent',
      },
      {
        username: 'delivery@persianmode.com',
        secret: _hash,
        access_level: _const.ACCESS_LEVEL.DeliveryAgent,
        first_name: 'delivery',
        surname: 'agent',
      },
      {
        username: 'offline@persianmode.com',
        secret: _hash,
        access_level: _const.ACCESS_LEVEL.OfflineSystem,
        first_name: 'offline',
        surname: 'system',
      }];

      return models()['Agent'].insertMany(agents);
    } else
      return Promise.resolve()
  })
  .then(() => {
    console.log('-> ', 'default agents has been added!');

    return models()['Page'].find().lean();
  })
  .then(res => {
    if (res && res.length)
      return Promise.resolve();

    PLACEMENTS = JSON.parse(fs.readFileSync('placements.json', 'utf8'));
    pKeys = Object.keys(PLACEMENTS);
    return Promise.all(pKeys.map((r, i) => {
      let isApp = !!appPages[r];
      console.log(`-> ${isApp ? 'app' : 'website'} page: '${r}' is added.`);
      let query = {address: r},
        update = {
          address: r,
          is_app: isApp,
          placement: PLACEMENTS[r]
        },

        options = {upsert: true, new: true, setDefaultsOnInsert: true};
      return models()['Page'].findOneAndUpdate(query, update, options);
    }))
  })
  .then(() => {
    console.log('-> ', 'default placements are added!');
    return models()['LoyaltyGroup'].find().lean();
  })
  .then(res => {
    if (!res || !res.length)
      return models()['LoyaltyGroup'].insertMany([
        {
          name: 'White',
          min_score: 0,
        },
        {
          name: 'Orange',
          min_score: 5000,
        },
        {
          name: 'Black',
          min_score: 11000,
        }
      ], {ordered: false});

    return Promise.resolve();
  })
  .then(res => {
    console.log('-> ', 'loyalty groups are added');
    let dictionary = JSON.parse(fs.readFileSync('dictionary.json', 'utf8'));

    let data = [];

    Object.keys(dictionary).forEach(type => {

      let typeData = dictionary[type];

      data = data.concat(Object.keys(typeData).map(name => {
        return {
          type,
          name,
          value: typeData[name]
        }
      }));
    });


    return models()['Dictionary'].insertMany(data, {ordered: false});
  })
  .then(res => {
    console.log('-> ', 'dictionary is added');
    process.exit();
  })
  .catch(err => {
    console.log(err);

    if (err.name !== 'BulkWriteError') {
      console.log('-> ', err);
    }
    else {
      console.log('-> ', 'dictionary is added');
    }
    process.exit();
  }
  );


modelIsReady = () => {
  return new Promise((resolve, reject) => {

    getModels = () => {

      setTimeout(() => {
        if (!models() || models().length)
          getModels();
        else
          resolve();
      }, 500);

    }
    getModels();
  })
}