server/migrations/2.5.2.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4 var util = require('util');
   5
   6 var logger = require('../config/logger')('migration');
   7
   8 var Sequence = function() {};
   9
  10 Sequence.prototype.enqueue = function(fn) {
  11   this.tail = this.tail ? this.tail.finally(fn) : fn();
  12 };
  13
  14 var Migration = function(queryInterface) {
  15   this.queryInterface = queryInterface;
  16   this.sequence = new Sequence();
  17 };
  18
  19 Migration.prototype.changeColumn = function(table, column, type) {
  20   var _this = this;
  21   this.sequence.enqueue(function() {
  22     return _this.queryInterface
  23       .changeColumn(table, column, type)
  24       .then(function() {
  25         logger.info('Changed column %s in table %s', column, table);
  26       })
  27       .catch(function(err) {
  28         logger.info(JSON.stringify(err));
  29       });
  30   });
  31 };
  32
  33 Migration.prototype.addColumn = function(table, column, type) {
  34   var _this = this;
  35   this.sequence.enqueue(function() {
  36     return _this.queryInterface
  37       .addColumn(table, column, type)
  38       .then(function() {
  39         logger.info('Added column %s to %s', column, table);
  40       })
  41       .catch(function(err) {
  42         logger.info(JSON.stringify(err));
  43       });
  44   });
  45 };
  46
  47 Migration.prototype.dropTable = function(table) {
  48   var _this = this;
  49   this.sequence.enqueue(function() {
  50     return _this.queryInterface
  51       .dropTable(table, {
  52         force: true
  53       })
  54       .then(function() {
  55         logger.info('table dropped %s', table);
  56       })
  57       .catch(function(err) {
  58         logger.info(JSON.stringify(err));
  59       });
  60   });
  61 };
  62
  63 Migration.prototype.addIndex = function(table, column, options) {
  64   var _this = this;
  65   this.sequence.enqueue(function() {
  66     return _this.queryInterface
  67       .addIndex(table, column, {
  68         indexName: options.indexName,
  69         indicesType: options.indicesType
  70       })
  71       .then(function() {
  72         logger.info('addIndex %s %s %s [%s]', table, column.join(','), options.indexName, options.indicesType);
  73       })
  74       .catch(function(err) {
  75         logger.info(JSON.stringify(err));
  76       });
  77   });
  78 };
  79
  80 Migration.prototype.removeIndex = function(table, indexName) {
  81   var _this = this;
  82   this.sequence.enqueue(function() {
  83     return _this.queryInterface
  84       .removeIndex(table, indexName)
  85       .then(function() {
  86         logger.info('removeIndex %s %s', table, indexName);
  87       })
  88       .catch(function(err) {
  89         logger.info(JSON.stringify(err));
  90       });
  91   });
  92 };
  93
  94 Migration.prototype.query = function(sql) {
  95   var _this = this;
  96   this.sequence.enqueue(function() {
  97     return _this.queryInterface.sequelize
  98       .query(sql)
  99       .then(function() {
 100         logger.info('query %s', sql);
 101       })
 102       .catch(function(err) {
 103         logger.info(JSON.stringify(err));
 104       });
 105   });
 106 };
 107
 108 Migration.prototype.removeColumn = function(table, column) {
 109   var _this = this;
 110   this.sequence.enqueue(function() {
 111     return _this.queryInterface
 112       .removeColumn(table, column)
 113       .then(function() {
 114         logger.info('Removed column %s from %s', column, table);
 115       })
 116       .catch(function(err) {
 117         logger.info(
 118           util.inspect(err, {
 119             showHidden: false,
 120             depth: null
 121           })
 122         );
 123       });
 124   });
 125 };
 126
 127 Migration.prototype.renameColumn = function(table, oldColumn, newColumn) {
 128   var _this = this;
 129   this.sequence.enqueue(function() {
 130     return _this.queryInterface
 131       .renameColumn(table, oldColumn, newColumn)
 132       .then(function() {
 133         logger.info('Renamed column from %s to %s on %s', oldColumn, newColumn, table);
 134       })
 135       .catch(function(err) {
 136         logger.info(
 137           util.inspect(err, {
 138             showHidden: false,
 139             depth: null
 140           })
 141         );
 142       });
 143   });
 144 };
 145
 146 Migration.prototype.final = function(resolve) {
 147   this.sequence.enqueue(function() {
 148     return resolve();
 149   });
 150 };
 151
 152 module.exports = {
 153   up: function(queryInterface, Sequelize) {
 154     return new BPromise(function(resolve) {
 155
 156       var migration = new Migration(queryInterface);
 157
 158       // START whatsapp
 159       migration.query('ALTER TABLE whatsapp_accounts ENCRYPTION=\'Y\';');
 160       migration.query('ALTER TABLE whatsapp_interactions ENCRYPTION=\'Y\';');
 161       migration.query('ALTER TABLE whatsapp_messages ENCRYPTION=\'Y\';');
 162       migration.query('ALTER TABLE report_whatsapp_queue ENCRYPTION=\'Y\';');
 163       // END whatsapp
 164
 165       // START cloud_providers
 166       migration.query('ALTER TABLE cloud_providers ENCRYPTION=\'Y\';');
 167       // END cloud_providers
 168
 169       // START voice_extensions
 170       migration.query('ALTER TABLE voice_extensions DROP FOREIGN KEY voice_extensions_ibfk_7');
 171       migration.query('ALTER TABLE voice_extensions DROP INDEX voice_extensions_ibfk_7');
 172       migration.query('ALTER TABLE voice_extensions ADD CONSTRAINT voice_extensions_ibfk_7 FOREIGN KEY (VoicePrefixId) REFERENCES voice_prefixes(id) ON UPDATE CASCADE ON DELETE CASCADE');
 173       // END  voice_extensions
 174
 175       //START voice_queues
 176       migration.addColumn('voice_queues', 'dialNoSuchNumberMaxRetry', {
 177         type: Sequelize.INTEGER,
 178         defaultValue: 3
 179       });
 180       migration.addColumn('voice_queues', 'dialNoSuchNumberRetryFrequency', {
 181         type: Sequelize.INTEGER,
 182         defaultValue: 150
 183       });
 184
 185       migration.addColumn('voice_queues', 'dialDropMaxRetry', {
 186         type: Sequelize.INTEGER,
 187         defaultValue: 3
 188       });
 189       migration.addColumn('voice_queues', 'dialDropRetryFrequency', {
 190         type: Sequelize.INTEGER,
 191         defaultValue: 150
 192       });
 193
 194       migration.addColumn('voice_queues', 'dialAbandonedMaxRetry', {
 195         type: Sequelize.INTEGER,
 196         defaultValue: 3
 197       });
 198       migration.addColumn('voice_queues', 'dialAbandonedRetryFrequency', {
 199         type: Sequelize.INTEGER,
 200         defaultValue: 150
 201       });
 202
 203       migration.addColumn('voice_queues', 'dialMachineMaxRetry', {
 204         type: Sequelize.INTEGER,
 205         defaultValue: 3
 206       });
 207       migration.addColumn('voice_queues', 'dialMachineRetryFrequency', {
 208         type: Sequelize.INTEGER,
 209         defaultValue: 150
 210       });
 211
 212       migration.addColumn('voice_queues', 'dialAgentRejectMaxRetry', {
 213         type: Sequelize.INTEGER,
 214         defaultValue: 3
 215       });
 216       migration.addColumn('voice_queues', 'dialAgentRejectRetryFrequency', {
 217         type: Sequelize.INTEGER,
 218         defaultValue: 150
 219       });
 220       //END voice_queues
 221
 222       //START campaigns
 223       migration.addColumn('campaigns', 'dialNoSuchNumberMaxRetry', {
 224         type: Sequelize.INTEGER,
 225         defaultValue: 3
 226       });
 227       migration.addColumn('campaigns', 'dialNoSuchNumberRetryFrequency', {
 228         type: Sequelize.INTEGER,
 229         defaultValue: 150
 230       });
 231       migration.addColumn('campaigns', 'dialDropMaxRetry', {
 232         type: Sequelize.INTEGER,
 233         defaultValue: 3
 234       });
 235       migration.addColumn('campaigns', 'dialDropRetryFrequency', {
 236         type: Sequelize.INTEGER,
 237         defaultValue: 150
 238       });
 239       migration.addColumn('campaigns', 'dialAbandonedMaxRetry', {
 240         type: Sequelize.INTEGER,
 241         defaultValue: 3
 242       });
 243       migration.addColumn('campaigns', 'dialAbandonedRetryFrequency', {
 244         type: Sequelize.INTEGER,
 245         defaultValue: 150
 246       });
 247       migration.addColumn('campaigns', 'dialMachineMaxRetry', {
 248         type: Sequelize.INTEGER,
 249         defaultValue: 3
 250       });
 251       migration.addColumn('campaigns', 'dialMachineRetryFrequency', {
 252         type: Sequelize.INTEGER,
 253         defaultValue: 150
 254       });
 255       migration.addColumn('campaigns', 'dialAgentRejectMaxRetry', {
 256         type: Sequelize.INTEGER,
 257         defaultValue: 3
 258       });
 259       migration.addColumn('campaigns', 'dialAgentRejectRetryFrequency', {
 260         type: Sequelize.INTEGER,
 261         defaultValue: 150
 262       });
 263       //END campaigns
 264
 265       //START cm_hopper
 266       migration.addColumn('cm_hopper', 'countnosuchnumberretry', {
 267         type: Sequelize.INTEGER,
 268         defaultValue: 0
 269       });
 270       migration.addColumn('cm_hopper', 'countdropretry', {
 271         type: Sequelize.INTEGER,
 272         defaultValue: 0
 273       });
 274       migration.addColumn('cm_hopper', 'countabandonedretry', {
 275         type: Sequelize.INTEGER,
 276         defaultValue: 0
 277       });
 278       migration.addColumn('cm_hopper', 'countmachineretry', {
 279         type: Sequelize.INTEGER,
 280         defaultValue: 0
 281       });
 282       migration.addColumn('cm_hopper', 'countagentrejectretry', {
 283         type: Sequelize.INTEGER,
 284         defaultValue: 0
 285       });
 286       //END cm_hopper
 287
 288       //START cm_hopper_final
 289       migration.addColumn('cm_hopper_final', 'countnosuchnumberretry', {
 290         type: Sequelize.INTEGER,
 291         defaultValue: 0
 292       });
 293       migration.addColumn('cm_hopper_final', 'countdropretry', {
 294         type: Sequelize.INTEGER,
 295         defaultValue: 0
 296       });
 297       migration.addColumn('cm_hopper_final', 'countabandonedretry', {
 298         type: Sequelize.INTEGER,
 299         defaultValue: 0
 300       });
 301       migration.addColumn('cm_hopper_final', 'countmachineretry', {
 302         type: Sequelize.INTEGER,
 303         defaultValue: 0
 304       });
 305       migration.addColumn('cm_hopper_final', 'countagentrejectretry', {
 306         type: Sequelize.INTEGER,
 307         defaultValue: 0
 308       });
 309       //END cm_hopper_final
 310
 311       //START cm_hopper_history
 312       migration.addColumn('cm_hopper_history', 'countnosuchnumberretry', {
 313         type: Sequelize.INTEGER,
 314         defaultValue: 0
 315       });
 316       migration.addColumn('cm_hopper_history', 'countdropretry', {
 317         type: Sequelize.INTEGER,
 318         defaultValue: 0
 319       });
 320       migration.addColumn('cm_hopper_history', 'countabandonedretry', {
 321         type: Sequelize.INTEGER,
 322         defaultValue: 0
 323       });
 324       migration.addColumn('cm_hopper_history', 'countmachineretry', {
 325         type: Sequelize.INTEGER,
 326         defaultValue: 0
 327       });
 328       migration.addColumn('cm_hopper_history', 'countagentrejectretry', {
 329         type: Sequelize.INTEGER,
 330         defaultValue: 0
 331       });
 332       //END cm_hopper_history
 333
 334       // START FINAL
 335       migration.final(resolve);
 336       // END FINAL
 337     });
 338   },
 339
 340   down: function(queryInterface, Sequelize) {
 341     // var migration = new Migration(queryInterface);
 342   }
 343 };