server/migrations/2.0.63.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4 var rs = require('randomstring');
   5 var util = require('util');
   6
   7 var logger = require('../config/logger')('migration');
   8
   9 var Sequence = function() {};
  10
  11 Sequence.prototype.enqueue = function(fn) {
  12   this.tail = this.tail ? this.tail.finally(fn) : fn();
  13 };
  14
  15 var Migration = function(queryInterface) {
  16   this.queryInterface = queryInterface;
  17   this.sequence = new Sequence();
  18 };
  19
  20 Migration.prototype.changeColumn = function(table, column, type) {
  21   var _this = this;
  22   this.sequence.enqueue(function() {
  23     return _this.queryInterface
  24       .changeColumn(table, column, type)
  25       .then(function(res) {
  26         logger.info('Changed column %s in table %s', column, table);
  27       })
  28       .catch(function(err) {
  29         logger.info(JSON.stringify(err));
  30       });
  31   });
  32 };
  33
  34 Migration.prototype.addColumn = function(table, column, type) {
  35   var _this = this;
  36   this.sequence.enqueue(function() {
  37     return _this.queryInterface
  38       .addColumn(table, column, type)
  39       .then(function() {
  40         logger.info('Added column %s to %s', column, table);
  41       })
  42       .catch(function(err) {
  43         logger.info(JSON.stringify(err));
  44       });
  45   });
  46 };
  47
  48 Migration.prototype.dropTable = function(table) {
  49   var _this = this;
  50   this.sequence.enqueue(function() {
  51     return _this.queryInterface
  52       .dropTable(table, {
  53         force: true
  54       })
  55       .then(function() {
  56         logger.info('table dropped %s', table);
  57       })
  58       .catch(function(err) {
  59         logger.info(JSON.stringify(err));
  60       });
  61   });
  62 };
  63
  64 Migration.prototype.addIndex = function(table, column, indexName) {
  65   var _this = this;
  66   this.sequence.enqueue(function() {
  67     return _this.queryInterface.addIndex(table, column, {
  68         indexName: indexName
  69       })
  70       .then(function() {
  71         logger.info('addIndex %s %s %s', table, column.join(','), indexName);
  72       })
  73       .catch(function(err) {
  74         logger.info(JSON.stringify(err));
  75       });
  76   });
  77 };
  78
  79 Migration.prototype.query = function(sql) {
  80   var _this = this;
  81   this.sequence.enqueue(function() {
  82     return _this.queryInterface.sequelize.query(sql)
  83       .then(function() {
  84         logger.info('query %s', sql);
  85       })
  86       .catch(function(err) {
  87         logger.info(JSON.stringify(err));
  88       });
  89   });
  90 };
  91
  92 Migration.prototype.removeColumn = function(table, column) {
  93   var _this = this;
  94   this.sequence.enqueue(function() {
  95     return _this.queryInterface.removeColumn(table, column)
  96       .then(function() {
  97         logger.info('Removed column %s from %s', column, table);
  98       })
  99       .catch(function(err) {
 100         logger.info(util.inspect(err, {
 101           showHidden: false,
 102           depth: null
 103         }));
 104       });
 105   });
 106 };
 107
 108 Migration.prototype.renameColumn = function(table, oldColumn, newColumn) {
 109   var _this = this;
 110   this.sequence.enqueue(function() {
 111     return _this.queryInterface.renameColumn(table, oldColumn, newColumn)
 112       .then(function() {
 113         logger.info('Renamed column from %s to %s on %s', oldColumn, newColumn, table);
 114       })
 115       .catch(function(err) {
 116         logger.info(util.inspect(err, {
 117           showHidden: false,
 118           depth: null
 119         }));
 120       });
 121   });
 122 };
 123
 124 Migration.prototype.final = function(resolve) {
 125   this.sequence.enqueue(function() {
 126     return resolve();
 127   });
 128 };
 129
 130 module.exports = {
 131   up: function(queryInterface, Sequelize) {
 132     return new BPromise(function(resolve) {
 133       var migration = new Migration(queryInterface);
 134
 135       // START CHAT WEBSITE
 136       migration.addColumn('chat_websites', 'messagesAlignment', {
 137         type: Sequelize.STRING,
 138         defaultValue: 'alternate'
 139       });
 140
 141       migration.addColumn('chat_websites', 'defaultTitle', {
 142         type: Sequelize.STRING
 143       });
 144
 145       migration.addColumn('chat_websites', 'customerAvatar', {
 146         type: Sequelize.TEXT
 147       });
 148
 149       migration.addColumn('chat_websites', 'showCustomerAvatar', {
 150         type: Sequelize.BOOLEAN,
 151         defaultValue: false
 152       });
 153       // END CHAT WEBSITE
 154
 155       //START TAG APPLICATION
 156
 157       migration.addColumn('chat_applications', 'TagId', {
 158         type: Sequelize.INTEGER
 159       });
 160
 161       migration.query(
 162         'ALTER TABLE `chat_applications` \
 163         ADD CONSTRAINT `chat_applications_ibfk_5` \
 164         FOREIGN KEY (`TagId`) \
 165         REFERENCES tools_tags(`id`) \
 166         ON UPDATE CASCADE'
 167       );
 168
 169       migration.addColumn('fax_applications', 'TagId', {
 170         type: Sequelize.INTEGER
 171       });
 172
 173       migration.query(
 174         'ALTER TABLE `fax_applications` \
 175         ADD CONSTRAINT `fax_applications_ibfk_5` \
 176         FOREIGN KEY (`TagId`) \
 177         REFERENCES tools_tags(`id`) \
 178         ON UPDATE CASCADE'
 179       );
 180
 181       migration.addColumn('mail_applications', 'TagId', {
 182         type: Sequelize.INTEGER
 183       });
 184
 185       migration.query(
 186         'ALTER TABLE `mail_applications` \
 187         ADD CONSTRAINT `mail_applications_ibfk_5` \
 188         FOREIGN KEY (`TagId`) \
 189         REFERENCES tools_tags(`id`) \
 190         ON UPDATE CASCADE'
 191       );
 192
 193       migration.addColumn('openchannel_applications', 'TagId', {
 194         type: Sequelize.INTEGER
 195       });
 196
 197       migration.query(
 198         'ALTER TABLE `openchannel_applications` \
 199         ADD CONSTRAINT `openchannel_applications_ibfk_5` \
 200         FOREIGN KEY (`TagId`) \
 201         REFERENCES tools_tags(`id`) \
 202         ON UPDATE CASCADE'
 203       );
 204
 205       migration.addColumn('sms_applications', 'TagId', {
 206         type: Sequelize.INTEGER
 207       });
 208
 209       migration.query(
 210         'ALTER TABLE `sms_applications` \
 211         ADD CONSTRAINT `sms_applications_ibfk_5` \
 212         FOREIGN KEY (`TagId`) \
 213         REFERENCES tools_tags(`id`) \
 214         ON UPDATE CASCADE'
 215       );
 216
 217       //END TAG APPLICATION
 218
 219       //START REPORT_DIAL
 220       migration.query('ALTER TABLE report_dial CHANGE `hodltime` `holdtime` INT(11) DEFAULT NULL');
 221       //END REPORT_DIAL
 222
 223       //START OPENCHANNEL TOKEN
 224       migration.addColumn('openchannel_accounts', 'token', {
 225         type: Sequelize.STRING
 226       });
 227       //END OPENCHANNEL TOKEN
 228
 229       // START VOICE QUEUE LOG
 230       migration.addColumn('voice_queues_log', 'data', {
 231         type: Sequelize.STRING,
 232         allowNull: false,
 233         defaultValue: ''
 234       });
 235       // END VOICE QUEUE LOG
 236
 237       // START CUSTOM DASHBOARD WIDGET
 238       migration.changeColumn('dashboard_items', 'title', {
 239         type: Sequelize.STRING,
 240         allowNull: false
 241       });
 242       // END CUSTOM DASHBOARD WIDGET
 243
 244       // START FINAL
 245       migration.final(resolve);
 246       // END FINAL
 247     });
 248   },
 249
 250   down: function(queryInterface, Sequelize) {
 251     // var migration = new Migration(queryInterface);
 252   }
 253 };