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 };