server/migrations/2.0.46.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4
   5 var logger = require('../config/logger')('migration');
   6 var util = require('util');
   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(res) {
  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(res) {
  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(res) {
  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.addIndex(table, column, {
  67                 indexName: indexName
  68             })
  69             .then(function(res) {
  70                 logger.info('addIndex %s %s %s', table, column.join(','), indexName);
  71             })
  72             .catch(function(err) {
  73                 logger.info(JSON.stringify(err));
  74             });
  75     });
  76 };
  77
  78 Migration.prototype.query = function(sql) {
  79     var _this = this;
  80     this.sequence.enqueue(function() {
  81         return _this.queryInterface.sequelize.query(sql)
  82             .then(function(res) {
  83                 logger.info('query %s', sql);
  84             })
  85             .catch(function(err) {
  86                 logger.info(JSON.stringify(err));
  87             });
  88     });
  89 };
  90
  91 Migration.prototype.removeColumn = function(table, column) {
  92     var _this = this;
  93     this.sequence.enqueue(function() {
  94         return _this.queryInterface.removeColumn(table, column)
  95             .then(function(res) {
  96                 logger.info('Removed column %s from %s', column, table);
  97             })
  98             .catch(function(err) {
  99                 logger.info(util.inspect(err, {
 100                     showHidden: false,
 101                     depth: null
 102                 }));
 103             });
 104     });
 105 };
 106
 107 Migration.prototype.final = function(resolve) {
 108     var _this = this;
 109     this.sequence.enqueue(function() {
 110         return resolve();
 111     });
 112 };
 113
 114 module.exports = {
 115     up: function(queryInterface, Sequelize) {
 116         return new BPromise(function(resolve, reject) {
 117             var migration = new Migration(queryInterface);
 118
 119             // START USER
 120             migration.changeColumn('users', 'showWebBar', {
 121                 type: Sequelize.INTEGER,
 122                 defaultValue: 0
 123             });
 124             // END USER
 125
 126             // START USER
 127             // UPDATE AGENT COLUMN PERMISSION
 128             migration.query("UPDATE users SET permissions='101,102,103,104,105,106,107,108,109,100' WHERE role='agent' AND (permissions IS NULL OR permissions = '')");
 129
 130             migration.addColumn('users', 'crudPermissions', {
 131                 type: Sequelize.INTEGER,
 132                 defaultValue: 0
 133             });
 134             //END USER
 135
 136             // START CHATWEBSITE
 137             migration.addColumn('chat_websites', 'noteTitle', {
 138                 type: Sequelize.STRING,
 139                 defaultValue: 'Note'
 140             });
 141
 142             migration.addColumn('chat_websites', 'placeholderMessage', {
 143                 type: Sequelize.STRING,
 144                 defaultValue: 'Type a message'
 145             });
 146             // END CHATWEBSITE
 147
 148             // START Fax Interaction
 149             migration.addColumn('fax_interactions', 'fax', {
 150                 type: Sequelize.STRING
 151             });
 152             migration.query("UPDATE fax_interactions as t1 JOIN cm_contacts AS t2 ON t1.ContactId = t2.id SET t1.fax = t2.fax");
 153
 154             // END Fax Interaction
 155
 156             // START FINAL
 157             migration.final(resolve);
 158             // END FINAL
 159         });
 160     },
 161
 162     down: function(queryInterface, Sequelize) {
 163         var migration = new Migration(queryInterface);
 164     }
 165 };