server/migrations/2.0.44.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4
   5 var logger = require('../config/logger')('migration');
   6 var util = require('util');
   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(res) {
  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(res) {
  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(res) {
  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, indexName) {
  64   var _this = this;
  65   this.sequence.enqueue(function() {
  66     return _this.queryInterface.addIndex(table, column, {
  67         indexName: indexName
  68       })
  69       .then(function(res) {
  70         logger.info('addIndex %s %s %s', table, column.join(','), indexName);
  71       })
  72       .catch(function(err) {
  73         logger.info(JSON.stringify(err));
  74       });
  75   });
  76 };
  77
  78 Migration.prototype.query = function(sql) {
  79   var _this = this;
  80   this.sequence.enqueue(function() {
  81     return _this.queryInterface.sequelize.query(sql)
  82       .then(function(res) {
  83         logger.info('query %s', sql);
  84       })
  85       .catch(function(err) {
  86         logger.info(JSON.stringify(err));
  87       });
  88   });
  89 };
  90
  91 Migration.prototype.removeColumn = function(table, column) {
  92   var _this = this;
  93   this.sequence.enqueue(function() {
  94     return _this.queryInterface.removeColumn(table, column)
  95       .then(function(res) {
  96         logger.info('Removed column %s from %s', column, table);
  97       })
  98       .catch(function(err) {
  99         logger.info(util.inspect(err, {
 100           showHidden: false,
 101           depth: null
 102         }));
 103       });
 104   });
 105 };
 106
 107 Migration.prototype.final = function(resolve) {
 108   var _this = this;
 109   this.sequence.enqueue(function() {
 110     return resolve();
 111   });
 112 };
 113
 114 module.exports = {
 115   up: function(queryInterface, Sequelize) {
 116     return new BPromise(function(resolve, reject) {
 117       var migration = new Migration(queryInterface);
 118
 119       // START CHATWEBSITE
 120       migration.addColumn('chat_websites', 'closingQuestion', {
 121         type: Sequelize.STRING,
 122         defaultValue: 'Do you want to close the interaction?'
 123       });
 124       // END CHATWEBSITE
 125
 126       // START CHAT INTERACTIONS
 127       migration.addColumn('chat_interactions', 'read1stAt', {
 128         type: Sequelize.DATE
 129       });
 130       // END CHAT INTERACTIONS
 131
 132       // START CHAT MESSAGES
 133       migration.addColumn('chat_messages', 'readAt', {
 134         type: Sequelize.DATE
 135       });
 136       // END CHAT MESSAGES
 137
 138       // START FAX INTERACTIONS
 139       migration.addColumn('fax_interactions', 'read1stAt', {
 140         type: Sequelize.DATE
 141       });
 142       // END FAX INTERACTIONS
 143
 144       // START FAX MESSAGES
 145       migration.addColumn('fax_messages', 'readAt', {
 146         type: Sequelize.DATE
 147       });
 148       // END FAX MESSAGES
 149
 150       // START OPENCHANNEL INTERACTIONS
 151       migration.addColumn('openchannel_interactions', 'read1stAt', {
 152         type: Sequelize.DATE
 153       });
 154       migration.addColumn('openchannel_interactions', 'threadId', {
 155         type: Sequelize.STRING
 156       });
 157       migration.addColumn('openchannel_interactions', 'externalUrl', {
 158         type: Sequelize.STRING
 159       });
 160       // END OPENCHANNEL INTERACTIONS
 161
 162       // START OPENCHANNEL MESSAGES
 163       migration.addColumn('openchannel_messages', 'readAt', {
 164         type: Sequelize.DATE
 165       });
 166       // END OPENCHANNEL MESSAGES
 167
 168       // START MAIL INTERACTIONS
 169       migration.addColumn('mail_interactions', 'read1stAt', {
 170         type: Sequelize.DATE
 171       });
 172       migration.addColumn('mail_interactions', 'substatus', {
 173         type: Sequelize.STRING(60)
 174       });
 175       migration.addColumn('mail_interactions', 'substatusAt', {
 176         type: Sequelize.DATE
 177       });
 178       // END MAIL INTERACTIONS
 179
 180       // START MAIL MESSAGES
 181       migration.addColumn('mail_messages', 'readAt', {
 182         type: Sequelize.DATE
 183       });
 184       // END MAIL MESSAGES
 185
 186       // START SMS INTERACTIONS
 187       migration.addColumn('sms_interactions', 'read1stAt', {
 188         type: Sequelize.DATE
 189       });
 190       // END SMS INTERACTIONS
 191
 192       // START SMS MESSAGES
 193       migration.addColumn('sms_messages', 'readAt', {
 194         type: Sequelize.DATE
 195       });
 196       // END SMS MESSAGES
 197
 198       // START DISPOSITIONS
 199       migration.changeColumn('chat_dispositions', 'name', {
 200         type: Sequelize.STRING,
 201         unique: 'nameAndAccount',
 202         allowNull: false
 203       });
 204       migration.changeColumn('fax_dispositions', 'name', {
 205         type: Sequelize.STRING,
 206         unique: 'nameAndAccount',
 207         allowNull: false
 208       });
 209       migration.changeColumn('openchannel_dispositions', 'name', {
 210         type: Sequelize.STRING,
 211         unique: 'nameAndAccount',
 212         allowNull: false
 213       });
 214       migration.changeColumn('sms_dispositions', 'name', {
 215         type: Sequelize.STRING,
 216         unique: 'nameAndAccount',
 217         allowNull: false
 218       });
 219       migration.changeColumn('voice_dispositions', 'name', {
 220         type: Sequelize.STRING,
 221         unique: 'nameAndAccount',
 222         allowNull: false
 223       });
 224       migration.query('ALTER TABLE chat_dispositions add UNIQUE INDEX nameAndAccount (name, ChatAccountId)');
 225       migration.query('ALTER TABLE fax_dispositions add UNIQUE INDEX nameAndAccount (name, FaxAccountId)');
 226       migration.query('ALTER TABLE openchannel_dispositions add UNIQUE INDEX nameAndAccount (name, OpenchannelAccountId)');
 227       migration.query('ALTER TABLE sms_dispositions add UNIQUE INDEX nameAndAccount (name, SmsAccountId)');
 228       migration.query('ALTER TABLE voice_dispositions add UNIQUE INDEX nameAndAccount (name, ListId)');
 229       migration.changeColumn('mail_dispositions', 'name', {
 230         type: Sequelize.STRING,
 231         unique: 'nameAndAccount',
 232         allowNull: false
 233       });
 234       migration.query('ALTER TABLE mail_dispositions DROP INDEX name');
 235       migration.query('ALTER TABLE mail_dispositions add UNIQUE INDEX nameAndAccount (name, MailAccountId)');
 236       // END DISPOSITIONS
 237
 238       // START FINAL
 239       migration.final(resolve);
 240       // END FINAL
 241     });
 242   },
 243
 244   down: function(queryInterface, Sequelize) {
 245     var migration = new Migration(queryInterface);
 246   }
 247 };