server/migrations/2.0.39.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 ejs = require('ejs');
   8 var fs = require('fs');
   9 var path = require('path');
  10 var exec = require('child_process').exec;
  11
  12 var config = require('../config/environment');
  13
  14 var Sequence = function() {};
  15
  16 Sequence.prototype.enqueue = function(fn) {
  17   this.tail = this.tail ? this.tail.finally(fn) : fn();
  18 };
  19
  20 var Migration = function(queryInterface) {
  21   this.queryInterface = queryInterface;
  22   this.sequence = new Sequence();
  23 };
  24
  25 Migration.prototype.changeColumn = function(table, column, type) {
  26   var _this = this;
  27   this.sequence.enqueue(function() {
  28     return _this.queryInterface
  29       .changeColumn(table, column, type)
  30       .then(function(res) {
  31         logger.info('Changed column %s in table %s', column, table);
  32       })
  33       .catch(function(err) {
  34         logger.info(JSON.stringify(err));
  35       });
  36   });
  37 };
  38
  39 Migration.prototype.addColumn = function(table, column, type) {
  40   var _this = this;
  41   this.sequence.enqueue(function() {
  42     return _this.queryInterface
  43       .addColumn(table, column, type)
  44       .then(function(res) {
  45         logger.info('Added column %s to %s', column, table);
  46       })
  47       .catch(function(err) {
  48         logger.info(JSON.stringify(err));
  49       });
  50   });
  51 };
  52
  53 Migration.prototype.dropTable = function(table) {
  54   var _this = this;
  55   this.sequence.enqueue(function() {
  56     return _this.queryInterface
  57       .dropTable(table, {
  58         force: true
  59       })
  60       .then(function(res) {
  61         logger.info('table dropped %s', table);
  62       })
  63       .catch(function(err) {
  64         logger.info(JSON.stringify(err));
  65       });
  66   });
  67 };
  68
  69 Migration.prototype.addIndex = function(table, column, indexName) {
  70   var _this = this;
  71   this.sequence.enqueue(function() {
  72     return _this.queryInterface.addIndex(table, column, {
  73         indexName: indexName
  74       })
  75       .then(function(res) {
  76         logger.info('addIndex %s %s %s', table, column.join(','), indexName);
  77       })
  78       .catch(function(err) {
  79         logger.info(JSON.stringify(err));
  80       });
  81   });
  82 };
  83
  84 Migration.prototype.query = function(sql) {
  85   var _this = this;
  86   this.sequence.enqueue(function() {
  87     return _this.queryInterface.sequelize.query(sql)
  88       .then(function(res) {
  89         logger.info('query %s', sql);
  90       })
  91       .catch(function(err) {
  92         logger.info(JSON.stringify(err));
  93       });
  94   });
  95 };
  96
  97 Migration.prototype.removeColumn = function(table, column) {
  98   var _this = this;
  99   this.sequence.enqueue(function() {
 100     return _this.queryInterface.removeColumn(table, column)
 101       .then(function(res) {
 102         logger.info('Removed column %s from %s', column, table);
 103       })
 104       .catch(function(err) {
 105         logger.info(util.inspect(err, {
 106           showHidden: false,
 107           depth: null
 108         }));
 109       });
 110   });
 111 };
 112
 113 Migration.prototype.checkVoiceContexts = function() {
 114   var _this = this;
 115   var VoiceContext = _this.queryInterface.sequelize.import(path.join(config.root, 'server/api/voiceContext/voiceContext.model'));
 116   this.sequence.enqueue(function() {
 117     return VoiceContext.findOrCreate({
 118         where: {
 119           name: 'xcally-mixmonitor-context'
 120         },
 121         defaults: {
 122           name: 'xcally-mixmonitor-context',
 123           description: 'default entry context (DO NOT DELETE)',
 124           defaultEntry: true
 125         }
 126       })
 127       .spread(function(entity, created) {
 128         return VoiceContext
 129           .findAll({
 130             raw: true
 131           });
 132       })
 133       .then(function(contexts) {
 134         var templateContext = fs.readFileSync(path.join(config.root, 'server/files/templates/context.ejs'), 'utf8');
 135
 136         var contextsFile = ejs.render(templateContext, {
 137           contexts: contexts || []
 138         });
 139
 140         fs.writeFileSync('/etc/asterisk/extensions_xcally_contexts.conf', contextsFile);
 141
 142         exec('asterisk -rx "reload chan_sip.so"', function(err, stdout, stderr) {
 143           logger.info('Exec chmod', ' Error :', JSON.stringify(err), stdout, stderr);
 144         });
 145
 146       })
 147       .catch(function(err) {
 148         logger.info(JSON.stringify(err));
 149       });
 150   });
 151 };
 152
 153 Migration.prototype.final = function(resolve) {
 154   var _this = this;
 155   this.sequence.enqueue(function() {
 156     return resolve();
 157   });
 158 };
 159
 160 module.exports = {
 161   up: function(queryInterface, Sequelize) {
 162     return new BPromise(function(resolve, reject) {
 163       var migration = new Migration(queryInterface);
 164       // START SETTINGS
 165       migration.addColumn('settings', 'defaultPageTitle', {
 166         type: Sequelize.BOOLEAN,
 167         defaultValue: true
 168       });
 169       migration.addColumn('settings', 'pageTitle', {
 170         type: Sequelize.STRING
 171       });
 172       // END SETTINGS
 173
 174       // START VOICECONTEXT
 175       migration.checkVoiceContexts();
 176       // END VOICECONTEXT
 177
 178       // START SALESFORCE CONF
 179       migration.addColumn('int_salesforce_configurations', 'moduleSearch', {
 180         type: Sequelize.ENUM('contact_lead', 'contact', 'lead'),
 181         defaultValue: 'contact_lead'
 182       });
 183       migration.addColumn('int_salesforce_configurations', 'moduleCreate', {
 184         type: Sequelize.ENUM('nothing', 'contact', 'lead'),
 185         defaultValue: 'lead'
 186       });
 187       // END SALESFORCE CONF
 188
 189       // START FAX
 190       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '1', 'NoOp', '', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 191
 192       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '2', 'Set', 'CDR(type)=outbound-fax', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 193
 194       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '3', 'Wait', '6', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 195
 196       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '4', 'Set', 'FAXOPT(ecm)=${XMF-ECM}', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 197
 198       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '5', 'Set', 'FAXOPT(headerinfo)=${XMF-HEADERINFO}', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 199
 200       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '6', 'Set', 'FAXOPT(localstationid)=${XMF-LOCALSTATIONID}', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 201
 202       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '7', 'Set', 'FAXOPT(maxrate)=${XMF-MAXRATE}', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 203
 204       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '8', 'Set', 'FAXOPT(minrate)=${XMF-MINRATE}', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 205
 206       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '9', 'Set', 'FAXOPT(modem)=${XMF-MODEM}', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 207
 208       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '10', 'Set', 'FAXOPT(t38timeout)=${XMF-T38TIMEOUT}', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 209
 210       migration.query("INSERT INTO `voice_extensions` (`context`, `exten`, `priority`, `app`, `appdata`, `type`, `description`, `createdAt`, `updatedAt`) VALUES ('from-sip', 'xcally-motion-fax', '11', 'SendFax', '${XMF-PATH},d', 'system', 'Fax extensions auto generated', NOW(), NOW());");
 211
 212       exec('chmod 775 /var/opt/motion2/server/files/attachments', function(err, stdout, stderr) {
 213         logger.info('Exec chmod', ' Error :', JSON.stringify(err), stdout, stderr);
 214         exec('ls -la /var/opt/motion2/server/files', function(err, stdout, stderr) {
 215           logger.info('Ls :', ' Error :', JSON.stringify(err), stdout, stderr);
 216         });
 217       });
 218       // END FAX
 219
 220       // START CONTACT
 221       migration.addColumn('cm_contacts', 'deletedAt', {
 222         type: Sequelize.DATE,
 223         defaultValue: null
 224       });
 225       // END CONTACT
 226
 227       // START FINAL
 228       migration.final(resolve);
 229       // END FINAL
 230     });
 231   },
 232
 233   down: function(queryInterface, Sequelize) {
 234     var migration = new Migration(queryInterface);
 235   }
 236 };