awatertrevi/infisical
1
0
Fork 0
mirror of https://github.com/awatertrevi/infisical.git synced 2026-10-04 15:26:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix migration

Browse Source
This commit is contained in:
Carlos Monastyrski
2025-07-24 12:07:01 -03:00
parent 0d97bb4c8c
commit b05ea8a69a
1 changed files with 26 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/db/migrations/20250722152841_add-policies-environments-table.ts
+26 -26
View File
@@ -16,6 +16,19 @@ export async function up(knex: Knex): Promise<void> {
t.timestamps(true, true, true); t.timestamps(true, true, true);
t.unique(["policyId", "envId"]); t.unique(["policyId", "envId"]);
}); });
const existingAccessApprovalPolicies = await knex(TableName.AccessApprovalPolicy)
.select(selectAllTableCols(TableName.AccessApprovalPolicy))
.whereNotNull(`${TableName.AccessApprovalPolicy}.envId`);
const accessApprovalPolicies = existingAccessApprovalPolicies.map(async (policy) => {
await knex(TableName.AccessApprovalPolicyEnvironment).insert({
policyId: policy.id,
envId: policy.envId
});
});
await Promise.all(accessApprovalPolicies);
} }
if (!(await knex.schema.hasTable(TableName.SecretApprovalPolicyEnvironment))) { if (!(await knex.schema.hasTable(TableName.SecretApprovalPolicyEnvironment))) {
await knex.schema.createTable(TableName.SecretApprovalPolicyEnvironment, (t) => { await knex.schema.createTable(TableName.SecretApprovalPolicyEnvironment, (t) => {
@@ -27,6 +40,19 @@ export async function up(knex: Knex): Promise<void> {
t.timestamps(true, true, true); t.timestamps(true, true, true);
t.unique(["policyId", "envId"]); t.unique(["policyId", "envId"]);
}); });
const existingSecretApprovalPolicies = await knex(TableName.SecretApprovalPolicy)
.select(selectAllTableCols(TableName.SecretApprovalPolicy))
.whereNotNull(`${TableName.SecretApprovalPolicy}.envId`);
const secretApprovalPolicies = existingSecretApprovalPolicies.map(async (policy) => {
await knex(TableName.SecretApprovalPolicyEnvironment).insert({
policyId: policy.id,
envId: policy.envId
});
});
await Promise.all(secretApprovalPolicies);
} }
await knex.schema.alterTable(TableName.AccessApprovalPolicy, (t) => { await knex.schema.alterTable(TableName.AccessApprovalPolicy, (t) => {
@@ -45,32 +71,6 @@ export async function up(knex: Knex): Promise<void> {
await createOnUpdateTrigger(knex, TableName.AccessApprovalPolicyEnvironment); await createOnUpdateTrigger(knex, TableName.AccessApprovalPolicyEnvironment);
await createOnUpdateTrigger(knex, TableName.SecretApprovalPolicyEnvironment); await createOnUpdateTrigger(knex, TableName.SecretApprovalPolicyEnvironment);
const existingAccessApprovalPolicies = await knex(TableName.AccessApprovalPolicy)
.select(selectAllTableCols(TableName.AccessApprovalPolicy))
.whereNotNull(`${TableName.AccessApprovalPolicy}.envId`);
const accessApprovalPolicies = existingAccessApprovalPolicies.map(async (policy) => {
await knex(TableName.AccessApprovalPolicyEnvironment).insert({
policyId: policy.id,
envId: policy.envId
});
});
await Promise.all(accessApprovalPolicies);
const existingSecretApprovalPolicies = await knex(TableName.SecretApprovalPolicy)
.select(selectAllTableCols(TableName.SecretApprovalPolicy))
.whereNotNull(`${TableName.SecretApprovalPolicy}.envId`);
const secretApprovalPolicies = existingSecretApprovalPolicies.map(async (policy) => {
await knex(TableName.SecretApprovalPolicyEnvironment).insert({
policyId: policy.id,
envId: policy.envId
});
});
await Promise.all(secretApprovalPolicies);
} }
export async function down(knex: Knex): Promise<void> { export async function down(knex: Knex): Promise<void> {