server/migrations/2.0.51.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4 var fs = require('fs');
   5 var util = require('util');
   6 var _ = require('lodash');
   7
   8 var logger = require('../config/logger')('migration');
   9
  10 var Sequence = function() {};
  11
  12 Sequence.prototype.enqueue = function(fn) {
  13     this.tail = this.tail ? this.tail.finally(fn) : fn();
  14 };
  15
  16 var Migration = function(queryInterface) {
  17     this.queryInterface = queryInterface;
  18     this.sequence = new Sequence();
  19 };
  20
  21 Migration.prototype.changeColumn = function(table, column, type) {
  22     var _this = this;
  23     this.sequence.enqueue(function() {
  24         return _this.queryInterface
  25             .changeColumn(table, column, type)
  26             .then(function(res) {
  27                 logger.info('Changed column %s in table %s', column, table);
  28             })
  29             .catch(function(err) {
  30                 logger.info(JSON.stringify(err));
  31             });
  32     });
  33 };
  34
  35 Migration.prototype.addColumn = function(table, column, type) {
  36     var _this = this;
  37     this.sequence.enqueue(function() {
  38         return _this.queryInterface
  39             .addColumn(table, column, type)
  40             .then(function(res) {
  41                 logger.info('Added column %s to %s', column, table);
  42             })
  43             .catch(function(err) {
  44                 logger.info(JSON.stringify(err));
  45             });
  46     });
  47 };
  48
  49 Migration.prototype.dropTable = function(table) {
  50     var _this = this;
  51     this.sequence.enqueue(function() {
  52         return _this.queryInterface
  53             .dropTable(table, {
  54                 force: true
  55             })
  56             .then(function(res) {
  57                 logger.info('table dropped %s', table);
  58             })
  59             .catch(function(err) {
  60                 logger.info(JSON.stringify(err));
  61             });
  62     });
  63 };
  64
  65 Migration.prototype.addIndex = function(table, column, indexName) {
  66     var _this = this;
  67     this.sequence.enqueue(function() {
  68         return _this.queryInterface.addIndex(table, column, {
  69                 indexName: indexName
  70             })
  71             .then(function(res) {
  72                 logger.info('addIndex %s %s %s', table, column.join(','), indexName);
  73             })
  74             .catch(function(err) {
  75                 logger.info(JSON.stringify(err));
  76             });
  77     });
  78 };
  79
  80 Migration.prototype.query = function(sql) {
  81     var _this = this;
  82     this.sequence.enqueue(function() {
  83         return _this.queryInterface.sequelize.query(sql)
  84             .then(function(res) {
  85                 logger.info('query %s', sql);
  86             })
  87             .catch(function(err) {
  88                 logger.info(JSON.stringify(err));
  89             });
  90     });
  91 };
  92
  93 Migration.prototype.removeColumn = function(table, column) {
  94     var _this = this;
  95     this.sequence.enqueue(function() {
  96         return _this.queryInterface.removeColumn(table, column)
  97             .then(function(res) {
  98                 logger.info('Removed column %s from %s', column, table);
  99             })
 100             .catch(function(err) {
 101                 logger.info(util.inspect(err, {
 102                     showHidden: false,
 103                     depth: null
 104                 }));
 105             });
 106     });
 107 };
 108
 109 Migration.prototype.final = function(resolve) {
 110     var _this = this;
 111     this.sequence.enqueue(function() {
 112         return resolve();
 113     });
 114 };
 115
 116 module.exports = {
 117     up: function(queryInterface, Sequelize) {
 118         return new BPromise(function(resolve, reject) {
 119
 120             var migration = new Migration(queryInterface);
 121
 122             //START CHAT INTERNAL MESSAGES
 123             migration.addColumn('chat_internal_messages', 'ChatInternalMessageId', {
 124                 type: Sequelize.INTEGER
 125             });
 126             migration.addColumn('chat_internal_messages', 'ChatGroupId', {
 127                 type: Sequelize.INTEGER
 128             });
 129             migration.query('ALTER TABLE `chat_internal_messages` \
 130                 ADD CONSTRAINT `chat_internal_messages_ibfk_3` \
 131                 FOREIGN KEY (`ChatGroupId`) \
 132                 REFERENCES chat_groups(`id`) \
 133                 ON UPDATE CASCADE \
 134                 ON DELETE CASCADE');
 135             //END CHAT INTERNAL MESSAGES
 136
 137             // START CHAT INTERACTIONS
 138             migration.addColumn('chat_interactions', 'lastMsgDirection', {
 139                 type: Sequelize.ENUM('in', 'out'),
 140                 defaultValue: 'in',
 141                 allowNull: false
 142             });
 143             migration.addColumn('chat_interactions', 'lastMsgAt', {
 144                 type: Sequelize.DATE
 145             });
 146             // END CHAT INTERACTIONS
 147
 148             // START MAIL INTERACTIONS
 149             migration.addColumn('mail_interactions', 'lastMsgDirection', {
 150                 type: Sequelize.ENUM('in', 'out'),
 151                 defaultValue: 'in',
 152                 allowNull: false
 153             });
 154             migration.addColumn('mail_interactions', 'lastMsgAt', {
 155                 type: Sequelize.DATE
 156             });
 157             // END MAIL INTERACTIONS
 158
 159             // START SMS INTERACTIONS
 160             migration.addColumn('sms_interactions', 'lastMsgDirection', {
 161                 type: Sequelize.ENUM('in', 'out'),
 162                 defaultValue: 'in',
 163                 allowNull: false
 164             });
 165             migration.addColumn('sms_interactions', 'lastMsgAt', {
 166                 type: Sequelize.DATE
 167             });
 168             // END SMS INTERACTIONS
 169
 170             // START OPENCHANNEL INTERACTIONS
 171             migration.addColumn('openchannel_interactions', 'lastMsgDirection', {
 172                 type: Sequelize.ENUM('in', 'out'),
 173                 defaultValue: 'in',
 174                 allowNull: false
 175             });
 176             migration.addColumn('openchannel_interactions', 'lastMsgAt', {
 177                 type: Sequelize.DATE
 178             });
 179             // END OPENCHANNEL INTERACTIONS
 180
 181             // START FAX INTERACTIONS
 182             migration.addColumn('fax_interactions', 'lastMsgDirection', {
 183                 type: Sequelize.ENUM('in', 'out'),
 184                 defaultValue: 'in',
 185                 allowNull: false
 186             });
 187             migration.addColumn('fax_interactions', 'lastMsgAt', {
 188                 type: Sequelize.DATE
 189             });
 190             // END FAX INTERACTIONS
 191
 192             var channels = ['Chat', 'Mail', 'Sms', 'Openchannel'];
 193             for (var i = 0; i < channels.length; i++) {
 194               migration.query('UPDATE '+channels[i].toLowerCase()+'_interactions t1, (SELECT '+channels[i]+'InteractionId, MAX(id) AS messageid, ANY_VALUE(direction) AS direction, ANY_VALUE(createdAt) AS createdAt \
 195                   FROM '+channels[i].toLowerCase()+'_messages \
 196                   WHERE '+channels[i]+'InteractionId IS NOT NULL AND (direction=\'in\' OR (direction=\'out\' AND secret=0 AND UserId IS NOT NULL)) \
 197                   GROUP BY '+channels[i]+'InteractionId) t2 SET t1.lastMsgDirection = t2.direction, t1.lastMsgAt = t2.createdAt WHERE t1.id = t2.'+channels[i]+'InteractionId;');
 198             }
 199
 200             migration.query('UPDATE fax_interactions t1, (SELECT FaxInteractionId, MAX(id) AS messageid, ANY_VALUE(direction) AS direction, ANY_VALUE(createdAt) AS createdAt \
 201                 FROM fax_messages \
 202                 WHERE FaxInteractionId IS NOT NULL \
 203                 GROUP BY FaxInteractionId) t2 SET t1.lastMsgDirection = t2.direction, t1.lastMsgAt = t2.createdAt WHERE t1.id = t2.FaxInteractionId;');
 204
 205             // START SMS
 206             migration.changeColumn('sms_accounts', 'type', {
 207               type: Sequelize.ENUM('twilio', 'skebby', 'connectel')
 208             });
 209             // END SMS
 210
 211             // START VOICECALLREPORT
 212             migration.addColumn('report_call', 'note', {
 213                 type: Sequelize.STRING
 214             });
 215             // END VOICECALLREPORT
 216
 217             // START CM
 218             migration.addIndex('cm_contacts', ['phone'], 'phone');
 219             migration.addIndex('cm_hopper_final', ['uniqueid'], 'uniqueid');
 220             migration.addIndex('cm_hopper_history', ['uniqueid'], 'uniqueid');
 221             // END CM
 222
 223             //START VOICERECORDINGS
 224             migration.addIndex('voice_recordings', ['uniqueid'], 'uniqueid');
 225             //END VOICERECORDINGS
 226
 227             //START REPORTMEMBER
 228             migration.addIndex('report_member', ['membername', 'interface'], 'membername_interface');
 229             //END REPORTMEMBER
 230
 231             //START USERS
 232             migration.query('UPDATE users SET permissions=\'101,102,103,110,104,105,106,107,108,109,100\' WHERE permissions=\'101,102,103,104,105,106,107,108,109,100\'');
 233             //END USERS
 234
 235             // START DIALER
 236             migration.query("DELETE FROM `voice_extensions` WHERE exten = 'xcally-motion-dialer';");
 237
 238             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '1', 'NoOp', '', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 239
 240             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '2', 'set', 'CDR(type)=dialer', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 241
 242             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '3', 'set', 'CALLERID(all)=${XMD-CALLERID}', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 243
 244             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '4', 'gotoif', '$[\"${XMD-AMD}\" != \"NONE\" ]?5:11', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 245
 246             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '5', 'answer', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 247
 248             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '6', 'background', 'silence/1', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 249
 250             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '7', 'amd', '${XMD-AMDINITIALSILENCE},${XMD-AMDGREETING},${XMD-AMDAFTERGREETINGSILENCE},${XMD-AMDTOTALANALYSISTIME},${XMD-AMDMINWORDLENGTH},${XMD-AMDBETWEENWORDSSILENCE},${XMD-AMDMAXIMUMNUMBEROFWORDS},${XMD-AMDSILENCETHRESHOLD},${XMD-AMDMAXIMUMWORDLENGTH}', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 251
 252             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '8', 'gotoif', '$[\"${AMDSTATUS}\" == \"HUMAN\" ]?11:9', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 253
 254             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`,`createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '9', 'gotoif', '$[\"${AMDSTATUS}\" == \"NOTSURE\" ]?11:10', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 255
 256             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`,`createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '10', 'gotoif', '$[\"${AMDSTATUS}\" == \"MACHINE\" ]?14:11', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 257
 258             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '11', 'execif', '$[\"${XMD-AGI}\" != \"NONE\" ]?AGI(${XMD-AGI})', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 259
 260             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '12', 'execif', '$[\"${XMD-QUEUE}\" != \"NONE\" ]?QUEUE(${XMD-QUEUE})', 'system', 'Dialer extensions auto generated', NOW(), NOW());");
 261
 262             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '13', 'Execif', '$[\"${XMD-AGIAFTER}\" != \"NONE\" ]?AGI(${XMD-AGIAFTER})', 'system', 'dialer extensions auto generated', NOW(), NOW());");
 263
 264             migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-dialer', '14', 'hangup', 'system', 'dialer extensions auto generated', NOW(), NOW());");
 265             //END DIALER
 266
 267             // START FINAL
 268             migration.final(resolve);
 269             // END FINAL
 270         });
 271     },
 272
 273     down: function(queryInterface, Sequelize) {
 274         var migration = new Migration(queryInterface);
 275     }
 276 };