server/migrations/2.5.18.js

   1 'use strict';\r
   2 \r
   3 var BPromise = require('bluebird');\r
   4 var util = require('util');\r
   5 \r
   6 var logger = require('../config/logger')('migration');\r
   7 \r
   8 var Sequence = function() {};\r
   9 \r
  10 Sequence.prototype.enqueue = function(fn) {\r
  11   this.tail = this.tail ? this.tail.finally(fn) : fn();\r
  12 };\r
  13 \r
  14 var Migration = function(queryInterface) {\r
  15   this.queryInterface = queryInterface;\r
  16   this.sequence = new Sequence();\r
  17 };\r
  18 \r
  19 Migration.prototype.changeColumn = function(table, column, type) {\r
  20   var _this = this;\r
  21   this.sequence.enqueue(function() {\r
  22     return _this.queryInterface\r
  23       .changeColumn(table, column, type)\r
  24       .then(function() {\r
  25         logger.info('Changed column %s in table %s', column, table);\r
  26       })\r
  27       .catch(function(err) {\r
  28         logger.info(JSON.stringify(err));\r
  29       });\r
  30   });\r
  31 };\r
  32 \r
  33 Migration.prototype.addColumn = function(table, column, type) {\r
  34   var _this = this;\r
  35   this.sequence.enqueue(function() {\r
  36     return _this.queryInterface\r
  37       .addColumn(table, column, type)\r
  38       .then(function() {\r
  39         logger.info('Added column %s to %s', column, table);\r
  40       })\r
  41       .catch(function(err) {\r
  42         logger.info(JSON.stringify(err));\r
  43       });\r
  44   });\r
  45 };\r
  46 \r
  47 Migration.prototype.dropTable = function(table) {\r
  48   var _this = this;\r
  49   this.sequence.enqueue(function() {\r
  50     return _this.queryInterface\r
  51       .dropTable(table, {\r
  52         force: true\r
  53       })\r
  54       .then(function() {\r
  55         logger.info('table dropped %s', table);\r
  56       })\r
  57       .catch(function(err) {\r
  58         logger.info(JSON.stringify(err));\r
  59       });\r
  60   });\r
  61 };\r
  62 \r
  63 Migration.prototype.addIndex = function(table, column, indexName) {\r
  64   var _this = this;\r
  65   this.sequence.enqueue(function() {\r
  66     return _this.queryInterface\r
  67       .addIndex(table, column, {\r
  68         indexName: indexName\r
  69       })\r
  70       .then(function() {\r
  71         logger.info('addIndex %s %s %s', table, column.join(','), indexName);\r
  72       })\r
  73       .catch(function(err) {\r
  74         logger.info(JSON.stringify(err));\r
  75       });\r
  76   });\r
  77 };\r
  78 \r
  79 Migration.prototype.removeIndex = function(table, indexName) {\r
  80   var _this = this;\r
  81   this.sequence.enqueue(function() {\r
  82     return _this.queryInterface\r
  83       .removeIndex(table, indexName)\r
  84       .then(function() {\r
  85         logger.info('removeIndex %s %s', table, indexName);\r
  86       })\r
  87       .catch(function(err) {\r
  88         logger.info(JSON.stringify(err));\r
  89       });\r
  90   });\r
  91 };\r
  92 \r
  93 Migration.prototype.query = function(sql) {\r
  94   var _this = this;\r
  95   this.sequence.enqueue(function() {\r
  96     return _this.queryInterface.sequelize\r
  97       .query(sql)\r
  98       .then(function() {\r
  99         logger.info('query %s', sql);\r
 100       })\r
 101       .catch(function(err) {\r
 102         logger.info(JSON.stringify(err));\r
 103       });\r
 104   });\r
 105 };\r
 106 \r
 107 Migration.prototype.removeColumn = function(table, column) {\r
 108   var _this = this;\r
 109   this.sequence.enqueue(function() {\r
 110     return _this.queryInterface\r
 111       .removeColumn(table, column)\r
 112       .then(function() {\r
 113         logger.info('Removed column %s from %s', column, table);\r
 114       })\r
 115       .catch(function(err) {\r
 116         logger.info(\r
 117           util.inspect(err, {\r
 118             showHidden: false,\r
 119             depth: null\r
 120           })\r
 121         );\r
 122       });\r
 123   });\r
 124 };\r
 125 \r
 126 Migration.prototype.renameColumn = function(table, oldColumn, newColumn) {\r
 127   var _this = this;\r
 128   this.sequence.enqueue(function() {\r
 129     return _this.queryInterface\r
 130       .renameColumn(table, oldColumn, newColumn)\r
 131       .then(function() {\r
 132         logger.info('Renamed column from %s to %s on %s', oldColumn, newColumn, table);\r
 133       })\r
 134       .catch(function(err) {\r
 135         logger.info(\r
 136           util.inspect(err, {\r
 137             showHidden: false,\r
 138             depth: null\r
 139           })\r
 140         );\r
 141       });\r
 142   });\r
 143 };\r
 144 \r
 145 Migration.prototype.final = function(resolve) {\r
 146   this.sequence.enqueue(function() {\r
 147     return resolve();\r
 148   });\r
 149 };\r
 150 \r
 151 module.exports = {\r
 152   up: function(queryInterface, Sequelize) {\r
 153     return new BPromise(function(resolve) {\r
 154       var migration = new Migration(queryInterface);\r
 155 \r
 156       // START settings\r
 157       migration.addColumn('settings', 'chatInteractionsReloadTimeout', {\r
 158         type: Sequelize.INTEGER,\r
 159         defaultValue: 0\r
 160       });\r
 161 \r
 162       migration.addColumn('settings', 'mailInteractionsReloadTimeout', {\r
 163         type: Sequelize.INTEGER,\r
 164         defaultValue: 0\r
 165       });\r
 166 \r
 167       migration.addColumn('settings', 'openchannelInteractionsReloadTimeout', {\r
 168         type: Sequelize.INTEGER,\r
 169         defaultValue: 0\r
 170       });\r
 171 \r
 172       migration.addColumn('settings', 'smsInteractionsReloadTimeout', {\r
 173         type: Sequelize.INTEGER,\r
 174         defaultValue: 0\r
 175       });\r
 176 \r
 177       migration.addColumn('settings', 'whatsappInteractionsReloadTimeout', {\r
 178         type: Sequelize.INTEGER,\r
 179         defaultValue: 0\r
 180       });\r
 181       // END settings\r
 182 \r
 183       // START mail_applications\r
 184       migration.query('UPDATE mail_applications SET appdata = REPLACE(appdata, \'0,\', \'0,1\') WHERE appdata LIKE \'0,%\' AND app = \'autoreply\';');\r
 185 \r
 186       migration.query('UPDATE mail_applications SET appdata = REPLACE(appdata, \'1,\', \'1,1\') WHERE appdata LIKE \'1,%\' AND app = \'autoreply\';');\r
 187       // END mail_applications\r
 188 \r
 189       // START FINAL\r
 190       migration.final(resolve);\r
 191       // END FINAL\r
 192     });\r
 193   },\r
 194 \r
 195   down: function(queryInterface, Sequelize) {\r
 196     // var migration = new Migration(queryInterface);\r
 197   }\r
 198 };