Changeset ae5d054 for database/drizzle/queries

Timestamp:

12/28/25 20:12:33 (6 months ago)

Author:

Tome <gjorgievtome@…>

Branches:

main

Children:

8a7f936

Parents:

d69e088

Message:

Fix compatibility issues

Location:

database/drizzle/queries

Files:

• builds.ts (modified) (1 diff)
• components.ts (modified) (6 diffs)

database/drizzle/queries/builds.ts

@@ -511 +511 @@
             description
         })
-        .where(eq(buildsTable.id, buildId))
-        .returning({ id: buildsTable.id });
+        .where(
+            eq(buildsTable.id, buildId)
+        )
+        .returning({
+            id: buildsTable.id
+        });
 
     return updated?.id ?? null;

database/drizzle/queries/components.ts

@@ -278 +278 @@
     switch (componentType) {
         case 'cpu':
-            compatibleComponents = await getCompatibleCPUs(db, existing, limit, sortCondition);
+            compatibleComponents = await getCompatibleCPUs(db, existing, existingTDP, limit, sortCondition);
             break;
         case 'motherboard':
@@ -287 +287 @@
             break;
         case 'gpu':
-            compatibleComponents = await getCompatibleGPUs(db, existing, pciExpressSlotsUsed, limit, sortCondition);
+            compatibleComponents = await getCompatibleGPUs(db, existing, existingTDP, pciExpressSlotsUsed, limit, sortCondition);
             break;
         case 'memory':
@@ -317 +317 @@
 
 // Helper functions for checking component-specific compatibility
-async function getCompatibleCPUs(db: Database, existing: any, limit?: number, sortCondition?: any) {
+async function getCompatibleCPUs(db: Database, existing: any, existingTDP?: number, limit?: number, sortCondition?: any) {
     const conditions = [eq(componentsTable.type, 'cpu')];
 
@@ -362 +362 @@
         .limit(limit || 100);
 
+    let filteredCPUs = cpus;
+
     if (existing.cooler?.details?.cpuSockets) {
         const coolerSockets = existing.cooler.details.cpuSockets.map((s: any) => s.socket);
-        return cpus.filter(cpu => coolerSockets.includes(cpu.socket));
-    }
-
-    return cpus;
+        filteredCPUs = filteredCPUs.filter(cpu => coolerSockets.includes(cpu.socket));
+    }
+
+    if(existing.psu?.details?.wattage && existingTDP) {
+        const psuWattage = Number(existing.psu.details.wattage) || 0;
+
+        if (psuWattage > 0) {
+            const budget = psuWattage / 1.2;
+
+            const currentCpuTdp = Number(existing.cpu?.details?.tdp) || 0;
+            const baseWithoutCpu = existingTDP - currentCpuTdp;
+
+            filteredCPUs = filteredCPUs.filter(cpu => {
+                const cpuTdp = Number(cpu.tdp) || 0;
+                return (baseWithoutCpu + cpuTdp) <= budget;
+            });
+        }
+    }
+
+    return filteredCPUs;
 }
 
@@ -517 +535 @@
 }
 
-async function getCompatibleGPUs(db: Database, existing: any, pciExpressSlotsUsed: number, limit?: number, sortCondition?: any) {
+async function getCompatibleGPUs(db: Database, existing: any, existingTDP: number, pciExpressSlotsUsed: number, limit?: number, sortCondition?: any) {
     const conditions = [eq(componentsTable.type, 'gpu')];
 
@@ -556 +574 @@
         .limit(limit || 100);
 
+    let filteredGPUs = gpus;
+
     if (existing.motherboard) {
         const availableSlots = Number(existing.motherboard.details.pciExpressSlots);
-        return gpus.filter(() => (pciExpressSlotsUsed + 1) <= availableSlots);
-    }
-
-    return gpus;
+        filteredGPUs = gpus.filter(() => (pciExpressSlotsUsed + 1) <= availableSlots);
+    }
+
+    if(existing.psu?.details?.wattage && existingTDP) {
+        const psuWattage = Number(existing.psu.details.wattage) || 0;
+
+        if (psuWattage > 0) {
+            const budget = psuWattage / 1.2;
+
+            const currentGpuTdp = Number(existing.cpu?.details?.tdp) || 0;
+            const baseWithoutGpu = existingTDP - currentGpuTdp;
+
+            filteredGPUs = filteredGPUs.filter(cpu => {
+                const gpuTdp = Number(cpu.tdp) || 0;
+                return (baseWithoutGpu + gpuTdp) <= budget;
+            });
+        }
+    }
+
+    return filteredGPUs;
 }