fix: batch scheduler updates, typed JWT user, log catch blocks, move script

- scheduler.ts: collect completed enrollment IDs in loop, single updateMany
after — eliminates N queries per day for completions
- ContentHandler.ts: log Redis cache failures instead of swallowing silently
- index.ts: remove (request as any).user cast — now safe via FastifyJWT
augmentation in types/fastify.d.ts
- types/fastify.d.ts: augment @fastify/jwt FastifyJWT interface so request.user
resolves to {id, role, organizationId} after jwtVerify(), not string|object|Buffer
- delete-user.ts: moved from apps/api root to apps/api/scripts/

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

apps/api/src/index.ts

@@ -80,7 +80,7 @@ const registerRoutes = async () => {
             }
 
             // Multi-Tenant Enforcement
-            const user = request.user as any;
+            const user = request.user;
             const requestedOrgId = request.headers['x-organization-id'] as string;
 
             if (user && user.role !== 'SUPER_ADMIN') {

apps/api/src/types/fastify.d.ts

@@ -1,15 +1,20 @@
 import { PrismaClient } from '@repo/database';
+import '@fastify/multipart';
+
+// Tell @fastify/jwt what shape our JWT payload has.
+// This makes request.user properly typed after jwtVerify().
+declare module '@fastify/jwt' {
+  interface FastifyJWT {
+    payload: { id: string; role: string; organizationId: string };
+    user: { id: string; role: string; organizationId: string };
+  }
+}
 
 declare module 'fastify' {
   interface FastifyInstance {
     prisma: PrismaClient;
   }
   interface FastifyRequest {
-    user: {
-      id: string;
-      role: string;
-      organizationId: string;
-    };
     organizationId?: string;
     rawBody?: Buffer;
   }

apps/whatsapp-worker/src/handlers/ContentHandler.ts

@@ -17,7 +17,9 @@ export class ContentHandler implements JobHandler {
         try {
             const cached = await connection.get(cacheKey);
             if (cached) return JSON.parse(cached);
-        } catch (err) {}
+        } catch (err) {
+            logger.warn({ err, organizationId }, '[ContentHandler] Redis cache lookup failed');
+        }
 
         const org = await prisma.organization.findUnique({
             where: { id: organizationId },

apps/whatsapp-worker/src/scheduler.ts

@@ -41,13 +41,14 @@ export function startDailyScheduler() {
                 }
             });
 
+            const completedIds: string[] = [];
+
             for (const enrollment of activeEnrollments) {
-                // Find progress for this specific track
+                // Find progress for this specific track (in-memory, no extra query)
                 const progress = enrollment.user.progress.find(p => p.trackId === enrollment.trackId);
 
                 if (progress?.exerciseStatus === 'PENDING') {
-                    const lastInteraction = progress.lastInteraction;
-                    const hoursSinceLast = (Date.now() - new Date(lastInteraction).getTime()) / (1000 * 60 * 60);
+                    const hoursSinceLast = (Date.now() - new Date(progress.lastInteraction).getTime()) / (1000 * 60 * 60);
 
                     if (hoursSinceLast >= 72) {
                         logger.info(`[SCHEDULER] Queuing RESURRECTION nudge for User ${enrollment.userId}`);
@@ -60,21 +61,15 @@ export function startDailyScheduler() {
                 }
 
                 const nextDay = enrollment.currentDay + 1;
-
-                // ── Check the next day content exists in memory ──────────────────────────
                 const nextDayContent = enrollment.track.days.find(d => d.dayNumber === nextDay);
 
                 if (!nextDayContent) {
-                    // No more content → mark enrollment COMPLETED
+                    // Collect for batch update instead of N individual queries
                     logger.info(`[SCHEDULER] No Day ${nextDay} for Track ${enrollment.trackId} — marking COMPLETED`);
-                    await prisma.enrollment.update({
-                        where: { id: enrollment.id },
-                        data: { status: 'COMPLETED', completedAt: new Date() }
-                    });
+                    completedIds.push(enrollment.id);
                     continue;
                 }
 
-                // ── Queue the next lesson ─────────────────────────────────────
                 await whatsappQueue.add('send-content', {
                     userId: enrollment.userId,
                     trackId: enrollment.trackId,
@@ -83,6 +78,15 @@ export function startDailyScheduler() {
 
                 logger.info(`[SCHEDULER] Queued Day ${nextDay} for User ${enrollment.userId}`);
             }
+
+            // Single batch update instead of one query per completed enrollment
+            if (completedIds.length > 0) {
+                await prisma.enrollment.updateMany({
+                    where: { id: { in: completedIds } },
+                    data: { status: 'COMPLETED', completedAt: new Date() }
+                });
+                logger.info(`[SCHEDULER] Marked ${completedIds.length} enrollment(s) as COMPLETED`);
+            }
         } catch (error) {
             logger.error('[SCHEDULER] Error:', error);
         }