server/migrations/2.0.52.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 SETTINGS
 123       migration.addColumn('settings', 'callRecordingEncryption', {
 124         type: Sequelize.BOOLEAN,
 125         defaultValue: false
 126       });
 127       migration.addColumn('settings', 'passwordExpiresDays', {
 128         type: Sequelize.INTEGER(11),
 129         defaultValue: 90
 130       });
 131       migration.query('UPDATE settings SET securePassword=false WHERE id=1');
 132       //END SETTINGS
 133
 134       //START CANNED ANSWERS
 135       migration.addColumn('tools_canned_answers', 'MailAccountId', {
 136         type: Sequelize.INTEGER
 137       });
 138       migration.addColumn('tools_canned_answers', 'FaxAccountId', {
 139         type: Sequelize.INTEGER
 140       });
 141       migration.addColumn('tools_canned_answers', 'SmsAccountId', {
 142         type: Sequelize.INTEGER
 143       });
 144       migration.addColumn('tools_canned_answers', 'OpenchannelAccountId', {
 145         type: Sequelize.INTEGER
 146       });
 147       migration.addColumn('tools_canned_answers', 'ChatWebsiteId', {
 148         type: Sequelize.INTEGER
 149       });
 150
 151       migration.query('ALTER TABLE `tools_canned_answers` \
 152         ADD CONSTRAINT `tools_canned_answers_ibfk_1` \
 153         FOREIGN KEY (`MailAccountId`) \
 154         REFERENCES mail_accounts(`id`) \
 155         ON UPDATE CASCADE \
 156         ON DELETE CASCADE');
 157       migration.query('ALTER TABLE `tools_canned_answers` \
 158         ADD CONSTRAINT `tools_canned_answers_ibfk_2` \
 159         FOREIGN KEY (`FaxAccountId`) \
 160         REFERENCES fax_accounts(`id`) \
 161         ON UPDATE CASCADE \
 162         ON DELETE CASCADE');
 163       migration.query('ALTER TABLE `tools_canned_answers` \
 164         ADD CONSTRAINT `tools_canned_answers_ibfk_3` \
 165         FOREIGN KEY (`SmsAccountId`) \
 166         REFERENCES sms_accounts(`id`) \
 167         ON UPDATE CASCADE \
 168         ON DELETE CASCADE');
 169       migration.query('ALTER TABLE `tools_canned_answers` \
 170         ADD CONSTRAINT `tools_canned_answers_ibfk_4` \
 171         FOREIGN KEY (`OpenchannelAccountId`) \
 172         REFERENCES openchannel_accounts(`id`) \
 173         ON UPDATE CASCADE \
 174         ON DELETE CASCADE');
 175
 176       migration.query('ALTER TABLE `tools_canned_answers` \
 177         ADD CONSTRAINT `tools_canned_answers_ibfk_5` \
 178         FOREIGN KEY (`ChatWebsiteId`) \
 179         REFERENCES chat_websites(`id`) \
 180         ON UPDATE CASCADE \
 181         ON DELETE CASCADE');
 182       //START CANNED ANSWERS
 183
 184       //START USERS
 185       migration.addColumn('users', 'passwordResetAt', {
 186         type: Sequelize.DATE,
 187         defaultValue: null
 188       });
 189       migration.query('UPDATE users SET passwordResetAt=NOW()');
 190       //END USERS
 191
 192       //START USERS
 193       migration.addColumn('report_dial', 'duration', {
 194         type: Sequelize.INTEGER
 195       });
 196       migration.addColumn('report_dial', 'holdtime', {
 197         type: Sequelize.INTEGER
 198       });
 199       migration.addColumn('report_dial', 'billableseconds', {
 200         type: Sequelize.INTEGER
 201       });
 202       //END USERS
 203
 204       // START SMS
 205       migration.changeColumn('sms_accounts', 'type', {
 206         type: Sequelize.ENUM('twilio', 'skebby', 'connectel', 'clicksend')
 207       });
 208       // END SMS
 209
 210       //START CUSTOM DASHBOARDS
 211       migration.addColumn('dashboard_items', 'background', {
 212         type: Sequelize.STRING,
 213         allowNull: false,
 214         defaultValue: '#ffffff',
 215         validate: {
 216           notEmpty: true
 217         }
 218       });
 219
 220       migration.addColumn('dashboard_items', 'foreground', {
 221         type: Sequelize.STRING,
 222         allowNull: false,
 223         defaultValue: '#2196f3',
 224         validate: {
 225           notEmpty: true
 226         }
 227       });
 228
 229       migration.addColumn('dashboard_items', 'link', {
 230         type: Sequelize.STRING
 231       });
 232       //END CUSTOM DASHBOARDS
 233
 234       // START FINAL
 235       migration.final(resolve);
 236       // END FINAL
 237     });
 238   },
 239
 240   down: function(queryInterface, Sequelize) {
 241     var migration = new Migration(queryInterface);
 242   }
 243 };