server/migrations/2.0.34.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', 'key', {
 121                 type: Sequelize.STRING,
 122                 allowNull: false
 123             });
 124             migration.addColumn('chat_websites', 'forwardTranscriptMessage', {
 125                 type: Sequelize.STRING
 126             });
 127             migration.addColumn('chat_websites', 'skipMessageButton', {
 128                 type: Sequelize.STRING,
 129                 defaultValue: 'Skip'
 130             });
 131             migration.addColumn('chat_websites', 'enableFeedback', {
 132                 type: Sequelize.BOOLEAN,
 133                 defaultValue: false
 134             });
 135             migration.addColumn('chat_websites', 'enableCustomerWriting', {
 136                 type: Sequelize.BOOLEAN,
 137                 defaultValue: false
 138             });
 139             migration.addColumn('chat_websites', 'conditionAgreement', {
 140                 type: Sequelize.BOOLEAN,
 141                 defaultValue: false
 142             });
 143             migration.addColumn('chat_websites', 'waitingTitle', {
 144                 type: Sequelize.STRING,
 145                 defaultValue: 'All of our agents are busy at this time. Your chat is very important to us.'
 146             });
 147             migration.addColumn('chat_websites', 'waitingMessage', {
 148                 type: Sequelize.STRING,
 149                 defaultValue: 'Please hold and we will answer your request as soon as possible.'
 150             });
 151             migration.addColumn('chat_websites', 'autoclose', {
 152                 type: Sequelize.BOOLEAN,
 153                 defaultValue: true
 154             });
 155             migration.addColumn('chat_websites', 'unmanagedMessage', {
 156                 type: Sequelize.STRING,
 157                 defaultValue: 'Your request has not been processed.'
 158             });
 159             migration.addColumn('chat_websites', 'enableUnmanagedNote', {
 160                 type: Sequelize.BOOLEAN,
 161                 defaultValue: true
 162             });
 163             migration.addColumn('chat_websites', 'sendUnmanaged', {
 164                 type: Sequelize.STRING,
 165                 defaultValue: 'Send'
 166             });
 167             migration.addColumn('chat_websites', 'skipUnmanaged', {
 168                 type: Sequelize.STRING,
 169                 defaultValue: 'Skip'
 170             });
 171             migration.changeColumn('chat_websites', 'closingMessage', {
 172                 type: Sequelize.STRING,
 173                 defaultValue: 'Thanks you for your time!'
 174             });
 175             // END CHATWEBSITE
 176
 177             // START CHATINTERACTION
 178             migration.addColumn('chat_interactions', 'browserName', {
 179                 type: Sequelize.STRING
 180             });
 181             migration.addColumn('chat_interactions', 'browserVersion', {
 182                 type: Sequelize.STRING
 183             });
 184             migration.addColumn('chat_interactions', 'osName', {
 185                 type: Sequelize.STRING
 186             });
 187             migration.addColumn('chat_interactions', 'osVersion', {
 188                 type: Sequelize.STRING
 189             });
 190             migration.addColumn('chat_interactions', 'deviceModel', {
 191                 type: Sequelize.STRING
 192             });
 193             migration.addColumn('chat_interactions', 'deviceVendor', {
 194                 type: Sequelize.STRING
 195             });
 196             migration.addColumn('chat_interactions', 'deviceType', {
 197                 type: Sequelize.STRING
 198             });
 199             // END CHATINTERACTION
 200
 201             // START CHATMESSAGES
 202             migration.addColumn('chat_messages', 'AttachmentId', {
 203                 type: Sequelize.INTEGER
 204             });
 205             migration.query('ALTER TABLE `chat_messages` \
 206             ADD CONSTRAINT `chat_messages_ibfk_5` \
 207             FOREIGN KEY (`AttachmentId`) \
 208             REFERENCES attachments(`id`) \
 209             ON UPDATE CASCADE \
 210             ON DELETE SET NULL');
 211             // END CHATMESSAGES
 212
 213             // START RECALLME
 214             migration.addColumn('voice_queues', 'dialRecallMeTimeout', {
 215                 type: Sequelize.INTEGER(5).UNSIGNED,
 216                 defaultValue: 30
 217             });
 218             migration.addColumn('voice_queues', 'dialRecallInQueue', {
 219                 type: Sequelize.BOOLEAN,
 220                 defaultValue: false
 221             });
 222             migration.addColumn('cm_hopper', 'recallme', {
 223                 type: Sequelize.BOOLEAN,
 224                 defaultValue: false
 225             });
 226             migration.addColumn('cm_hopper_final', 'recallme', {
 227                 type: Sequelize.BOOLEAN,
 228                 defaultValue: false
 229             });
 230             migration.addColumn('cm_hopper_history', 'recallme', {
 231                 type: Sequelize.BOOLEAN,
 232                 defaultValue: false
 233             });
 234             // STOP RECALLME
 235
 236             // START RECORDINGS
 237             migration.addColumn('voice_recordings', 'userDisposition', {
 238                 type: Sequelize.STRING
 239             });
 240             // STOP RECORDINGS
 241
 242             // START EMAIL
 243             migration.dropTable('user_has_mail_rooms');
 244
 245             migration.query('ALTER TABLE mail_rooms DROP FOREIGN KEY mail_rooms_ibfk_1');
 246             migration.query('ALTER TABLE mail_rooms DROP COLUMN MailAccountId');
 247             migration.dropTable('mail_rooms');
 248
 249             migration.query('ALTER TABLE analytics_extracted_reports DROP FOREIGN KEY analytics_extracted_reports_ibfk_1');
 250             migration.query('ALTER TABLE mail_messages DROP COLUMN MailMessageId');
 251
 252             migration.query('ALTER TABLE mail_messages DROP FOREIGN KEY mail_messages_ibfk_1');
 253             migration.query('ALTER TABLE mail_messages DROP COLUMN MailRoomId');
 254             migration.query('ALTER TABLE mail_messages DROP FOREIGN KEY mail_messages_ibfk_2');
 255             migration.query('ALTER TABLE mail_messages DROP COLUMN UserId');
 256             migration.dropTable('mail_messages');
 257
 258             migration.dropTable('mail_attachments');
 259             migration.dropTable('mail_dispositions');
 260             migration.dropTable('mail_applications');
 261             migration.dropTable('user_has_mail_interactions');
 262             migration.dropTable('mail_interactions');
 263             migration.dropTable('team_has_mail_queues');
 264             migration.dropTable('user_has_mail_queues');
 265             migration.dropTable('mail_queues');
 266
 267             migration.removeColumn('mail_accounts', 'fidelity');
 268             migration.removeColumn('mail_accounts', 'timeout');
 269             migration.removeColumn('mail_accounts', 'whiteLabel');
 270             migration.removeColumn('mail_accounts', 'acceptUrl');
 271             migration.removeColumn('mail_accounts', 'rejectUrl');
 272             migration.removeColumn('mail_accounts', 'acceptMethod');
 273             migration.removeColumn('mail_accounts', 'rejectMethod');
 274             migration.removeColumn('mail_accounts', 'actions');
 275             migration.removeColumn('mail_accounts', 'closeUrl');
 276             migration.removeColumn('mail_accounts', 'closeMethod');
 277             migration.removeColumn('mail_accounts', 'signature');
 278             migration.removeColumn('mail_accounts', 'custom');
 279
 280             migration.addColumn('mail_accounts', 'active', {
 281                 type: Sequelize.BOOLEAN,
 282                 defaultValue: true
 283             });
 284
 285             migration.removeColumn('mail_servers_out', 'state');
 286
 287             migration.dropTable('mail_servers_in');
 288
 289             migration.query("CREATE TABLE `mail_interactions` ( \
 290       `id` int(11) NOT NULL AUTO_INCREMENT, \
 291       `closed` tinyint(1) DEFAULT '0', \
 292       `closedAt` datetime DEFAULT NULL, \
 293       `disposition` varchar(255) DEFAULT NULL, \
 294       `note` varchar(255) DEFAULT NULL, \
 295       `inReplyTo` varchar(190) DEFAULT NULL, \
 296       `to` varchar(255) DEFAULT NULL, \
 297       `cc` longtext, \
 298       `subject` text, \
 299       `createdAt` datetime NOT NULL, \
 300       `updatedAt` datetime NOT NULL, \
 301       `UserId` int(11) DEFAULT NULL, \
 302       `MailAccountId` int(11) DEFAULT NULL, \
 303       `ContactId` int(11) DEFAULT NULL, \
 304       PRIMARY KEY (`id`), \
 305       KEY `UserId` (`UserId`), \
 306       KEY `MailAccountId` (`MailAccountId`), \
 307       KEY `ContactId` (`ContactId`), \
 308       CONSTRAINT `mail_interactions_ibfk_1` FOREIGN KEY (`UserId`) REFERENCES `users` (`id`) ON DELETE SET NULL ON UPDATE CASCADE, \
 309       CONSTRAINT `mail_interactions_ibfk_2` FOREIGN KEY (`MailAccountId`) REFERENCES `mail_accounts` (`id`) ON DELETE SET NULL ON UPDATE CASCADE, \
 310       CONSTRAINT `mail_interactions_ibfk_3` FOREIGN KEY (`ContactId`) REFERENCES `cm_contacts` (`id`) ON UPDATE CASCADE \
 311     ) ENGINE=InnoDB DEFAULT CHARSET=utf8;");
 312
 313             migration.query("CREATE TABLE `mail_messages` ( \
 314               `id` int(11) NOT NULL AUTO_INCREMENT, \
 315               `body` longtext COLLATE utf8mb4_unicode_ci NOT NULL, \
 316               `read` tinyint(1) DEFAULT '0', \
 317               `direction` enum('in','out') COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT 'out', \
 318               `messageId` varchar(190) COLLATE utf8mb4_unicode_ci DEFAULT NULL, \
 319               `from` varchar(255) COLLATE utf8mb4_unicode_ci DEFAULT NULL, \
 320               `to` longtext COLLATE utf8mb4_unicode_ci, \
 321               `cc` longtext COLLATE utf8mb4_unicode_ci, \
 322               `bcc` longtext COLLATE utf8mb4_unicode_ci, \
 323               `subject` text COLLATE utf8mb4_unicode_ci, \
 324               `sentAt` datetime DEFAULT NULL, \
 325               `createdAt` datetime NOT NULL, \
 326               `updatedAt` datetime NOT NULL, \
 327               `MailAccountId` int(11) DEFAULT NULL, \
 328               `MailInteractionId` int(11) DEFAULT NULL, \
 329               `UserId` int(11) DEFAULT NULL, \
 330               `ContactId` int(11) DEFAULT NULL, \
 331               PRIMARY KEY (`id`), \
 332               KEY `MailAccountId` (`MailAccountId`), \
 333               KEY `MailInteractionId` (`MailInteractionId`), \
 334               KEY `UserId` (`UserId`), \
 335               KEY `ContactId` (`ContactId`), \
 336               KEY `messageId` (`messageId`), \
 337               CONSTRAINT `mail_messages_ibfk_1` FOREIGN KEY (`MailAccountId`) REFERENCES `mail_accounts` (`id`) ON DELETE SET NULL ON UPDATE CASCADE, \
 338               CONSTRAINT `mail_messages_ibfk_2` FOREIGN KEY (`MailInteractionId`) REFERENCES `mail_interactions` (`id`) ON DELETE CASCADE ON UPDATE CASCADE, \
 339               CONSTRAINT `mail_messages_ibfk_3` FOREIGN KEY (`UserId`) REFERENCES `users` (`id`) ON DELETE SET NULL ON UPDATE CASCADE, \
 340               CONSTRAINT `mail_messages_ibfk_4` FOREIGN KEY (`ContactId`) REFERENCES `cm_contacts` (`id`) ON DELETE CASCADE ON UPDATE CASCADE \
 341           ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;");
 342             // STOP EMAIL
 343
 344             // START ATTACHMENTS
 345             migration.query('CREATE TABLE `attachments` ( \
 346         `id` int(11) NOT NULL AUTO_INCREMENT, \
 347         `name` varchar(255) DEFAULT NULL, \
 348         `basename` varchar(255) DEFAULT NULL, \
 349         `type` varchar(255) DEFAULT NULL, \
 350         `createdAt` datetime NOT NULL, \
 351         `updatedAt` datetime NOT NULL, \
 352         `MailMessageId` int(11) DEFAULT NULL, \
 353         PRIMARY KEY (`id`), \
 354         KEY `MailMessageId` (`MailMessageId`), \
 355         CONSTRAINT `attachments_ibfk_1` FOREIGN KEY (`MailMessageId`) REFERENCES `mail_messages` (`id`) ON DELETE CASCADE ON UPDATE CASCADE \
 356       ) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8;');
 357
 358             migration.dropTable('fax_attachments');
 359             // END ATTACHMENTS
 360
 361             // START SMS ACCOUNT
 362             migration.addColumn('sms_accounts', 'phone', {
 363                 type: Sequelize.STRING
 364             });
 365             migration.addColumn('sms_accounts', 'accountSid', {
 366                 type: Sequelize.STRING
 367             });
 368             migration.addColumn('sms_accounts', 'authToken', {
 369                 type: Sequelize.STRING
 370             });
 371             migration.addColumn('sms_accounts', 'key', {
 372                 type: Sequelize.STRING,
 373                 allowNull: false
 374             });
 375             // END SMS ACCOUNT
 376
 377             // START COLLATE CHANGE
 378             migration.query('ALTER TABLE users CONVERT TO CHARACTER SET utf8 COLLATE utf8_bin;');
 379             // migration.query('ALTER TABLE voice_extensions CONVERT TO CHARACTER SET utf8 COLLATE utf8_bin;');
 380             //END COLLATE CHANGE
 381
 382             //START OPENCHANNEL
 383             migration.addColumn('openchannel_accounts', 'key', {
 384                 type: Sequelize.STRING,
 385                 allowNull: false
 386             });
 387             //END OPENCHANNEL
 388
 389             //START FAX
 390             migration.addColumn('fax_accounts', 'key', {
 391                 type: Sequelize.STRING,
 392                 allowNull: false
 393             });
 394             //END FAX
 395
 396             //START MAIL
 397             migration.addColumn('mail_accounts', 'key', {
 398                 type: Sequelize.STRING,
 399                 allowNull: false
 400             });
 401             //END MAIL
 402
 403             // START FINAL
 404             migration.final(resolve);
 405             // END FINAL
 406         });
 407     },
 408
 409     down: function(queryInterface, Sequelize) {
 410         var migration = new Migration(queryInterface);
 411     }
 412 };