server/migrations/2.0.42.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4
   5 var logger = require('../config/logger')('migration');
   6 var util = require('util');
   7 var path = require('path');
   8 var config = require('../config/environment');
   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.getCustomFields = function() {
 110   var _this = this;
 111   var CmCustomField = _this.queryInterface.sequelize.import(path.join(config.root, 'server/api/cmCustomField/cmCustomField.model'));
 112   return CmCustomField.findAll({
 113       where: {
 114         type: {
 115           $notIn: ['number', 'switch']
 116         }
 117       },
 118       attributes: ['id']
 119     })
 120     .then(function(entities) {
 121       return entities;
 122     })
 123     .catch(function(err) {
 124       logger.info(JSON.stringify(err));
 125     });
 126 };
 127
 128
 129 Migration.prototype.final = function(resolve) {
 130   var _this = this;
 131   this.sequence.enqueue(function() {
 132     return resolve();
 133   });
 134 };
 135
 136 module.exports = {
 137   up: function(queryInterface, Sequelize) {
 138     return new BPromise(function(resolve, reject) {
 139       var migration = new Migration(queryInterface);
 140
 141       // START TOOLS TAGS
 142       migration.addColumn('tools_tags', 'color', {
 143         type: Sequelize.STRING,
 144         defaultValue: '#0091EA'
 145       });
 146       // END TOOLS TAGS
 147
 148       // START OPENCHANNEL MESSAGES
 149       migration.addColumn('openchannel_messages', 'secret', {
 150         type: Sequelize.BOOLEAN,
 151         defaultValue: false
 152       });
 153       // END OPENCHANNEL MESSAGES
 154
 155       //START CONTACTS
 156       migration.getCustomFields()
 157         .then(function(entities) {
 158           if (entities) {
 159             for (var i = 0, length = entities.length; i < length; i++) {
 160               migration.changeColumn('cm_contacts', 'cf_' + entities[i].id, {
 161                 type: Sequelize.TEXT
 162               });
 163             }
 164           }
 165         });
 166       //END CONTACTS
 167
 168       // START FAX
 169       migration.addColumn('fax_messages', 'failMessage', {
 170         type: Sequelize.TEXT
 171       });
 172
 173       // END FAX
 174
 175       // START USER
 176       migration.addColumn('users', 'extensionMonitor', {
 177         type: Sequelize.STRING,
 178         defaultValue: ''
 179       });
 180
 181       // END USER
 182
 183       // START FINAL
 184       migration.final(resolve);
 185       // END FINAL
 186     });
 187   },
 188
 189   down: function(queryInterface, Sequelize) {
 190     var migration = new Migration(queryInterface);
 191   }
 192 };