server/migrations/2.0.66.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4 var rs = require('randomstring');
   5 var util = require('util');
   6
   7 var logger = require('../config/logger')('migration');
   8
   9 var Sequence = function() {};
  10
  11 Sequence.prototype.enqueue = function(fn) {
  12     this.tail = this.tail ? this.tail.finally(fn) : fn();
  13 };
  14
  15 var Migration = function(queryInterface) {
  16     this.queryInterface = queryInterface;
  17     this.sequence = new Sequence();
  18 };
  19
  20 Migration.prototype.changeColumn = function(table, column, type) {
  21     var _this = this;
  22     this.sequence.enqueue(function() {
  23         return _this.queryInterface
  24             .changeColumn(table, column, type)
  25             .then(function() {
  26                 logger.info('Changed column %s in table %s', column, table);
  27             })
  28             .catch(function(err) {
  29                 logger.info(JSON.stringify(err));
  30             });
  31     });
  32 };
  33
  34 Migration.prototype.addColumn = function(table, column, type) {
  35     var _this = this;
  36     this.sequence.enqueue(function() {
  37         return _this.queryInterface
  38             .addColumn(table, column, type)
  39             .then(function() {
  40                 logger.info('Added column %s to %s', column, table);
  41             })
  42             .catch(function(err) {
  43                 logger.info(JSON.stringify(err));
  44             });
  45     });
  46 };
  47
  48 Migration.prototype.dropTable = function(table) {
  49     var _this = this;
  50     this.sequence.enqueue(function() {
  51         return _this.queryInterface
  52             .dropTable(table, {
  53                 force: true
  54             })
  55             .then(function() {
  56                 logger.info('table dropped %s', table);
  57             })
  58             .catch(function(err) {
  59                 logger.info(JSON.stringify(err));
  60             });
  61     });
  62 };
  63
  64 Migration.prototype.addIndex = function(table, column, indexName) {
  65     var _this = this;
  66     this.sequence.enqueue(function() {
  67         return _this.queryInterface.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.removeIndex(table, indexName)
  83             .then(function() {
  84                 logger.info('removeIndex %s %s', table, indexName);
  85             })
  86             .catch(function(err) {
  87                 logger.info(JSON.stringify(err));
  88             });
  89     });
  90 };
  91
  92 Migration.prototype.query = function(sql) {
  93     var _this = this;
  94     this.sequence.enqueue(function() {
  95         return _this.queryInterface.sequelize.query(sql)
  96             .then(function() {
  97                 logger.info('query %s', sql);
  98             })
  99             .catch(function(err) {
 100                 logger.info(JSON.stringify(err));
 101             });
 102     });
 103 };
 104
 105 Migration.prototype.removeColumn = function(table, column) {
 106     var _this = this;
 107     this.sequence.enqueue(function() {
 108         return _this.queryInterface.removeColumn(table, column)
 109             .then(function() {
 110                 logger.info('Removed column %s from %s', column, table);
 111             })
 112             .catch(function(err) {
 113                 logger.info(util.inspect(err, {
 114                     showHidden: false,
 115                     depth: null
 116                 }));
 117             });
 118     });
 119 };
 120
 121 Migration.prototype.renameColumn = function(table, oldColumn, newColumn) {
 122     var _this = this;
 123     this.sequence.enqueue(function() {
 124         return _this.queryInterface.renameColumn(table, oldColumn, newColumn)
 125             .then(function() {
 126                 logger.info('Renamed column from %s to %s on %s', oldColumn, newColumn, table);
 127             })
 128             .catch(function(err) {
 129                 logger.info(util.inspect(err, {
 130                     showHidden: false,
 131                     depth: null
 132                 }));
 133             });
 134     });
 135 };
 136
 137 Migration.prototype.final = function(resolve) {
 138     this.sequence.enqueue(function() {
 139         return resolve();
 140     });
 141 };
 142
 143 module.exports = {
 144     up: function(queryInterface, Sequelize) {
 145         return new BPromise(function(resolve) {
 146             var migration = new Migration(queryInterface);
 147
 148             // START analytics_report_fields
 149             migration.changeColumn('analytics_report_fields', 'field', {
 150                 type: Sequelize.TEXT
 151             });
 152             // END analytics_report_fields
 153
 154             // START tools_schedules
 155             migration.addColumn('tools_schedules', 'cc', {
 156                 type: Sequelize.TEXT
 157             });
 158
 159             migration.addColumn('tools_schedules', 'bcc', {
 160                 type: Sequelize.TEXT
 161             });
 162
 163             migration.addColumn('settings', 'split', {
 164                 type: Sequelize.BOOLEAN,
 165                 defaultValue: true
 166             });
 167
 168             migration.addColumn('settings', 'splitSizeCsv', {
 169                 type: Sequelize.INTEGER,
 170                 defaultValue: 5000
 171             });
 172
 173             migration.addColumn('settings', 'splitSizePdf', {
 174                 type: Sequelize.INTEGER,
 175                 defaultValue: 1000
 176             });
 177
 178             migration.addColumn('settings', 'splitSizeXlsx', {
 179                 type: Sequelize.INTEGER,
 180                 defaultValue: 5000
 181             });
 182             // END tools_schedules
 183
 184             // START mail_accounts
 185             migration.addColumn('mail_accounts', 'queueTransfer', {
 186                 type: Sequelize.BOOLEAN,
 187                 defaultValue: false
 188             });
 189
 190             migration.addColumn('mail_accounts', 'queueTransferTimeout', {
 191                 type: Sequelize.INTEGER,
 192                 validate: {
 193                     min: 1,
 194                     max: 2147483
 195                 },
 196                 defaultValue: 300
 197             });
 198
 199             migration.addColumn('mail_accounts', 'agentTransfer', {
 200                 type: Sequelize.BOOLEAN,
 201                 defaultValue: false
 202             });
 203
 204             migration.addColumn('mail_accounts', 'agentTransferTimeout', {
 205                 type: Sequelize.INTEGER,
 206                 validate: {
 207                     min: 1,
 208                     max: 2147483
 209                 },
 210                 defaultValue: 300
 211             });
 212             // END mail_accounts
 213
 214             // START users
 215             migration.addColumn('users', 'phoneBarPrefixRequired', {
 216                 type: Sequelize.BOOLEAN,
 217                 defaultValue: false
 218             });
 219             // END users
 220
 221             // START mail_interactions
 222             migration.changeColumn('mail_interactions', 'subject', {
 223                 type: Sequelize.TEXT('') + ' CHARSET utf8mb4 COLLATE utf8mb4_unicode_ci'
 224             });
 225
 226             migration.changeColumn('mail_interactions', 'lastMsgBody', {
 227                 type: Sequelize.TEXT('long') + ' CHARSET utf8mb4 COLLATE utf8mb4_unicode_ci'
 228             });
 229             // END mail_interactions
 230
 231             // START CM CONTACTS
 232             migration.addColumn('cm_contacts', 'viber', {
 233                 type: Sequelize.STRING
 234             });
 235             // END CM CONTACTS
 236
 237             // START FINAL
 238             migration.final(resolve);
 239             // END FINAL
 240         });
 241     },
 242
 243     down: function(queryInterface, Sequelize) {
 244         // var migration = new Migration(queryInterface);
 245     }
 246 };