server/migrations/2.0.48.js

   1 'use strict';
   2
   3 var BPromise = require('bluebird');
   4 var fs = require('fs');
   5 var util = require('util');
   6 var _ = require('lodash');
   7
   8 var logger = require('../config/logger')('migration');
   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.final = function(resolve) {
 110     var _this = this;
 111     this.sequence.enqueue(function() {
 112         return resolve();
 113     });
 114 };
 115
 116 module.exports = {
 117     up: function(queryInterface, Sequelize) {
 118         return new BPromise(function(resolve, reject) {
 119
 120             var migration = new Migration(queryInterface);
 121
 122             // START SETTINGS
 123             migration.addColumn('settings', 'turnaddr', {
 124                 type: Sequelize.STRING
 125             });
 126             migration.addColumn('settings', 'turnusername', {
 127                 type: Sequelize.STRING
 128             });
 129             migration.addColumn('settings', 'turnpassword', {
 130                 type: Sequelize.STRING
 131             });
 132             // END SETTINGS
 133
 134             // START USERS
 135             migration.addColumn('users', 'rtcp_mux', {
 136                 type: Sequelize.ENUM('yes', 'no'),
 137                 defaultValue: 'no'
 138             });
 139
 140             migration.query('UPDATE users SET rtcp_mux=\'yes\' WHERE showWebBar=2');
 141             // END USERS
 142
 143             // START SMS INTERACTIONS
 144             migration.addColumn('sms_interactions', 'firstMsgDirection', {
 145                 type: Sequelize.ENUM('in', 'out'),
 146                 defaultValue: 'in',
 147                 allowNull: false
 148             });
 149
 150             // Update the firstMsgDirection column with correct value (direction of the first message for each interactions)
 151             migration.query("UPDATE sms_interactions t1, (SELECT SmsInteractionId, MIN(id) AS messageid, ANY_VALUE(direction) AS direction FROM sms_messages WHERE SmsInteractionId IS NOT NULL GROUP BY SmsInteractionId) t2 SET t1.firstMsgDirection = t2.direction WHERE t1.id = t2.SmsInteractionId;");
 152             // END SMS INTERACTIONS
 153
 154             // START MAIL INTERACTIONS
 155             migration.addColumn('mail_interactions', 'firstMsgDirection', {
 156                 type: Sequelize.ENUM('in', 'out'),
 157                 defaultValue: 'in',
 158                 allowNull: false
 159             });
 160
 161             // Update the firstMsgDirection column with correct value (direction of the first message for each interactions)
 162             migration.query("UPDATE mail_interactions t1, (SELECT MailInteractionId, MIN(id) AS messageid, ANY_VALUE(direction) AS direction FROM mail_messages WHERE MailInteractionId IS NOT NULL GROUP BY MailInteractionId) t2 SET t1.firstMsgDirection = t2.direction WHERE t1.id = t2.MailInteractionId;");
 163             // END MAIL INTERACTIONS
 164
 165             // START FAX INTERACTIONS
 166             migration.addColumn('fax_interactions', 'firstMsgDirection', {
 167                 type: Sequelize.ENUM('in', 'out'),
 168                 defaultValue: 'in',
 169                 allowNull: false
 170             });
 171
 172             // Update the firstMsgDirection column with correct value (direction of the first message for each interactions)
 173             migration.query("UPDATE fax_interactions t1, (SELECT FaxInteractionId, MIN(id) AS messageid, ANY_VALUE(direction) AS direction FROM fax_messages WHERE FaxInteractionId IS NOT NULL GROUP BY FaxInteractionId) t2 SET t1.firstMsgDirection = t2.direction WHERE t1.id = t2.FaxInteractionId;");
 174             // END FAX INTERACTIONS
 175
 176             // START rtp.conf
 177             try {
 178                 fs.writeFileSync('/etc/asterisk/stun_xcally.conf', '; STUN server list\n', {
 179                     encoding: 'utf8'
 180                 });
 181                 fs.writeFileSync('/etc/asterisk/turn_xcally.conf', '; TURN server list\n', {
 182                     encoding: 'utf8'
 183                 });
 184
 185                 var lines = fs.readFileSync('/etc/asterisk/rtp.conf', {
 186                     encoding: 'utf8'
 187                 });
 188
 189                 lines = _.replace(lines, '[ice_host_candidates]', '#include "stun_xcally.conf"\n#include "turn_xcally.conf"\n[ice_host_candidates]');
 190
 191                 fs.writeFileSync('/etc/asterisk/rtp.conf', lines, {
 192                     encoding: 'utf8'
 193                 });
 194                 fs.appendFileSync('/etc/asterisk/res_stun_monitor.conf', '#include "stun_xcally.conf"', {
 195                     encoding: 'utf8'
 196                 });
 197             } catch (err) {
 198                 logger.info(JSON.stringify(err));
 199             }
 200             // END rtp.conf
 201
 202             // START FINAL
 203             migration.final(resolve);
 204             // END FINAL
 205         });
 206     },
 207
 208     down: function(queryInterface, Sequelize) {
 209         var migration = new Migration(queryInterface);
 210     }
 211 };