Changes in / [67186d2:107303c]

Files:

• database/drizzle/queries/builds.ts (modified) (1 diff)
• pages/+Layout.telefunc.ts (modified) (2 diffs)

database/drizzle/queries/builds.ts

@@ -495 +495 @@
 }
 
-export async function addNewBuild(db: Database, userId: number, name: string, description: string) {
-    const [newBuild] = await db
-        .insert(buildsTable)
-        .values({
-            userId: userId,
-            name: name,
-            createdAt: new Date().toISOString().split('T')[0],
-            description: description,
-            totalPrice: Number(0).toFixed(2),
-            isApproved: false
-        })
-        .returning({
-            id: buildsTable.id
-        });
-
-    return newBuild?.id ?? null;
+export async function addNewBuild(db: Database, userId: number, name: string, description: string, componentIds: number[]) {
+    return db.transaction(async (tx) => {
+        const components = await tx
+            .select({
+                price:  componentsTable.price
+            })
+            .from(componentsTable)
+            .where(
+                inArray(componentsTable.id, componentIds)
+            );
+
+        const totalPrice = components.reduce((sum, c) => sum + Number(c.price), 0);
+
+        const [newBuild] = await tx
+            .insert(buildsTable)
+            .values({
+                userId: userId,
+                name: name,
+                createdAt: new Date().toISOString().split('T')[0],
+                description: description,
+                totalPrice: totalPrice.toFixed(2),
+                isApproved: false
+            })
+            .returning({
+                id: buildsTable.id
+            });
+
+        if(components.length) {
+            await tx.insert(buildComponentsTable)
+                .values(
+                    componentIds.map(componentId => ({
+                        buildId: newBuild.id,
+                        componentId: componentId
+                    }))
+                );
+        }
+
+        return newBuild?.id ?? null;
+    });
 }
 

pages/+Layout.telefunc.ts

@@ -3 +3 @@
 import {Abort} from "telefunc";
 import type {Database} from "../database/drizzle/db";
-import {addNewBuild} from "../database/drizzle/queries";
 
 export async function onGetAuthState() {
@@ -114 +113 @@
     return newBuild;
 }
-
-export async function onAddNewBuild({ name, description }
-                                          : { name: string; description: string }) {
-    const { c, userId } = requireUser()
-
-    const newBuildId = await drizzleQueries.addNewBuild(c.db, userId, name, description);
-
-    if (!newBuildId) throw Abort();
-
-    return { buildId: newBuildId };
-}