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

requested changes

Browse Source
This commit is contained in:
Daniel Hougaard
2025-04-23 21:40:01 +04:00
parent 6e65656360
commit 9ea6eca560
2 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/db/migrations/20250419004044_secret-reminder-recipients.ts
-4
View File
@@ -1,7 +1,6 @@
import { Knex } from "knex"; import { Knex } from "knex";
import { TableName } from "../schemas"; import { TableName } from "../schemas";
import { createOnUpdateTrigger, dropOnUpdateTrigger } from "../utils";
export async function up(knex: Knex): Promise<void> { export async function up(knex: Knex): Promise<void> {
const hasSecretReminderRecipientsTable = await knex.schema.hasTable(TableName.SecretReminderRecipients); const hasSecretReminderRecipientsTable = await knex.schema.hasTable(TableName.SecretReminderRecipients);
@@ -23,8 +22,6 @@ export async function up(knex: Knex): Promise<void> {
table.index("secretId"); table.index("secretId");
table.unique(["secretId", "userId"]); table.unique(["secretId", "userId"]);
}); });
await createOnUpdateTrigger(knex, TableName.SecretReminderRecipients);
} }
} }
@@ -33,6 +30,5 @@ export async function down(knex: Knex): Promise<void> {
if (hasSecretReminderRecipientsTable) { if (hasSecretReminderRecipientsTable) {
await knex.schema.dropTableIfExists(TableName.SecretReminderRecipients); await knex.schema.dropTableIfExists(TableName.SecretReminderRecipients);
await dropOnUpdateTrigger(knex, TableName.SecretReminderRecipients);
} }
} }
backend/src/services/secret/secret-queue.ts
+1 -1
View File
@@ -259,7 +259,7 @@ export const secretQueueFactory = ({
}); });
} }
if (recipients) { if (recipients?.length) {
await secretReminderRecipientsDAL.transaction(async (tx) => { await secretReminderRecipientsDAL.transaction(async (tx) => {
await secretReminderRecipientsDAL.delete({ secretId: newSecret.id }, tx); await secretReminderRecipientsDAL.delete({ secretId: newSecret.id }, tx);
await secretReminderRecipientsDAL.insertMany( await secretReminderRecipientsDAL.insertMany(