3 var BPromise = require('bluebird');
4 var util = require('util');
6 var logger = require('../config/logger')('migration');
8 var Sequence = function() {};
10 Sequence.prototype.enqueue = function(fn) {
11 this.tail = this.tail ? this.tail.finally(fn) : fn();
14 var Migration = function(queryInterface) {
15 this.queryInterface = queryInterface;
16 this.sequence = new Sequence();
19 Migration.prototype.changeColumn = function(table, column, type) {
21 this.sequence.enqueue(function() {
22 return _this.queryInterface
23 .changeColumn(table, column, type)
25 logger.info('Changed column %s in table %s', column, table);
27 .catch(function(err) {
28 logger.info(JSON.stringify(err));
33 Migration.prototype.addColumn = function(table, column, type) {
35 this.sequence.enqueue(function() {
36 return _this.queryInterface
37 .addColumn(table, column, type)
39 logger.info('Added column %s to %s', column, table);
41 .catch(function(err) {
42 logger.info(JSON.stringify(err));
47 Migration.prototype.dropTable = function(table) {
49 this.sequence.enqueue(function() {
50 return _this.queryInterface
55 logger.info('table dropped %s', table);
57 .catch(function(err) {
58 logger.info(JSON.stringify(err));
63 Migration.prototype.addIndex = function(table, column, indexName) {
65 this.sequence.enqueue(function() {
66 return _this.queryInterface.addIndex(table, column, {
70 logger.info('addIndex %s %s %s', table, column.join(','), indexName);
72 .catch(function(err) {
73 logger.info(JSON.stringify(err));
78 Migration.prototype.removeIndex = function(table, indexName) {
80 this.sequence.enqueue(function() {
81 return _this.queryInterface.removeIndex(table, indexName)
83 logger.info('removeIndex %s %s', table, indexName);
85 .catch(function(err) {
86 logger.info(JSON.stringify(err));
91 Migration.prototype.query = function(sql) {
93 this.sequence.enqueue(function() {
94 return _this.queryInterface.sequelize.query(sql)
96 logger.info('query %s', sql);
98 .catch(function(err) {
99 logger.info(JSON.stringify(err));
104 Migration.prototype.removeColumn = function(table, column) {
106 this.sequence.enqueue(function() {
107 return _this.queryInterface.removeColumn(table, column)
109 logger.info('Removed column %s from %s', column, table);
111 .catch(function(err) {
112 logger.info(util.inspect(err, {
120 Migration.prototype.renameColumn = function(table, oldColumn, newColumn) {
122 this.sequence.enqueue(function() {
123 return _this.queryInterface.renameColumn(table, oldColumn, newColumn)
125 logger.info('Renamed column from %s to %s on %s', oldColumn, newColumn, table);
127 .catch(function(err) {
128 logger.info(util.inspect(err, {
136 Migration.prototype.final = function(resolve) {
137 this.sequence.enqueue(function() {
143 up: function(queryInterface, Sequelize) {
144 return new BPromise(function(resolve) {
145 var migration = new Migration(queryInterface);
147 // START report_jscripty_answers
148 migration.changeColumn('report_jscripty_answers', 'answer', {
149 type: Sequelize.TEXT('long')
151 // END report_jscripty_answers
153 // START report_jscripty_questions
154 migration.changeColumn('report_jscripty_questions', 'answer', {
155 type: Sequelize.TEXT('long')
157 // END report_jscripty_questions
159 // START tools_sounds
161 'UPDATE tools_sounds S1 JOIN \
162 (SELECT name FROM tools_sounds GROUP BY name HAVING COUNT(id) > 1) S2 \
163 ON S1.name = S2.name \
164 SET S1.name = CONCAT(S1.name, \'_\', LOWER(LPAD(CONV(FLOOR(RAND()*POW(36,6)), 10, 36), 6, 0)))'
167 migration.changeColumn('tools_sounds', 'name', {
168 type: Sequelize.STRING,
173 // START chat_websites
174 migration.addColumn('chat_websites', 'messageFontSize', {
175 type: Sequelize.INTEGER,
179 migration.addColumn('chat_websites', 'backgroundColor', {
180 type: Sequelize.STRING,
182 defaultValue: '#fafafa',
190 migration.addColumn('cm_contacts', 'line', {
191 type: Sequelize.STRING
195 // START voice_prefixes
196 migration.query('DELETE FROM `voice_prefixes`');
197 migration.query('DELETE FROM `user_has_voice_prefixes`');
198 migration.removeIndex('voice_prefixes', 'prefix');
199 migration.removeColumn('voice_prefixes', 'prefix');
200 migration.addColumn('voice_prefixes', 'callerIdAll', {
201 type: Sequelize.STRING
203 migration.addColumn('voice_prefixes', 'VoiceExtensionId', {
204 type: Sequelize.INTEGER
206 // END voice_prefixes
208 // START voice_extensions
209 migration.addColumn('voice_extensions', 'VoicePrefixId', {
210 type: Sequelize.INTEGER
214 'ALTER TABLE `voice_extensions` \
215 ADD CONSTRAINT `voice_extensions_ibfk_7` \
216 FOREIGN KEY (`VoicePrefixId`) \
217 REFERENCES voice_prefixes(`id`) \
223 'update voice_extensions set app = \'ExecIf\', appdata = CONCAT(\'$[${LEN(${PREFIX-CALLERIDALL})} > 0]?Set(CALLERID(all)=${PREFIX-CALLERIDALL}):Set(\', appdata, \')\') where appdata LIKE CONCAT(\'CALLERID(all)\', \'%\') and type = \'outbound\''
225 // END voice_extensions
228 migration.addColumn('report_call', 'prefix', {
229 type: Sequelize.STRING
234 migration.final(resolve);
239 down: function(queryInterface, Sequelize) {
240 // var migration = new Migration(queryInterface);