adding new version

Author: agairola

app/prisma.ts

@@ -5,7 +5,15 @@ import { PrismaClient } from '@/generated/prisma';
 //
 // Learn more: https://pris.ly/d/help/next-js-best-practices
 
-const prisma = global.prisma || new PrismaClient();
+const prisma = global.prisma || new PrismaClient({
+  // Use Prisma Accelerate for connection pooling
+  datasourceUrl: process.env.PRISMA_DATABASE_URL || process.env.DATABASE_URL,
+  // Optimize for serverless environments
+  ...(process.env.NODE_ENV === 'production' && {
+    log: ['error'],
+    errorFormat: 'minimal',
+  })
+});
 
 if (process.env.NODE_ENV !== 'production') global.prisma = prisma;
 

generated/prisma/edge.js

@@ -30,8 +30,8 @@ interface SecurityEvent {
 class OptimizedAnalyticsCollector {
   private requestBatch: RequestAnalytics[] = [];
   private securityBatch: SecurityEvent[] = [];
-  private readonly BATCH_SIZE = 50; // Batch writes for performance
-  private readonly FLUSH_INTERVAL = 30000; // 30 seconds
+  private readonly BATCH_SIZE = 100; // Larger batches for better efficiency
+  private readonly FLUSH_INTERVAL = 15000; // 15 seconds - faster flushing
   private flushTimer: NodeJS.Timeout | null = null;
 
   constructor() {
@@ -69,36 +69,41 @@ class OptimizedAnalyticsCollector {
     }
   }
 
-  // Optimized database write with batching
+  // Optimized database write with batching and connection management
   private async flushRequests() {
     if (this.requestBatch.length === 0) return;
 
     const batch = [...this.requestBatch];
     this.requestBatch = [];
 
     try {
-      await prisma.analyticsRequest.createMany({
-        data: batch.map(req => ({
-          timestamp: req.timestamp,
-          endpoint: req.endpoint,
-          method: req.method,
-          statusCode: req.statusCode,
-          responseTime: req.responseTime,
-          clientId: req.clientId,
-          userId: req.userId,
-          ipAddress: req.ipAddress,
-          userAgent: req.userAgent,
-          country: req.country,
-          city: req.city,
-          clientType: req.clientType,
-          platform: req.platform
-        })),
-        skipDuplicates: true // Prevent errors on duplicate inserts
+      // Use transaction for better connection management
+      await prisma.$transaction(async (tx) => {
+        await tx.analyticsRequest.createMany({
+          data: batch.map(req => ({
+            timestamp: req.timestamp,
+            endpoint: req.endpoint,
+            method: req.method,
+            statusCode: req.statusCode,
+            responseTime: req.responseTime,
+            clientId: req.clientId,
+            userId: req.userId,
+            ipAddress: req.ipAddress,
+            userAgent: req.userAgent,
+            country: req.country,
+            city: req.city,
+            clientType: req.clientType,
+            platform: req.platform
+          })),
+          skipDuplicates: true
+        });
       });
     } catch (error) {
       console.error('Failed to flush analytics requests:', error);
-      // Re-add failed batch to retry later
-      this.requestBatch.unshift(...batch);
+      // Re-add failed batch to retry later (with limit to prevent infinite growth)
+      if (this.requestBatch.length < this.BATCH_SIZE * 2) {
+        this.requestBatch.unshift(...batch);
+      }
     }
   }