server/migrations/2.0.30.js

   1 'use strict';
   2 var BPromise = require('bluebird');
   3
   4 var logger = require('../config/logger')('migration');
   5 var util = require('util');
   6
   7 var Sequence = function() {};
   8
   9 Sequence.prototype.enqueue = function(fn) {
  10   this.tail = this.tail ? this.tail.finally(fn) : fn();
  11 };
  12
  13 var Migration = function(queryInterface) {
  14   this.queryInterface = queryInterface;
  15   this.sequence = new Sequence();
  16 };
  17
  18 Migration.prototype.changeColumn = function(table, column, type) {
  19   var _this = this;
  20   this.sequence.enqueue(function() {
  21     return _this.queryInterface
  22       .changeColumn(table, column, type)
  23       .then(function(res) {
  24         logger.info('Changed column %s in table %s', column, table);
  25       })
  26       .catch(function(err) {
  27         logger.info(JSON.stringify(err));
  28       });
  29   });
  30 };
  31
  32 Migration.prototype.addColumn = function(table, column, type) {
  33   var _this = this;
  34   this.sequence.enqueue(function() {
  35     return _this.queryInterface
  36       .addColumn(table, column, type)
  37       .then(function(res) {
  38         logger.info('Added column %s to %s', column, table);
  39       })
  40       .catch(function(err) {
  41         logger.info(JSON.stringify(err));
  42       });
  43   });
  44 };
  45
  46 Migration.prototype.dropTable = function(table) {
  47   var _this = this;
  48   this.sequence.enqueue(function() {
  49     return _this.queryInterface
  50       .dropTable(table, {
  51         force: true
  52       })
  53       .then(function(res) {
  54         logger.info('table dropped %s', table);
  55       })
  56       .catch(function(err) {
  57         logger.info(JSON.stringify(err));
  58       });
  59   });
  60 };
  61
  62 Migration.prototype.addIndex = function(table, column, indexName) {
  63   var _this = this;
  64   this.sequence.enqueue(function() {
  65     return _this.queryInterface.addIndex(table, column, {
  66         indexName: indexName
  67       })
  68       .then(function(res) {
  69         logger.info('addIndex %s %s %s', table, column.join(','), indexName);
  70       })
  71       .catch(function(err) {
  72         logger.info(JSON.stringify(err));
  73       });
  74   });
  75 };
  76
  77 Migration.prototype.query = function(sql) {
  78   var _this = this;
  79   this.sequence.enqueue(function() {
  80     return _this.queryInterface.sequelize.query(sql)
  81       .then(function(res) {
  82         logger.info('query %s', sql);
  83       })
  84       .catch(function(err) {
  85         logger.info(JSON.stringify(err));
  86       });
  87   });
  88 };
  89
  90 Migration.prototype.final = function(resolve) {
  91   var _this = this;
  92   this.sequence.enqueue(function() {
  93     return resolve();
  94   });
  95 };
  96
  97 module.exports = {
  98
  99   up: function(queryInterface, Sequelize) {
 100     return new BPromise(function(resolve, reject) {
 101
 102       var migration = new Migration(queryInterface);
 103
 104       // START CHAT
 105       migration.dropTable('user_has_chat_rooms');
 106       migration.dropTable('chat_enquiries');
 107       migration.dropTable('chat_messages');
 108       migration.dropTable('chat_proactive_actions');
 109       migration.dropTable('chat_dispositions');
 110       migration.dropTable('chat_applications');
 111       migration.dropTable('user_has_chat_interactions');
 112       migration.dropTable('chat_interactions');
 113       migration.dropTable('team_has_chat_queues');
 114       migration.dropTable('user_has_chat_queues');
 115       migration.dropTable('chat_queues');
 116       migration.dropTable('chat_visitors');
 117       migration.dropTable('chat_websites_fields');
 118       migration.dropTable('chat_websites');
 119       // END CHAT
 120
 121       migration.changeColumn('voice_queues', 'dialQueueTimeout', {
 122         type: Sequelize.INTEGER(3).UNSIGNED,
 123         defaultValue: 3,
 124         validate: {
 125           min: 1,
 126           max: 999
 127         },
 128         comment: 'Queue Timeout Seconds (min:1, max:999)'
 129       });
 130       // START FINAL
 131       migration.final(resolve);
 132       // END FINAL
 133
 134     });
 135
 136   },
 137
 138   down: function(queryInterface, Sequelize) {
 139     var migration = new Migration(queryInterface);
 140   }
 141 };