groot/automatisch
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: Convert migration files to JS

Browse Source
This commit is contained in:
Faruk AYDIN
2024-01-04 21:44:40 +01:00
parent 6d1bfc0be0
commit 0f71924d06
64 changed files with 235 additions and 326 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/backend/knexfile.ts
View File

@@ -1,7 +1,7 @@
import { knexSnakeCaseMappers } from 'objection';
import appConfig from './src/config/app';
const fileExtension = appConfig.isDev || appConfig.isTest ? 'ts' : 'js';
const fileExtension = 'js';
const knexConfig = {
client: 'pg',

6
packages/backend/src/db/migrations/20211005151457_create_users.ts → packages/backend/src/db/migrations/20211005151457_create_users.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('users', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.string('email').unique().notNullable();
@@ -10,6 +8,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('users');
}

6
packages/backend/src/db/migrations/20211011120732_create_credentials.ts → packages/backend/src/db/migrations/20211011120732_create_credentials.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('credentials', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.string('key').notNullable();
@@ -13,6 +11,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('credentials');
}

6
packages/backend/src/db/migrations/20211014144855_remove_display_name_from_credentials.ts → packages/backend/src/db/migrations/20211014144855_remove_display_name_from_credentials.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('credentials', (table) => {
table.dropColumn('display_name');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('credentials', (table) => {
table.string('display_name');
});

7
packages/backend/src/db/migrations/20211017104154_rename_credentials_as_connections.js Normal file
View File

@@ -0,0 +1,7 @@
export async function up(knex) {
return knex.schema.renameTable('credentials', 'connections');
}
export async function down(knex) {
return knex.schema.renameTable('connections', 'credentials');
}

9
packages/backend/src/db/migrations/20211017104154_rename_credentials_as_connections.ts
View File

@@ -1,9 +0,0 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
return knex.schema.renameTable('credentials', 'connections');
}
export async function down(knex: Knex): Promise<void> {
return knex.schema.renameTable('connections', 'credentials');
}

6
packages/backend/src/db/migrations/20211106214730_create_steps.ts → packages/backend/src/db/migrations/20211106214730_create_steps.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('steps', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.string('key').notNullable();
@@ -13,6 +11,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('steps');
}

6
packages/backend/src/db/migrations/20211122140336_create_flows.ts → packages/backend/src/db/migrations/20211122140336_create_flows.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('flows', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.string('name');
@@ -10,6 +8,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('flows');
}

6
packages/backend/src/db/migrations/20211122140612_add_flow_id_to_steps.ts → packages/backend/src/db/migrations/20211122140612_add_flow_id_to_steps.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('steps', (table) => {
table.uuid('flow_id').references('id').inTable('flows');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('steps', (table) => {
table.dropColumn('flow_id');
});

6
packages/backend/src/db/migrations/20220105151725_remove_constraints_from_steps.ts → packages/backend/src/db/migrations/20220105151725_remove_constraints_from_steps.js
View File

@@ -1,13 +1,11 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.alterTable('steps', (table) => {
table.string('key').nullable().alter();
table.string('app_key').nullable().alter();
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.alterTable('steps', (table) => {
table.string('key').notNullable().alter();
table.string('app_key').notNullable().alter();

6
packages/backend/src/db/migrations/20220108141045_add_active_column_to_flows.ts → packages/backend/src/db/migrations/20220108141045_add_active_column_to_flows.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('flows', (table) => {
table.boolean('active').defaultTo(false);
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('flows', (table) => {
table.dropColumn('active');
});

6
packages/backend/src/db/migrations/20220127141941_add_position_to_steps.ts → packages/backend/src/db/migrations/20220127141941_add_position_to_steps.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('steps', (table) => {
table.integer('position').notNullable();
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('steps', (table) => {
table.dropColumn('position');
});

6
packages/backend/src/db/migrations/20220205145128_add_status_to_steps.ts → packages/backend/src/db/migrations/20220205145128_add_status_to_steps.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('steps', (table) => {
table.string('status').notNullable().defaultTo('incomplete');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('steps', (table) => {
table.dropColumn('status');
});

6
packages/backend/src/db/migrations/20220219093113_create_executions.ts → packages/backend/src/db/migrations/20220219093113_create_executions.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('executions', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.uuid('flow_id').references('id').inTable('flows');
@@ -10,6 +8,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('executions');
}

6
packages/backend/src/db/migrations/20220219100800_create_execution_steps.ts → packages/backend/src/db/migrations/20220219100800_create_execution_steps.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('execution_steps', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.uuid('execution_id').references('id').inTable('executions');
@@ -13,6 +11,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('execution_steps');
}

6
packages/backend/src/db/migrations/20220221225128_alter_columns_of_execution_steps.ts → packages/backend/src/db/migrations/20220221225128_alter_columns_of_execution_steps.js
View File

@@ -1,13 +1,11 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.alterTable('execution_steps', (table) => {
table.jsonb('data_in').alter();
table.jsonb('data_out').alter();
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.alterTable('execution_steps', (table) => {
table.text('data_in').alter();
table.text('data_out').alter();

6
packages/backend/src/db/migrations/20220221225537_alter_parameters_column_of_steps.ts → packages/backend/src/db/migrations/20220221225537_alter_parameters_column_of_steps.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.alterTable('steps', (table) => {
table.jsonb('parameters').defaultTo('{}').alter();
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.alterTable('steps', (table) => {
table.text('parameters').alter();
});

6
packages/backend/src/db/migrations/20220727104324_add_draft_column_to_connections.ts → packages/backend/src/db/migrations/20220727104324_add_draft_column_to_connections.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('connections', (table) => {
table.boolean('draft').defaultTo(true);
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('connections', (table) => {
table.dropColumn('draft');
});

6
packages/backend/src/db/migrations/20220817121241_add_published_at_column_to_flows.ts → packages/backend/src/db/migrations/20220817121241_add_published_at_column_to_flows.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('flows', (table) => {
table.timestamp('published_at').nullable();
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('flows', (table) => {
table.dropColumn('published_at');
});

6
packages/backend/src/db/migrations/20220823171017_add_internal_id_to_executions.ts → packages/backend/src/db/migrations/20220823171017_add_internal_id_to_executions.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('executions', (table) => {
table.string('internal_id');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('executions', (table) => {
table.dropColumn('internal_id');
});

6
packages/backend/src/db/migrations/20220904160521_add_raw_error_to_execution_steps.ts → packages/backend/src/db/migrations/20220904160521_add_raw_error_to_execution_steps.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('execution_steps', (table) => {
table.jsonb('error_details');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('execution_steps', (table) => {
table.dropColumn('error_details');
});

10
packages/backend/src/db/migrations/20220928162525_soft-delete-base-model.ts → packages/backend/src/db/migrations/20220928162525_soft-delete-base-model.js
View File

@@ -1,18 +1,16 @@
import { Knex } from 'knex';
async function addDeletedColumn(knex: Knex, tableName: string) {
async function addDeletedColumn(knex, tableName) {
return await knex.schema.table(tableName, (table) => {
table.timestamp('deleted_at').nullable();
});
}
async function dropDeletedColumn(knex: Knex, tableName: string) {
async function dropDeletedColumn(knex, tableName) {
return await knex.schema.table(tableName, (table) => {
table.dropColumn('deleted_at');
});
}
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
await addDeletedColumn(knex, 'steps');
await addDeletedColumn(knex, 'flows');
await addDeletedColumn(knex, 'executions');
@@ -21,7 +19,7 @@ export async function up(knex: Knex): Promise<void> {
await addDeletedColumn(knex, 'connections');
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
await dropDeletedColumn(knex, 'steps');
await dropDeletedColumn(knex, 'flows');
await dropDeletedColumn(knex, 'executions');

6
packages/backend/src/db/migrations/20221214184855_add_remote_webhook_id_in_flow.ts → packages/backend/src/db/migrations/20221214184855_add_remote_webhook_id_in_flow.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('flows', (table) => {
table.string('remote_webhook_id');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('flows', (table) => {
table.dropColumn('remote_webhook_id');
});

6
packages/backend/src/db/migrations/20230218110748_add_role_to_users.ts → packages/backend/src/db/migrations/20230218110748_add_role_to_users.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('users', async (table) => {
table.string('role');
@@ -8,7 +6,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('users', (table) => {
table.dropColumn('role');
});

6
packages/backend/src/db/migrations/20230218131824_alter_role_to_not_nullable_for_users.ts → packages/backend/src/db/migrations/20230218131824_alter_role_to_not_nullable_for_users.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.alterTable('users', (table) => {
table.string('role').notNullable().alter();
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.alterTable('users', (table) => {
table.string('role').nullable().alter();
});

6
packages/backend/src/db/migrations/20230218150517_add_reset_password_token_to_users.ts → packages/backend/src/db/migrations/20230218150517_add_reset_password_token_to_users.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('users', (table) => {
table.string('reset_password_token');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('users', (table) => {
table.dropColumn('reset_password_token');
});

6
packages/backend/src/db/migrations/20230218150758_add_reset_password_token_sent_at_to_users.ts → packages/backend/src/db/migrations/20230218150758_add_reset_password_token_sent_at_to_users.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('users', (table) => {
table.timestamp('reset_password_token_sent_at');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('users', (table) => {
table.dropColumn('reset_password_token_sent_at');
});

6
packages/backend/src/db/migrations/20230301211751_add_full_name_to_users.ts → packages/backend/src/db/migrations/20230301211751_add_full_name_to_users.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('users', async (table) => {
table.string('full_name');
@@ -8,7 +6,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('users', (table) => {
table.dropColumn('full_name');
});

5
packages/backend/src/db/migrations/20230303134548_create_payment_plans.ts → packages/backend/src/db/migrations/20230303134548_create_payment_plans.js
View File

@@ -1,7 +1,6 @@
import { Knex } from 'knex';
import appConfig from '../../config/app';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
if (!appConfig.isCloud) return;
return knex.schema.createTable('payment_plans', (table) => {
@@ -18,7 +17,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
if (!appConfig.isCloud) return;
return knex.schema.dropTable('payment_plans');
}

5
packages/backend/src/db/migrations/20230303180902_create_usage_data.ts → packages/backend/src/db/migrations/20230303180902_create_usage_data.js
View File

@@ -1,7 +1,6 @@
import { Knex } from 'knex';
import appConfig from '../../config/app';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
if (!appConfig.isCloud) return;
return knex.schema.createTable('usage_data', (table) => {
@@ -14,7 +13,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
if (!appConfig.isCloud) return;
return knex.schema.dropTable('usage_data');
}

5
packages/backend/src/db/migrations/20230306103149_alter_consumed_task_count_of_usage_data.ts → packages/backend/src/db/migrations/20230306103149_alter_consumed_task_count_of_usage_data.js
View File

@@ -1,7 +1,6 @@
import { Knex } from 'knex';
import appConfig from '../../config/app';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
if (!appConfig.isCloud) return;
return knex.schema.alterTable('usage_data', (table) => {
@@ -9,7 +8,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
if (!appConfig.isCloud) return;
return knex.schema.alterTable('usage_data', (table) => {

5
packages/backend/src/db/migrations/20230318220822_add_trial_expiry_date_to_users.ts → packages/backend/src/db/migrations/20230318220822_add_trial_expiry_date_to_users.js
View File

@@ -1,7 +1,6 @@
import { Knex } from 'knex';
import appConfig from '../../config/app';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
if (!appConfig.isCloud) return;
return knex.schema.table('users', (table) => {
@@ -9,7 +8,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
if (!appConfig.isCloud) return;
return knex.schema.table('users', (table) => {

5
packages/backend/src/db/migrations/20230323145809_create_subscriptions.ts → packages/backend/src/db/migrations/20230323145809_create_subscriptions.js
View File

@@ -1,7 +1,6 @@
import { Knex } from 'knex';
import appConfig from '../../config/app';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
if (!appConfig.isCloud) return;
return knex.schema.createTable('subscriptions', (table) => {
@@ -20,7 +19,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
if (!appConfig.isCloud) return;
return knex.schema.dropTable('subscriptions');

5
packages/backend/src/db/migrations/20230324210051_add_deleted_at_to_subscriptions.ts → packages/backend/src/db/migrations/20230324210051_add_deleted_at_to_subscriptions.js
View File

@@ -1,7 +1,6 @@
import { Knex } from 'knex';
import appConfig from '../../config/app';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
if (!appConfig.isCloud) return;
return knex.schema.alterTable('subscriptions', (table) => {
@@ -9,7 +8,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
if (!appConfig.isCloud) return;
return knex.schema.alterTable('subscriptions', (table) => {

5
packages/backend/src/db/migrations/20230402183738_add_subscription_id_in_usage_data.ts → packages/backend/src/db/migrations/20230402183738_add_subscription_id_in_usage_data.js
View File

@@ -1,7 +1,6 @@
import { Knex } from 'knex';
import appConfig from '../../config/app';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
if (!appConfig.isCloud) return;
return knex.schema.table('usage_data', (table) => {
@@ -9,7 +8,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
if (!appConfig.isCloud) return;
return knex.schema.table('usage_data', (table) => {

5
packages/backend/src/db/migrations/20230411203412_add_cancellation_effective_date_to_subscriptions.ts → packages/backend/src/db/migrations/20230411203412_add_cancellation_effective_date_to_subscriptions.js
View File

@@ -1,7 +1,6 @@
import { Knex } from 'knex';
import appConfig from '../../config/app';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
if (!appConfig.isCloud) return;
return knex.schema.table('subscriptions', (table) => {
@@ -9,7 +8,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
if (!appConfig.isCloud) return;
return knex.schema.table('subscriptions', (table) => {

5
packages/backend/src/db/migrations/20230415134138_drop_payment_plans.ts → packages/backend/src/db/migrations/20230415134138_drop_payment_plans.js
View File

@@ -1,13 +1,12 @@
import { Knex } from 'knex';
import appConfig from '../../config/app';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
if (!appConfig.isCloud) return;
return knex.schema.dropTable('payment_plans');
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
if (!appConfig.isCloud) return;
return knex.schema.createTable('payment_plans', (table) => {

6
packages/backend/src/db/migrations/20230609201228_add_webhook_path_in_step.ts → packages/backend/src/db/migrations/20230609201228_add_webhook_path_in_step.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.table('steps', (table) => {
table.string('webhook_path');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.table('steps', (table) => {
table.dropColumn('webhook_path');
});

23
packages/backend/src/db/migrations/20230609201909_populate_data_in_webhook_path_in_step.js Normal file
View File

@@ -0,0 +1,23 @@
export async function up(knex) {
return await knex('steps')
.where('type', 'trigger')
.whereIn('app_key', [
'gitlab',
'typeform',
'twilio',
'flowers-software',
'webhook',
])
.update({
webhook_path: knex.raw('? || ??', [
'/webhooks/flows/',
knex.ref('flow_id'),
]),
});
}
export async function down(knex) {
return await knex('steps').update({
webhook_path: null,
});
}

16
packages/backend/src/db/migrations/20230609201909_populate_data_in_webhook_path_in_step.ts
View File

@@ -1,16 +0,0 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
return await knex('steps')
.where('type', 'trigger')
.whereIn('app_key', ['gitlab', 'typeform', 'twilio', 'flowers-software', 'webhook'])
.update({
webhook_path: knex.raw('? || ??', ['/webhooks/flows/', knex.ref('flow_id')]),
});
}
export async function down(knex: Knex): Promise<void> {
return await knex('steps').update({
webhook_path: null
});
}

9
packages/backend/src/db/migrations/20230615200200_create_roles.ts → packages/backend/src/db/migrations/20230615200200_create_roles.js
View File

@@ -1,8 +1,7 @@
import { Knex } from 'knex';
import capitalize from 'lodash/capitalize';
import lowerCase from 'lodash/lowerCase';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
await knex.schema.createTable('roles', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.string('name').notNullable();
@@ -12,9 +11,7 @@ export async function up(knex: Knex): Promise<void> {
table.timestamps(true, true);
});
const uniqueUserRoles = await knex('users')
.select('role')
.groupBy('role');
const uniqueUserRoles = await knex('users').select('role').groupBy('role');
let shouldCreateAdminRole = true;
for (const { role } of uniqueUserRoles) {
@@ -41,6 +38,6 @@ export async function up(knex: Knex): Promise<void> {
}
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('roles');
}

40
packages/backend/src/db/migrations/20230615205857_create_permissions.ts → packages/backend/src/db/migrations/20230615205857_create_permissions.js
View File

@@ -1,14 +1,12 @@
import { Knex } from 'knex';
const getPermissionForRole = (roleId: string, subject: string, actions: string[], conditions: string[] = []) => actions
.map(action => ({
const getPermissionForRole = (roleId, subject, actions, conditions = []) =>
actions.map((action) => ({
role_id: roleId,
subject,
action,
conditions,
}));
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
await knex.schema.createTable('permissions', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.uuid('role_id').references('id').inTable('roles');
@@ -19,7 +17,7 @@ export async function up(knex: Knex): Promise<void> {
table.timestamps(true, true);
});
const roles = await knex('roles').select(['id', 'key']) as { id: string, key: string }[];
const roles = await knex('roles').select(['id', 'key']);
for (const role of roles) {
// `admin` role should have no conditions unlike others by default
@@ -28,21 +26,41 @@ export async function up(knex: Knex): Promise<void> {
// default permissions
await knex('permissions').insert([
...getPermissionForRole(role.id, 'Connection', ['create', 'read', 'delete', 'update'], roleConditions),
...getPermissionForRole(
role.id,
'Connection',
['create', 'read', 'delete', 'update'],
roleConditions
),
...getPermissionForRole(role.id, 'Execution', ['read'], roleConditions),
...getPermissionForRole(role.id, 'Flow', ['create', 'delete', 'publish', 'read', 'update'], roleConditions),
...getPermissionForRole(
role.id,
'Flow',
['create', 'delete', 'publish', 'read', 'update'],
roleConditions
),
]);
// admin specific permission
if (isAdmin) {
await knex('permissions').insert([
...getPermissionForRole(role.id, 'User', ['create', 'read', 'delete', 'update']),
...getPermissionForRole(role.id, 'Role', ['create', 'read', 'delete', 'update']),
...getPermissionForRole(role.id, 'User', [
'create',
'read',
'delete',
'update',
]),
...getPermissionForRole(role.id, 'Role', [
'create',
'read',
'delete',
'update',
]),
]);
}
}
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('permissions');
}

10
packages/backend/src/db/migrations/20230615215004_add_role_id_to_users.ts → packages/backend/src/db/migrations/20230615215004_add_role_id_to_users.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
await knex.schema.table('users', async (table) => {
table.uuid('role_id').references('id').inTable('roles');
});
@@ -11,10 +9,10 @@ export async function up(knex: Knex): Promise<void> {
for (const role of roles) {
await knex('users')
.where({
role: role.key
role: role.key,
})
.update({
role_id: role.id
role_id: role.id,
});
}
@@ -22,7 +20,7 @@ export async function up(knex: Knex): Promise<void> {
await knex('users').whereNull('role_id').update({ role_id: theRole.id });
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return await knex.schema.table('users', (table) => {
table.dropColumn('role_id');
});

6
packages/backend/src/db/migrations/20230623115503_remove_role_column_in_users.ts → packages/backend/src/db/migrations/20230623115503_remove_role_column_in_users.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
await knex.schema.table('users', async (table) => {
table.dropColumn('role');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return await knex.schema.table('users', (table) => {
table.string('role').defaultTo('user');
});

6
packages/backend/src/db/migrations/20230702210636_create_saml_auth_providers.ts → packages/backend/src/db/migrations/20230702210636_create_saml_auth_providers.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('saml_auth_providers', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.string('name').notNullable();
@@ -19,6 +17,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('saml_auth_providers');
}

6
packages/backend/src/db/migrations/20230707094923_create_identities.ts → packages/backend/src/db/migrations/20230707094923_create_identities.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('identities', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.uuid('user_id').references('id').inTable('users');
@@ -12,6 +10,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('identities');
}

6
packages/backend/src/db/migrations/20230715214424_make_user_password_nullable.ts → packages/backend/src/db/migrations/20230715214424_make_user_password_nullable.js
View File

@@ -1,11 +1,9 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return await knex.schema.alterTable('users', (table) => {
table.string('password').nullable().alter();
});
}
export async function down(): Promise<void> {
export async function down() {
// void
}

16
packages/backend/src/db/migrations/20230807114158_seed_saml_permissions_to_admin.ts → packages/backend/src/db/migrations/20230807114158_seed_saml_permissions_to_admin.js
View File

@@ -1,10 +1,4 @@
import { Knex } from 'knex';
const getPermissionForRole = (
roleId: string,
subject: string,
actions: string[]
) =>
const getPermissionForRole = (roleId, subject, actions) =>
actions.map((action) => ({
role_id: roleId,
subject,
@@ -12,11 +6,11 @@ const getPermissionForRole = (
conditions: [],
}));
export async function up(knex: Knex): Promise<void> {
const role = (await knex('roles')
export async function up(knex) {
const role = await knex('roles')
.first(['id', 'key'])
.where({ key: 'admin' })
.limit(1)) as { id: string; key: string };
.limit(1);
await knex('permissions').insert(
getPermissionForRole(role.id, 'SamlAuthProvider', [
@@ -28,6 +22,6 @@ export async function up(knex: Knex): Promise<void> {
);
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
await knex('permissions').where({ subject: 'SamlAuthProvider' }).delete();
}

6
packages/backend/src/db/migrations/20230810124730_create_config.ts → packages/backend/src/db/migrations/20230810124730_create_config.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('config', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.string('key').unique().notNullable();
@@ -10,6 +8,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('config');
}

22
packages/backend/src/db/migrations/20230810134714_seed_update_config_permissions_to_admin.js Normal file
View File

@@ -0,0 +1,22 @@
const getPermissionForRole = (roleId, subject, actions) =>
actions.map((action) => ({
role_id: roleId,
subject,
action,
conditions: [],
}));
export async function up(knex) {
const role = await knex('roles')
.first(['id', 'key'])
.where({ key: 'admin' })
.limit(1);
await knex('permissions').insert(
getPermissionForRole(role.id, 'Config', ['update'])
);
}
export async function down(knex) {
await knex('permissions').where({ subject: 'Config' }).delete();
}

30
packages/backend/src/db/migrations/20230810134714_seed_update_config_permissions_to_admin.ts
View File

@@ -1,30 +0,0 @@
import { Knex } from 'knex';
const getPermissionForRole = (
roleId: string,
subject: string,
actions: string[]
) =>
actions.map((action) => ({
role_id: roleId,
subject,
action,
conditions: [],
}));
export async function up(knex: Knex): Promise<void> {
const role = (await knex('roles')
.first(['id', 'key'])
.where({ key: 'admin' })
.limit(1)) as { id: string; key: string };
await knex('permissions').insert(
getPermissionForRole(role.id, 'Config', [
'update',
])
);
}
export async function down(knex: Knex): Promise<void> {
await knex('permissions').where({ subject: 'Config' }).delete();
}

6
packages/backend/src/db/migrations/20230811142340_create_saml_auth_providers_role_mappings.ts → packages/backend/src/db/migrations/20230811142340_create_saml_auth_providers_role_mappings.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable(
'saml_auth_providers_role_mappings',
(table) => {
@@ -19,6 +17,6 @@ export async function up(knex: Knex): Promise<void> {
);
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('saml_auth_providers_role_mappings');
}

6
packages/backend/src/db/migrations/20230812132005_create_app_configs.ts → packages/backend/src/db/migrations/20230812132005_create_app_configs.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('app_configs', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.string('key').unique().notNullable();
@@ -12,6 +10,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('app_configs');
}

12
packages/backend/src/db/migrations/20230813172729_create_app_auth_clients.ts → packages/backend/src/db/migrations/20230813172729_create_app_auth_clients.js
View File

@@ -1,10 +1,12 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
return knex.schema.createTable('app_auth_clients', (table) => {
table.uuid('id').primary().defaultTo(knex.raw('gen_random_uuid()'));
table.string('name').unique().notNullable();
table.uuid('app_config_id').notNullable().references('id').inTable('app_configs');
table
.uuid('app_config_id')
.notNullable()
.references('id')
.inTable('app_configs');
table.text('auth_defaults').notNullable();
table.boolean('active').notNullable().defaultTo(false);
@@ -12,6 +14,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return knex.schema.dropTable('app_auth_clients');
}

14
packages/backend/src/db/migrations/20230815161102_add_app_auth_client_id_in_connections.js Normal file
View File

@@ -0,0 +1,14 @@
export async function up(knex) {
await knex.schema.table('connections', async (table) => {
table
.uuid('app_auth_client_id')
.references('id')
.inTable('app_auth_clients');
});
}
export async function down(knex) {
return await knex.schema.table('connections', (table) => {
table.dropColumn('app_auth_client_id');
});
}

13
packages/backend/src/db/migrations/20230815161102_add_app_auth_client_id_in_connections.ts
View File

@@ -1,13 +0,0 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
await knex.schema.table('connections', async (table) => {
table.uuid('app_auth_client_id').references('id').inTable('app_auth_clients');
});
}
export async function down(knex: Knex): Promise<void> {
return await knex.schema.table('connections', (table) => {
table.dropColumn('app_auth_client_id');
});
}

22
packages/backend/src/db/migrations/20230816121044_seed_update_app_permissions_to_admin.js Normal file
View File

@@ -0,0 +1,22 @@
const getPermissionForRole = (roleId, subject, actions) =>
actions.map((action) => ({
role_id: roleId,
subject,
action,
conditions: [],
}));
export async function up(knex) {
const role = await knex('roles')
.first(['id', 'key'])
.where({ key: 'admin' })
.limit(1);
await knex('permissions').insert(
getPermissionForRole(role.id, 'App', ['create', 'read', 'delete', 'update'])
);
}
export async function down(knex) {
await knex('permissions').where({ subject: 'App' }).delete();
}

33
packages/backend/src/db/migrations/20230816121044_seed_update_app_permissions_to_admin.ts
View File

@@ -1,33 +0,0 @@
import { Knex } from 'knex';
const getPermissionForRole = (
roleId: string,
subject: string,
actions: string[]
) =>
actions.map((action) => ({
role_id: roleId,
subject,
action,
conditions: [],
}));
export async function up(knex: Knex): Promise<void> {
const role = (await knex('roles')
.first(['id', 'key'])
.where({ key: 'admin' })
.limit(1)) as { id: string; key: string };
await knex('permissions').insert(
getPermissionForRole(role.id, 'App', [
'create',
'read',
'delete',
'update',
])
);
}
export async function down(knex: Knex): Promise<void> {
await knex('permissions').where({ subject: 'App' }).delete();
}

6
packages/backend/src/db/migrations/20230816173027_make_role_id_not_nullable_in_users.ts → packages/backend/src/db/migrations/20230816173027_make_role_id_not_nullable_in_users.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
const role = await knex('roles')
.select('id')
.whereIn('key', ['user', 'admin'])
@@ -18,7 +16,7 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
return await knex.schema.alterTable('users', (table) => {
table.uuid('role_id').nullable().alter();
});

6
packages/backend/src/db/migrations/20230824105813_soft_delete_soft_deleted_user_associations.ts → packages/backend/src/db/migrations/20230824105813_soft_delete_soft_deleted_user_associations.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
const users = await knex('users').whereNotNull('deleted_at');
const userIds = users.map((user) => user.id);
@@ -30,6 +28,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(): Promise<void> {
export async function down() {
// void
}

6
packages/backend/src/db/migrations/20230828134734_convert_permission_conditions_to_array.ts → packages/backend/src/db/migrations/20230828134734_convert_permission_conditions_to_array.js
View File

@@ -1,11 +1,9 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
await knex('permissions')
.where(knex.raw('conditions::text'), '=', knex.raw("'{}'::text"))
.update('conditions', JSON.stringify([]));
}
export async function down(): Promise<void> {
export async function down() {
// void
}

6
packages/backend/src/db/migrations/20231013094544_convert_user_emails_to_lowercase.ts → packages/backend/src/db/migrations/20231013094544_convert_user_emails_to_lowercase.js
View File

@@ -1,6 +1,4 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
await knex('users')
.whereRaw('email != LOWER(email)')
.update({
@@ -8,6 +6,6 @@ export async function up(knex: Knex): Promise<void> {
});
}
export async function down(): Promise<void> {
export async function down() {
// void
}

6
packages/backend/src/db/migrations/20231025101146_add_flow_id_index_in_executions.ts → packages/backend/src/db/migrations/20231025101146_add_flow_id_index_in_executions.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
await knex.schema.table('executions', (table) => {
table.index('flow_id');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
await knex.schema.table('executions', (table) => {
table.dropIndex('flow_id');
});

6
packages/backend/src/db/migrations/20231025101923_add_updated_at_index_in_executions.ts → packages/backend/src/db/migrations/20231025101923_add_updated_at_index_in_executions.js
View File

@@ -1,12 +1,10 @@
import { Knex } from 'knex';
export async function up(knex: Knex): Promise<void> {
export async function up(knex) {
await knex.schema.table('executions', (table) => {
table.index('updated_at');
});
}
export async function down(knex: Knex): Promise<void> {
export async function down(knex) {
await knex.schema.table('executions', (table) => {
table.dropIndex('updated_at');
});