Merge pull request #233 from Plant-for-the-Planet-org/feature/add-indexes

Feature/add indexes

Author: rupamkairi

apps/server/prisma/migrations/20250821055439_add_indexes/migration.sql

@@ -0,0 +1,11 @@
+-- CreateIndex
+CREATE INDEX "AlertMethod_userId_idx" ON "AlertMethod"("userId");
+
+-- CreateIndex
+CREATE INDEX "Site_userId_idx" ON "Site"("userId");
+
+-- CreateIndex
+CREATE INDEX "Site_detectionGeometry_idx" ON "Site" USING GIST ("detectionGeometry");
+
+-- CreateIndex
+CREATE INDEX "SiteAlert_isProcessed_eventDate_idx" ON "SiteAlert"("isProcessed", "eventDate");

apps/server/prisma/schema.prisma

@@ -60,6 +60,7 @@ model AlertMethod {
     verificationRequest VerificationRequest?
 
     @@unique([destination, userId, method])
+    @@index([userId])
 }
 
 model Site {
@@ -85,6 +86,9 @@ model Site {
     project            Project?                 @relation(fields: [projectId], references: [id])
     user               User?                    @relation(fields: [userId], references: [id], onDelete: Cascade)
     siteRelations      SiteRelation[]
+
+    @@index([userId])
+    @@index([detectionGeometry], type: Gist)
 }
 
 model Project {
@@ -141,6 +145,8 @@ model SiteAlert {
     data          Json?
     notifications Notification[]
     site          Site            @relation(fields: [siteId], references: [id], onDelete: Cascade)
+
+    @@index([isProcessed, eventDate])
 }
 
 model Notification {

apps/server/src/env.mjs

@@ -60,9 +60,14 @@ const server = z.object({
   ALERT_SMS_DISABLED: coerceBooleanWithDefault(true),
   ALERT_WHATSAPP_DISABLED: coerceBooleanWithDefault(true),
 
+
+  // Database slow query logging. Disabled by default.
+  DATABASE_LOG_SLOWQUERY: coerceBooleanWithDefault(false),
+
   // Notification batch size for processing notifications in batches. Defaults to 10.
   NOTIFICATION_BATCH_SIZE: z.string().default('10'),
 
+
   // API caching configuration. Enabled by default in production, disabled in development.
   PUBLIC_API_CACHING: z
     .union([z.literal('true'), z.literal('false')])
@@ -118,6 +123,7 @@ const processEnv = {
   WHATSAPP_ENDPOINT_AUTH_TOKEN: process.env.WHATSAPP_ENDPOINT_AUTH_TOKEN,
   ALERT_SMS_DISABLED: process.env.ALERT_SMS_DISABLED,
   ALERT_WHATSAPP_DISABLED: process.env.ALERT_WHATSAPP_DISABLED,
+  DATABASE_LOG_SLOWQUERY: process.env.DATABASE_LOG_SLOWQUERY,
   PUBLIC_API_CACHING: process.env.PUBLIC_API_CACHING,
   NOTIFICATION_BATCH_SIZE: process.env.NOTIFICATION_BATCH_SIZE,
 };

apps/server/src/server/db.ts

@@ -1,6 +1,7 @@
 import {PrismaClient} from '@prisma/client';
 
 import {env} from '../env.mjs';
+import {logger} from './logger';
 
 const globalForPrisma = globalThis as unknown as {prisma: PrismaClient};
 
@@ -10,6 +11,23 @@ export const prisma =
     log: env.NODE_ENV === 'development' ? ['error'] : ['error'],
   });
 
+// Add performance monitoring middleware (only if enabled via environment variable)
+if (env.DATABASE_LOG_SLOWQUERY) {
+  prisma.$use(async (params, next) => {
+    const start = Date.now();
+    const result = await next(params);
+    const duration = Date.now() - start;
+    
+    // Log queries that take longer than 1000ms
+    if (duration > 1000) {
+      const logMessage = `Slow query detected - Model: ${params.model}, Action: ${params.action}, Duration: ${duration}ms`;
+      logger(logMessage, 'warn');
+    }
+    
+    return result;
+  });
+}
+
 if (env.NODE_ENV !== 'production') {
   globalForPrisma.prisma = prisma;
 }