server/migrations/2.0.56.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.renameColumn = function(table, oldColumn, newColumn) {
 110   var _this = this;
 111   this.sequence.enqueue(function() {
 112     return _this.queryInterface.renameColumn(table, oldColumn, newColumn)
 113       .then(function(res) {
 114         logger.info('Renamed column from %s to %s on %s', oldColumn, newColumn, table);
 115       })
 116       .catch(function(err) {
 117         logger.info(util.inspect(err, {
 118           showHidden: false,
 119           depth: null
 120         }));
 121       });
 122   });
 123 };
 124
 125 Migration.prototype.final = function(resolve) {
 126   var _this = this;
 127   this.sequence.enqueue(function() {
 128     return resolve();
 129   });
 130 };
 131
 132 module.exports = {
 133   up: function(queryInterface, Sequelize) {
 134     return new BPromise(function(resolve, reject) {
 135
 136       var migration = new Migration(queryInterface);
 137
 138       // START BOOKED
 139       migration.changeColumn('voice_queues', 'strategy', {
 140         type: Sequelize.ENUM('roundrobin', 'ringall', 'leastrecent', 'fewestcalls', 'random', 'rrmemory', 'linear', 'wrandom', 'rrordered'),
 141         allowNull: false,
 142         defaultValue: 'ringall'
 143       });
 144       // END BOOKED
 145
 146       // START EXTRACTED REPORT
 147       migration.addColumn('analytics_extracted_reports', 'basename', {
 148         type: Sequelize.STRING,
 149         allowNull: false
 150       });
 151       // END EXTRACTED REPORT
 152
 153       // START MAIL ACCOUNT
 154       migration.addColumn('mail_accounts', 'notificationTemplate', {
 155         type: Sequelize.TEXT
 156       });
 157       migration.addColumn('mail_accounts', 'notificationSound', {
 158         type: Sequelize.BOOLEAN,
 159         defaultValue: true
 160       });
 161       migration.addColumn('mail_accounts', 'notificationShake', {
 162         type: Sequelize.BOOLEAN,
 163         defaultValue: false
 164       });
 165       // END MAIL ACCOUNT
 166
 167       // START CHAT ACCOUNT
 168       migration.addColumn('chat_websites', 'notificationTemplate', {
 169         type: Sequelize.TEXT
 170       });
 171       migration.addColumn('chat_websites', 'notificationSound', {
 172         type: Sequelize.BOOLEAN,
 173         defaultValue: true
 174       });
 175       migration.addColumn('chat_websites', 'notificationShake', {
 176         type: Sequelize.BOOLEAN,
 177         defaultValue: false
 178       });
 179       // END CHAT ACCOUNT
 180
 181       // START FAX ACCOUNT
 182       migration.addColumn('fax_accounts', 'notificationTemplate', {
 183         type: Sequelize.TEXT
 184       });
 185       migration.addColumn('fax_accounts', 'notificationSound', {
 186         type: Sequelize.BOOLEAN,
 187         defaultValue: true
 188       });
 189       migration.addColumn('fax_accounts', 'notificationShake', {
 190         type: Sequelize.BOOLEAN,
 191         defaultValue: false
 192       });
 193       // END FAX ACCOUNT
 194
 195       // START SMS ACCOUNT
 196       migration.addColumn('sms_accounts', 'notificationTemplate', {
 197         type: Sequelize.TEXT
 198       });
 199       migration.addColumn('sms_accounts', 'notificationSound', {
 200         type: Sequelize.BOOLEAN,
 201         defaultValue: true
 202       });
 203       migration.addColumn('sms_accounts', 'notificationShake', {
 204         type: Sequelize.BOOLEAN,
 205         defaultValue: false
 206       });
 207       // END SMS ACCOUNT
 208
 209       // START OPENCHANNEL ACCOUNT
 210       migration.addColumn('openchannel_accounts', 'notificationTemplate', {
 211         type: Sequelize.TEXT
 212       });
 213       migration.addColumn('openchannel_accounts', 'notificationSound', {
 214         type: Sequelize.BOOLEAN,
 215         defaultValue: true
 216       });
 217       migration.addColumn('openchannel_accounts', 'notificationShake', {
 218         type: Sequelize.BOOLEAN,
 219         defaultValue: false
 220       });
 221       // END OPENCHANNEL ACCOUNT
 222
 223       // START ACCOUNTS UPDATE
 224       migration.query('UPDATE chat_websites SET notificationTemplate=\'Account: {{account.name}}<br/>{{#queue}}Queue: {{queue.name}}<br/>{{/queue}}From : {{from}}\'');
 225       migration.query('UPDATE mail_accounts SET notificationTemplate=\'Account: {{account.name}}<br/>{{#queue}}Queue: {{queue.name}}<br/>{{/queue}}From : {{from}}<br/>Subject : {{message.subject}}\'');
 226       migration.query('UPDATE sms_accounts SET notificationTemplate=\'Account: {{account.name}}<br/>{{#queue}}Queue: {{queue.name}}<br/>{{/queue}}From : {{from}}\'');
 227       migration.query('UPDATE fax_accounts SET notificationTemplate=\'Account: {{account.name}}<br/>{{#queue}}Queue: {{queue.name}}<br/>{{/queue}}From : {{from}}\'');
 228       migration.query('UPDATE openchannel_accounts SET notificationTemplate=\'Account: {{account.name}}<br/>{{#queue}}Queue: {{queue.name}}<br/>{{/queue}}From : {{from}}\'');
 229       // END ACCOUNTS UPDATE
 230
 231       // START FINAL
 232       migration.final(resolve);
 233       // END FINAL
 234     });
 235   },
 236
 237   down: function(queryInterface, Sequelize) {
 238     var migration = new Migration(queryInterface);
 239   }
 240 };