Changeset 3870834 for database/drizzle

Timestamp:

12/29/25 02:25:26 (6 months ago)

Author:

Tome <gjorgievtome@…>

Branches:

main

Children:

b6e1b3c, dda6f51

Parents:

915ce0f

Message:

Add transanction to getBuildState

File:

• database/drizzle/queries/builds.ts (modified) (1 diff)

database/drizzle/queries/builds.ts

@@ -522 +522 @@
 
 export async function getBuildState(db: Database, userId: number, buildId: number) {
-    const [build] = await db
-        .select({
-            id: buildsTable.id,
-            userId: buildsTable.userId,
-            isApproved: buildsTable.isApproved,
-            name: buildsTable.name,
-            description: buildsTable.description,
-            totalPrice: buildsTable.totalPrice,
-        })
-        .from(buildsTable)
-        .where(
-            and(
-                eq(buildsTable.id, buildId),
-                eq(buildsTable.userId, userId)
-            )
-        )
-        .limit(1);
-
-    if (!build || build.isApproved) return null;
-
-    const components = await db
-        .select({ componentId: buildComponentsTable.componentId
-            })
-        .from(buildComponentsTable)
-        .where(
-            eq(buildComponentsTable.buildId, buildId)
-        );
-
-    return {
-        build,
-        componentIds: components.map(c => c.componentId)
-    };
-}
+    return db.transaction(async (tx) => {
+        const [build] = await tx
+            .select({
+                id: buildsTable.id,
+                userId: buildsTable.userId,
+                isApproved: buildsTable.isApproved,
+                name: buildsTable.name,
+                description: buildsTable.description,
+                totalPrice: buildsTable.totalPrice,
+            })
+            .from(buildsTable)
+            .where(
+                and(
+                    eq(buildsTable.id, buildId),
+                    eq(buildsTable.userId, userId)
+                )
+            )
+            .limit(1);
+
+        if (!build || build.isApproved) return null;
+
+        const components = await tx
+            .select({
+                componentId: buildComponentsTable.componentId
+            })
+            .from(buildComponentsTable)
+            .where(
+                eq(buildComponentsTable.buildId, buildId)
+            );
+
+        return {
+            build,
+            componentIds: components.map(c => c.componentId)
+        };
+    });
+}