12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485 |
- const migrate_name = 'ssl_passthrough_host';
- const logger = require('../logger').migrate;
- /**
- * Migrate
- *
- * @see http://knexjs.org/#Schema
- *
- * @param {Object} knex
- * @param {Promise} Promise
- * @returns {Promise}
- */
- exports.up = async function (knex/*, Promise*/) {
- logger.info('[' + migrate_name + '] Migrating Up...');
- await knex.schema.createTable('ssl_passthrough_host', (table) => {
- table.increments().primary();
- table.dateTime('created_on').notNull();
- table.dateTime('modified_on').notNull();
- table.integer('owner_user_id').notNull().unsigned();
- table.integer('is_deleted').notNull().unsigned().defaultTo(0);
- table.string('domain_name').notNull();
- table.string('forwarding_host').notNull();
- table.integer('forwarding_port').notNull().unsigned();
- table.integer('enabled').notNull().unsigned().defaultTo(1);
- table.json('meta').notNull();
- });
- logger.info('[' + migrate_name + '] Table created');
- // Remove unique constraint so name can be used for new table
- await knex.schema.alterTable('user_permission', (table) => {
- table.dropUnique('user_id');
- });
- await knex.schema.renameTable('user_permission', 'user_permission_old');
- // We need to recreate the table since sqlite does not support altering columns
- await knex.schema.createTable('user_permission', (table) => {
- table.increments().primary();
- table.dateTime('created_on').notNull();
- table.dateTime('modified_on').notNull();
- table.integer('user_id').notNull().unsigned();
- table.string('visibility').notNull();
- table.string('proxy_hosts').notNull();
- table.string('redirection_hosts').notNull();
- table.string('dead_hosts').notNull();
- table.string('streams').notNull();
- table.string('ssl_passthrough_hosts').notNull();
- table.string('access_lists').notNull();
- table.string('certificates').notNull();
- table.unique('user_id');
- });
- await knex('user_permission_old').select('*', 'streams as ssl_passthrough_hosts').then((data) => {
- if (data.length) {
- return knex('user_permission').insert(data);
- }
- return Promise.resolve();
- });
- await knex.schema.dropTableIfExists('user_permission_old');
- logger.info('[' + migrate_name + '] permissions updated');
- };
- /**
- * Undo Migrate
- *
- * @param {Object} knex
- * @param {Promise} Promise
- * @returns {Promise}
- */
- exports.down = function (knex/*, Promise*/) {
- logger.info('[' + migrate_name + '] Migrating Down...');
- return knex.schema.dropTable('stream').then(() => {
- return knex.schema.table('user_permission', (table) => {
- table.dropColumn('ssl_passthrough_hosts');
- });
- })
- .then(function () {
- logger.info('[' + migrate_name + '] Table altered and permissions updated');
- });
- };
|