server/migrations/2.5.0.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('CREATE TABLE `whatsapp_accounts` (' +
 160         ' `id` int(11) NOT NULL AUTO_INCREMENT,' +
 161         ' `name` varchar(255) NOT NULL,' +
 162         ' `key` varchar(255) NOT NULL,' +
 163         ' `remote` varchar(255) NOT NULL,' +
 164         ' `token` varchar(255) DEFAULT NULL,' +
 165         ' `phone` varchar(255) DEFAULT NULL,' +
 166         ' `type` enum(\'twilio\') DEFAULT NULL,' +
 167         ' `accountSid` varchar(255) DEFAULT NULL,' +
 168         ' `authToken` varchar(255) DEFAULT NULL,' +
 169         ' `notificationTemplate` text,' +
 170         ' `notificationSound` tinyint(1) DEFAULT \'0\',' +
 171         ' `notificationShake` tinyint(1) DEFAULT \'0\',' +
 172         ' `waitForTheAssignedAgent` int(11) DEFAULT \'10\',' +
 173         ' `queueTransfer` tinyint(1) DEFAULT \'0\',' +
 174         ' `queueTransferTimeout` int(11) DEFAULT \'300\',' +
 175         ' `agentTransfer` tinyint(1) DEFAULT \'0\',' +
 176         ' `agentTransferTimeout` int(11) DEFAULT \'300\',' +
 177         ' `mandatoryDispositionPauseId` int(11) DEFAULT NULL,' +
 178         ' `mandatoryDisposition` tinyint(1) DEFAULT \'0\',' +
 179         ' `description` varchar(255) DEFAULT NULL,' +
 180         ' `createdAt` datetime NOT NULL,' +
 181         ' `updatedAt` datetime NOT NULL,' +
 182         ' `ListId` int(11) DEFAULT NULL,' +
 183         ' PRIMARY KEY (`id`),' +
 184         ' UNIQUE KEY `name` (`name`),' +
 185         ' KEY `mandatoryDispositionPauseId` (`mandatoryDispositionPauseId`),' +
 186         ' KEY `ListId` (`ListId`),' +
 187         ' CONSTRAINT `whatsapp_accounts_ibfk_1` FOREIGN KEY (`mandatoryDispositionPauseId`) REFERENCES `tools_pauses` (`id`) ON DELETE NO ACTION ON UPDATE CASCADE,' +
 188         ' CONSTRAINT `whatsapp_accounts_ibfk_2` FOREIGN KEY (`ListId`) REFERENCES `cm_lists` (`id`) ON DELETE SET NULL ON UPDATE CASCADE' +
 189         ') ENGINE=InnoDB DEFAULT CHARSET=utf8;');
 190
 191       migration.addColumn('tools_dispositions', 'WhatsappAccountId', {
 192         type: Sequelize.INTEGER
 193       });
 194
 195       migration.addColumn('tools_canned_answers', 'WhatsappAccountId', {
 196         type: Sequelize.INTEGER
 197       });
 198
 199       migration.addColumn('users', 'whatsappPause', {
 200         type: Sequelize.BOOLEAN,
 201         defaultValue: false
 202       });
 203
 204       migration.addColumn('users', 'whatsappCapacity', {
 205         type: Sequelize.BOOLEAN,
 206         defaultValue: false
 207       });
 208
 209       migration.query('ALTER TABLE tools_dispositions ADD CONSTRAINT `tools_dispositions_ibfk_7` FOREIGN KEY (`WhatsappAccountId`) REFERENCES `whatsapp_accounts` (`id`) ON DELETE SET NULL ON UPDATE CASCADE');
 210       migration.query('ALTER TABLE tools_dispositions ADD CONSTRAINT `name_whatsapp` UNIQUE KEY (`name`,`WhatsappAccountId`)');
 211       migration.query('ALTER TABLE tools_canned_answers ADD CONSTRAINT `tools_canned_answers_ibfk_6` FOREIGN KEY (`WhatsappAccountId`) REFERENCES `whatsapp_accounts` (`id`) ON DELETE SET NULL ON UPDATE CASCADE');
 212
 213       migration.query('UPDATE users SET permissions=\'101,102,103,113,110,104,105,106,107,108,109,100,111,114\' WHERE role=\'agent\' AND permissions=\'101,102,103,110,104,105,106,107,108,109,100,111\'');
 214       // END whatsapp
 215
 216       // START chat_interactions
 217       migration.addColumn('chat_interactions', 'vidaooSessionId', {
 218         type: Sequelize.TEXT
 219       });
 220
 221       // START chat_websites
 222       migration.addColumn('chat_websites', 'vidaooEscalation', {
 223         type: Sequelize.BOOLEAN,
 224         defaultValue: false
 225       });
 226
 227       migration.addColumn('chat_websites', 'vidaooApiKey', {
 228         type: Sequelize.STRING
 229       });
 230       // END chat_websites
 231
 232       // START voice_recordings
 233       migration.addColumn('voice_recordings', 'location', {
 234         type: Sequelize.TEXT
 235       });
 236       migration.addColumn('voice_recordings', 'transcribeName', {
 237         type: Sequelize.STRING
 238       });
 239       migration.addColumn('voice_recordings', 'transcribeStatus', {
 240         type: Sequelize.STRING,
 241         defaultValue: 'NEW'
 242       });
 243       migration.addColumn('voice_recordings', 'fileUri', {
 244         type: Sequelize.TEXT
 245       });
 246       migration.addColumn('voice_recordings', 'fileText', {
 247         type: Sequelize.TEXT
 248       });
 249       migration.addColumn('voice_recordings', 'failureReason', {
 250         type: Sequelize.TEXT
 251       });
 252       migration.addColumn('voice_recordings', 'sentiment', {
 253         type: Sequelize.STRING
 254       });
 255       migration.addColumn('voice_recordings', 'sPositive', {
 256         type: Sequelize.FLOAT
 257       });
 258       migration.addColumn('voice_recordings', 'sNegative', {
 259         type: Sequelize.FLOAT
 260       });
 261       migration.addColumn('voice_recordings', 'sNeutral', {
 262         type: Sequelize.FLOAT
 263       });
 264       migration.addColumn('voice_recordings', 'sMixed', {
 265         type: Sequelize.FLOAT
 266       });
 267       migration.addColumn('voice_recordings', 'tempSentiment', {
 268         type: Sequelize.BOOLEAN
 269       });
 270       // END voice_recordings
 271
 272       // START settings
 273       migration.addColumn('settings', 'transcribe', {
 274         type: Sequelize.BOOLEAN
 275       });
 276       migration.addColumn('settings', 'automaticTranscribe', {
 277         type: Sequelize.BOOLEAN
 278       });
 279       migration.addColumn('settings', 'transcribeAccountId', {
 280         type: Sequelize.INTEGER
 281       });
 282       migration.addColumn('settings', 'transcribeRegion', {
 283         type: Sequelize.STRING
 284       });
 285       migration.addColumn('settings', 'sentiment', {
 286         type: Sequelize.BOOLEAN
 287       });
 288       migration.addColumn('settings', 'automaticSentiment', {
 289         type: Sequelize.BOOLEAN
 290       });
 291       migration.addColumn('settings', 'sentimentAccountId', {
 292         type: Sequelize.INTEGER
 293       });
 294       migration.addColumn('settings', 'sentimentRegion', {
 295         type: Sequelize.STRING
 296       });
 297       migration.addColumn('settings', 'language', {
 298         type: Sequelize.STRING
 299       });
 300       migration.addColumn('settings', 'bucket', {
 301         type: Sequelize.STRING
 302       });
 303       // END settings
 304
 305       // START FINAL
 306       migration.final(resolve);
 307       // END FINAL
 308     });
 309   },
 310
 311   down: function(queryInterface, Sequelize) {
 312     // var migration = new Migration(queryInterface);
 313   }
 314 };