server/migrations/2.0.41.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 exec = require('child_process').exec;
   8 var cmd = 'chown motion:asterisk /var/opt/motion2/server/files/attachments';
   9 var ls = 'ls -la /var/opt/motion2/server/files';
  10
  11 var Sequence = function() {};
  12
  13 Sequence.prototype.enqueue = function(fn) {
  14     this.tail = this.tail ? this.tail.finally(fn) : fn();
  15 };
  16
  17 var Migration = function(queryInterface) {
  18     this.queryInterface = queryInterface;
  19     this.sequence = new Sequence();
  20 };
  21
  22 Migration.prototype.changeColumn = function(table, column, type) {
  23     var _this = this;
  24     this.sequence.enqueue(function() {
  25         return _this.queryInterface
  26             .changeColumn(table, column, type)
  27             .then(function(res) {
  28                 logger.info('Changed column %s in table %s', column, table);
  29             })
  30             .catch(function(err) {
  31                 logger.info(JSON.stringify(err));
  32             });
  33     });
  34 };
  35
  36 Migration.prototype.addColumn = function(table, column, type) {
  37     var _this = this;
  38     this.sequence.enqueue(function() {
  39         return _this.queryInterface
  40             .addColumn(table, column, type)
  41             .then(function(res) {
  42                 logger.info('Added column %s to %s', column, table);
  43             })
  44             .catch(function(err) {
  45                 logger.info(JSON.stringify(err));
  46             });
  47     });
  48 };
  49
  50 Migration.prototype.dropTable = function(table) {
  51     var _this = this;
  52     this.sequence.enqueue(function() {
  53         return _this.queryInterface
  54             .dropTable(table, {
  55                 force: true
  56             })
  57             .then(function(res) {
  58                 logger.info('table dropped %s', table);
  59             })
  60             .catch(function(err) {
  61                 logger.info(JSON.stringify(err));
  62             });
  63     });
  64 };
  65
  66 Migration.prototype.addIndex = function(table, column, indexName) {
  67     var _this = this;
  68     this.sequence.enqueue(function() {
  69         return _this.queryInterface.addIndex(table, column, {
  70                 indexName: indexName
  71             })
  72             .then(function(res) {
  73                 logger.info('addIndex %s %s %s', table, column.join(','), indexName);
  74             })
  75             .catch(function(err) {
  76                 logger.info(JSON.stringify(err));
  77             });
  78     });
  79 };
  80
  81 Migration.prototype.query = function(sql) {
  82     var _this = this;
  83     this.sequence.enqueue(function() {
  84         return _this.queryInterface.sequelize.query(sql)
  85             .then(function(res) {
  86                 logger.info('query %s', sql);
  87             })
  88             .catch(function(err) {
  89                 logger.info(JSON.stringify(err));
  90             });
  91     });
  92 };
  93
  94 Migration.prototype.removeColumn = function(table, column) {
  95     var _this = this;
  96     this.sequence.enqueue(function() {
  97         return _this.queryInterface.removeColumn(table, column)
  98             .then(function(res) {
  99                 logger.info('Removed column %s from %s', column, table);
 100             })
 101             .catch(function(err) {
 102                 logger.info(util.inspect(err, {
 103                     showHidden: false,
 104                     depth: null
 105                 }));
 106             });
 107     });
 108 };
 109
 110
 111 Migration.prototype.final = function(resolve) {
 112     var _this = this;
 113     this.sequence.enqueue(function() {
 114         return resolve();
 115     });
 116 };
 117
 118 module.exports = {
 119     up: function(queryInterface, Sequelize) {
 120         return new BPromise(function(resolve, reject) {
 121             var migration = new Migration(queryInterface);
 122
 123             // START DESK ACCOUNTS
 124             migration.addColumn('int_desk_accounts', 'serverUrl', {
 125               type: Sequelize.STRING
 126             });
 127             // END DESK ACCOUNTS
 128
 129             // START CHAT INTERACTIONS
 130             migration.addColumn('chat_interactions', 'formData', {
 131               type: Sequelize.TEXT('long')
 132             });
 133             // END CHAT INTERACTIONS
 134
 135             // START CHAT MESSAGES
 136             migration.addColumn('chat_messages', 'secret', {
 137               type: Sequelize.BOOLEAN,
 138               defaultValue: false
 139             });
 140             // END CHAT MESSAGES
 141
 142             // START CHAT WEBSITES
 143             migration.addColumn('chat_websites', 'agentAvatar', {
 144               type: Sequelize.TEXT
 145             });
 146             migration.addColumn('chat_websites', 'showAgentAvatar', {
 147               type: Sequelize.BOOLEAN,
 148               defaultValue: false
 149             });
 150             // END CHAT WEBSITES
 151
 152             //START CUSTOM FIELDS
 153             migration.changeColumn('cm_custom_fields', 'values', {
 154               type: Sequelize.TEXT('long')
 155             });
 156             //END CUSTOM FIELDS
 157
 158            // START FINAL
 159            migration.final(resolve);
 160            // END FINAL
 161         });
 162     },
 163
 164     down: function(queryInterface, Sequelize) {
 165         var migration = new Migration(queryInterface);
 166     }
 167 };