server/migrations/2.5.44.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4 var util = require('util');
   5
   6 var logger = require('../config/logger')('migration');
   7
   8 var Sequence = function() {};
   9
  10 Sequence.prototype.enqueue = function(fn) {
  11   this.tail = this.tail ? this.tail.finally(fn) : fn();
  12 };
  13
  14 var Migration = function(queryInterface) {
  15   this.queryInterface = queryInterface;
  16   this.sequence = new Sequence();
  17 };
  18
  19 Migration.prototype.changeColumn = function(table, column, type) {
  20   var _this = this;
  21   this.sequence.enqueue(function() {
  22     return _this.queryInterface
  23       .changeColumn(table, column, type)
  24       .then(function() {
  25         logger.info('Changed column %s in table %s', column, table);
  26       })
  27       .catch(function(err) {
  28         logger.info(JSON.stringify(err));
  29       });
  30   });
  31 };
  32
  33 Migration.prototype.addColumn = function(table, column, type) {
  34   var _this = this;
  35   this.sequence.enqueue(function() {
  36     return _this.queryInterface
  37       .addColumn(table, column, type)
  38       .then(function() {
  39         logger.info('Added column %s to %s', column, table);
  40       })
  41       .catch(function(err) {
  42         logger.info(JSON.stringify(err));
  43       });
  44   });
  45 };
  46
  47 Migration.prototype.dropTable = function(table) {
  48   var _this = this;
  49   this.sequence.enqueue(function() {
  50     return _this.queryInterface
  51       .dropTable(table, {
  52         force: true
  53       })
  54       .then(function() {
  55         logger.info('table dropped %s', table);
  56       })
  57       .catch(function(err) {
  58         logger.info(JSON.stringify(err));
  59       });
  60   });
  61 };
  62
  63 Migration.prototype.addIndex = function(table, column, indexName) {
  64   var _this = this;
  65   this.sequence.enqueue(function() {
  66     return _this.queryInterface
  67       .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.removeIndex = function(table, indexName) {
  80   var _this = this;
  81   this.sequence.enqueue(function() {
  82     return _this.queryInterface
  83       .removeIndex(table, indexName)
  84       .then(function() {
  85         logger.info('removeIndex %s %s', table, indexName);
  86       })
  87       .catch(function(err) {
  88         logger.info(JSON.stringify(err));
  89       });
  90   });
  91 };
  92
  93 Migration.prototype.query = function(sql) {
  94   var _this = this;
  95   this.sequence.enqueue(function() {
  96     return _this.queryInterface.sequelize
  97       .query(sql)
  98       .then(function() {
  99         logger.info('query %s', sql);
 100       })
 101       .catch(function(err) {
 102         logger.info(JSON.stringify(err));
 103       });
 104   });
 105 };
 106
 107 Migration.prototype.removeColumn = function(table, column) {
 108   var _this = this;
 109   this.sequence.enqueue(function() {
 110     return _this.queryInterface
 111       .removeColumn(table, column)
 112       .then(function() {
 113         logger.info('Removed column %s from %s', column, table);
 114       })
 115       .catch(function(err) {
 116         logger.info(
 117           util.inspect(err, {
 118             showHidden: false,
 119             depth: null
 120           })
 121         );
 122       });
 123   });
 124 };
 125
 126 Migration.prototype.renameColumn = function(table, oldColumn, newColumn) {
 127   var _this = this;
 128   this.sequence.enqueue(function() {
 129     return _this.queryInterface
 130       .renameColumn(table, oldColumn, newColumn)
 131       .then(function() {
 132         logger.info('Renamed column from %s to %s on %s', oldColumn, newColumn, table);
 133       })
 134       .catch(function(err) {
 135         logger.info(
 136           util.inspect(err, {
 137             showHidden: false,
 138             depth: null
 139           })
 140         );
 141       });
 142   });
 143 };
 144
 145 Migration.prototype.final = function(resolve) {
 146   this.sequence.enqueue(function() {
 147     return resolve();
 148   });
 149 };
 150
 151 module.exports = {
 152   up: function(queryInterface, Sequelize) {
 153     return new BPromise(function(resolve) {
 154       var migration = new Migration(queryInterface);
 155
 156       // START user settings
 157       migration.query('CREATE TABLE `user_settings` (' +
 158         ' `id` int(11) NOT NULL AUTO_INCREMENT,' +
 159         ' `clientSideLoggingLevel` enum(\'error\',\'warning\',\'info\',\'debug\') NOT NULL DEFAULT \'error\',' +
 160         ' `clientSideLoggingEnabled` tinyint(1) DEFAULT \'0\',' +
 161         ' `clientSideLoggingScopes` text,' +
 162         ' `clientSideLoggingEnabledSince` datetime DEFAULT NULL,' +
 163         ' `createdAt` datetime NOT NULL,' +
 164         ' `updatedAt` datetime NOT NULL,' +
 165         ' `UserId` int(11) DEFAULT NULL,' +
 166         ' PRIMARY KEY (`id`),' +
 167         ' UNIQUE KEY `UserId` (`UserId`),' +
 168         ' CONSTRAINT `user_settings_ibfk_1` FOREIGN KEY (`UserId`) REFERENCES `users` (`id`) ON DELETE CASCADE ON UPDATE CASCADE' +
 169         ') ENGINE=InnoDB DEFAULT CHARSET=utf8;');
 170
 171       migration.query(
 172         "INSERT INTO `user_settings`(clientSideLoggingLevel, clientSideLoggingEnabled, clientSideLoggingEnabledSince, createdAt , updatedAt , UserId) SELECT 'error', false, NULL, NOW(), NOW(), id FROM `users`"
 173       );
 174       // END user settings
 175
 176       //START timezone
 177       migration.addColumn('cm_contacts', 'dialTimezone', {
 178         type: Sequelize.STRING
 179       });
 180       migration.addColumn('cm_contacts', 'utcOffset', {
 181         type: Sequelize.INTEGER,
 182         defaultValue: 0
 183       });
 184       migration.addColumn('cm_hopper', 'dialTimezone', {
 185         type: Sequelize.STRING
 186       });
 187       migration.addColumn('cm_hopper_history', 'dialTimezone', {
 188         type: Sequelize.STRING
 189       });
 190       //END timezone
 191
 192       // START int_dynamics365_accounts
 193       migration.addColumn('int_dynamics365_accounts', 'CloudProviderId', {
 194         type: Sequelize.INTEGER
 195       });
 196
 197       migration.addIndex('int_dynamics365_accounts', ['CloudProviderId'], 'CloudProviderId');
 198
 199       migration.query('ALTER TABLE `int_dynamics365_accounts` ADD CONSTRAINT `int_dynamics365_accounts_ibfk_2` FOREIGN KEY (`CloudProviderId`) REFERENCES `cloud_providers`(`id`) ON DELETE RESTRICT ON UPDATE CASCADE');
 200
 201       migration.addColumn('int_dynamics365_accounts', 'modernAuthentication', {
 202         type: Sequelize.BOOLEAN,
 203         defaultValue: true,
 204         after: 'description'
 205       });
 206
 207       migration.query('UPDATE int_dynamics365_accounts SET modernAuthentication = 0');
 208       // END int_dynamics365_accounts
 209
 210       // START FINAL
 211       migration.final(resolve);
 212       // END FINAL
 213     });
 214   },
 215
 216   down: function(queryInterface, Sequelize) {
 217     // var migration = new Migration(queryInterface);
 218   }
 219 };