Changeset 299af01 for src/app/api/customers/route.ts

Timestamp:

02/26/25 14:27:26 (6 weeks ago)

Author:

Naum Shapkarovski <naumshapkarovski@…>

Branches:

main

Children:

3c5302a

Parents:

057453c

Message:

chore

File:

• src/app/api/customers/route.ts (modified) (5 diffs)

src/app/api/customers/route.ts

@@ -4 +4 @@
 import { authenticateRequest } from 'src/lib/auth-middleware';
 import { CustomerStatus } from '@prisma/client';
+import { Prisma } from '@prisma/client';
 
 export async function GET(request: NextRequest) {
@@ -12 +13 @@
       return authResult;
     }
-    const { userId } = authResult;
+    const { userId, tenantId } = authResult;
 
     const searchParams = request.nextUrl.searchParams;
@@ -24 +25 @@
     const validatedFilters = customerTableFiltersSchema.parse(filters);
 
-    const customers = await prisma.client.findMany({
-      where: {
-        name: { contains: validatedFilters.name, mode: 'insensitive' },
-        status: validatedFilters.status
-          ? { equals: validatedFilters.status as CustomerStatus }
-          : undefined,
-      },
-    });
-    console.log('customers', customers);
+    // Replace Prisma query with raw SQL
+    const customers = await prisma.$queryRaw`
+      SELECT * FROM "Client"
+      WHERE "tenantId" = ${tenantId}
+        AND LOWER(name) LIKE LOWER(${`%${validatedFilters.name}%`})
+        ${
+          validatedFilters.status
+            ? Prisma.sql`AND status = ${validatedFilters.status}::"CustomerStatus"`
+            : Prisma.sql`AND TRUE`
+        }
+    `;
 
     return NextResponse.json(customers);
   } catch (error) {
+    console.error('Error fetching customers:', error);
     return NextResponse.json({ error: 'Internal Server Error' }, { status: 500 });
   }
@@ -47 +51 @@
       return authResult;
     }
-    const { userId } = authResult;
+    const { userId, tenantId } = authResult;
 
     const body = await request.json();
@@ -57 +61 @@
         ...validatedData,
         // userId,
+        tenantId,
       },
     });