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

Add transaction support

Browse Source
This commit is contained in:
Daniel Hougaard
2024-02-22 05:00:25 +01:00
parent 4aa5822ae2
commit ec3cf0208c
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/services/project/project-dal.ts
+4 -2
View File
@@ -1,3 +1,5 @@
import { Knex } from "knex";
import { TDbClient } from "@app/db"; import { TDbClient } from "@app/db";
import { ProjectsSchema, ProjectUpgradeStatus, TableName, TProjectsUpdate } from "@app/db/schemas"; import { ProjectsSchema, ProjectUpgradeStatus, TableName, TProjectsUpdate } from "@app/db/schemas";
import { DatabaseError } from "@app/lib/errors"; import { DatabaseError } from "@app/lib/errors";
@@ -66,13 +68,13 @@ export const projectDALFactory = (db: TDbClient) => {
} }
}; };
const setProjectUpgradeStatus = async (projectId: string, status: ProjectUpgradeStatus) => { const setProjectUpgradeStatus = async (projectId: string, status: ProjectUpgradeStatus | null, tx?: Knex) => {
try { try {
const data: TProjectsUpdate = { const data: TProjectsUpdate = {
upgradeStatus: status upgradeStatus: status
} as const; } as const;
await db(TableName.Project).where({ id: projectId }).update(data); await (tx || db)(TableName.Project).where({ id: projectId }).update(data);
} catch (error) { } catch (error) {
throw new DatabaseError({ error, name: "Set project upgrade status" }); throw new DatabaseError({ error, name: "Set project upgrade status" });
} }