server/migrations/2.0.59.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4 var fs = require('fs');
   5 var path = require('path');
   6 var util = require('util');
   7 var _ = require('lodash');
   8
   9 var logger = require('../config/logger')('migration');
  10
  11 var Sequence = function() {};
  12
  13 Sequence.prototype.enqueue = function(fn) {
  14   this.tail = this.tail ? this.tail.finally(fn) : fn();
  15 };
  16
  17 var Migration = function(queryInterface) {
  18   this.queryInterface = queryInterface;
  19   this.sequence = new Sequence();
  20 };
  21
  22 Migration.prototype.changeColumn = function(table, column, type) {
  23   var _this = this;
  24   this.sequence.enqueue(function() {
  25     return _this.queryInterface
  26       .changeColumn(table, column, type)
  27       .then(function(res) {
  28         logger.info('Changed column %s in table %s', column, table);
  29       })
  30       .catch(function(err) {
  31         logger.info(JSON.stringify(err));
  32       });
  33   });
  34 };
  35
  36 Migration.prototype.addColumn = function(table, column, type) {
  37   var _this = this;
  38   this.sequence.enqueue(function() {
  39     return _this.queryInterface
  40       .addColumn(table, column, type)
  41       .then(function(res) {
  42         logger.info('Added column %s to %s', column, table);
  43       })
  44       .catch(function(err) {
  45         logger.info(JSON.stringify(err));
  46       });
  47   });
  48 };
  49
  50 Migration.prototype.dropTable = function(table) {
  51   var _this = this;
  52   this.sequence.enqueue(function() {
  53     return _this.queryInterface
  54       .dropTable(table, {
  55         force: true
  56       })
  57       .then(function(res) {
  58         logger.info('table dropped %s', table);
  59       })
  60       .catch(function(err) {
  61         logger.info(JSON.stringify(err));
  62       });
  63   });
  64 };
  65
  66 Migration.prototype.addIndex = function(table, column, indexName) {
  67   var _this = this;
  68   this.sequence.enqueue(function() {
  69     return _this.queryInterface.addIndex(table, column, {
  70         indexName: indexName
  71       })
  72       .then(function(res) {
  73         logger.info('addIndex %s %s %s', table, column.join(','), indexName);
  74       })
  75       .catch(function(err) {
  76         logger.info(JSON.stringify(err));
  77       });
  78   });
  79 };
  80
  81 Migration.prototype.query = function(sql) {
  82   var _this = this;
  83   this.sequence.enqueue(function() {
  84     return _this.queryInterface.sequelize.query(sql)
  85       .then(function(res) {
  86         logger.info('query %s', sql);
  87       })
  88       .catch(function(err) {
  89         logger.info(JSON.stringify(err));
  90       });
  91   });
  92 };
  93
  94 Migration.prototype.removeColumn = function(table, column) {
  95   var _this = this;
  96   this.sequence.enqueue(function() {
  97     return _this.queryInterface.removeColumn(table, column)
  98       .then(function(res) {
  99         logger.info('Removed column %s from %s', column, table);
 100       })
 101       .catch(function(err) {
 102         logger.info(util.inspect(err, {
 103           showHidden: false,
 104           depth: null
 105         }));
 106       });
 107   });
 108 };
 109
 110 Migration.prototype.renameColumn = function(table, oldColumn, newColumn) {
 111   var _this = this;
 112   this.sequence.enqueue(function() {
 113     return _this.queryInterface.renameColumn(table, oldColumn, newColumn)
 114       .then(function(res) {
 115         logger.info('Renamed column from %s to %s on %s', oldColumn, newColumn, table);
 116       })
 117       .catch(function(err) {
 118         logger.info(util.inspect(err, {
 119           showHidden: false,
 120           depth: null
 121         }));
 122       });
 123   });
 124 };
 125
 126 Migration.prototype.final = function(resolve) {
 127   var _this = this;
 128   this.sequence.enqueue(function() {
 129     return resolve();
 130   });
 131 };
 132
 133 module.exports = {
 134   up: function(queryInterface, Sequelize) {
 135     return new BPromise(function(resolve, reject) {
 136
 137       var migration = new Migration(queryInterface);
 138
 139       // START SETTINGS
 140       migration.addColumn('settings', 'phoneBarAutoUpdater', {
 141         type: Sequelize.BOOLEAN,
 142         defaultValue: true
 143       });
 144       migration.addColumn('settings', 'phoneBarAutoUpdaterUrl', {
 145         type: Sequelize.STRING,
 146         defaultValue: 'https://www.xcally.com/bar/phonebar/autoupdater.xml'
 147       });
 148       // END SETTINGS
 149
 150       // START PREFIX
 151       migration.addColumn('campaigns', 'dialPrefix', {
 152         type: Sequelize.STRING
 153       });
 154       // END PREFIX
 155
 156       // START CM LIST
 157       migration.addColumn('cm_lists', 'dialPrefix', {
 158         type: Sequelize.STRING
 159       });
 160       // END CM LIST
 161
 162       // START USER
 163       migration.addColumn('users', 'alias', {
 164         type: Sequelize.STRING
 165       });
 166       // END USER
 167
 168       // START CM CONTACTS
 169       migration.addColumn('cm_contacts', 'skype', {
 170         type: Sequelize.STRING
 171       });
 172       migration.addColumn('cm_contacts', 'UserId', {
 173         type: Sequelize.INTEGER
 174       });
 175       migration.addColumn('cm_contacts', 'priority', {
 176         type: Sequelize.INTEGER(2).UNSIGNED,
 177         defaultValue: 2,
 178         validate: {
 179           min: 0,
 180           max: 4
 181         }
 182       });
 183       migration.addColumn('cm_contacts', 'scheduledat', {
 184         type: Sequelize.DATE,
 185         defaultValue: Sequelize.NOW
 186       });
 187       // END CM CONTACTS
 188
 189       // START MAIL INTERACTION
 190       migration.addColumn('mail_interactions', 'openedBy', {
 191         type: Sequelize.STRING,
 192         defaultValue: ''
 193       });
 194       // END MAIL INTERACTION
 195
 196       // START CHAT INTERACTION
 197       migration.addColumn('chat_interactions', 'openedBy', {
 198         type: Sequelize.STRING,
 199         defaultValue: ''
 200       });
 201       // END CHAT INTERACTION
 202
 203       // START SMS INTERACTION
 204       migration.addColumn('sms_interactions', 'openedBy', {
 205         type: Sequelize.STRING,
 206         defaultValue: ''
 207       });
 208       // END SMS INTERACTION
 209
 210       // START OPENCHANNEL INTERACTION
 211       migration.addColumn('openchannel_interactions', 'openedBy', {
 212         type: Sequelize.STRING,
 213         defaultValue: ''
 214       });
 215       // END OPENCHANNEL INTERACTION
 216
 217       // START FAX INTERACTION
 218       migration.addColumn('fax_interactions', 'openedBy', {
 219         type: Sequelize.STRING,
 220         defaultValue: ''
 221       });
 222       // END FAX INTERACTION
 223
 224       // START VOICEMAIL
 225       migration.query('DELETE FROM `voice_voicemail_messages` WHERE `mailboxuser` NOT IN (SELECT `mailbox` FROM `voice_voicemail`)');
 226
 227       migration.query('ALTER TABLE `voice_voicemail_messages` \
 228       ADD CONSTRAINT `voice_voicemail_messages_ibfk_1` \
 229       FOREIGN KEY (`mailboxuser`) \
 230       REFERENCES voice_voicemail(`mailbox`) \
 231       ON UPDATE CASCADE \
 232       ON DELETE CASCADE');
 233       // END VOICEMAIL
 234
 235       // START FINAL
 236       migration.final(resolve);
 237       // END FINAL
 238     });
 239   },
 240
 241   down: function(queryInterface, Sequelize) {
 242     var migration = new Migration(queryInterface);
 243   }
 244 };