Fix: Add Garbage Collector (GC) for media and temp files

apps/api/package.json

@@ -25,6 +25,7 @@
         "fastify": "^4.0.0",
         "fastify-plugin": "^4.5.1",
         "ioredis": "^5.9.3",
+        "node-cron": "^4.2.1",
         "openai": "^4.0.0",
         "pptxgenjs": "^3.12.0",
         "puppeteer": "^22.0.0",
@@ -37,6 +38,7 @@
         "@types/dotenv": "^8.2.3",
         "@types/fast-levenshtein": "^0.0.4",
         "@types/node": "^20.0.0",
+        "@types/node-cron": "^3.0.11",
         "@vitest/ui": "^4.0.18",
         "tsx": "^3.0.0",
         "typescript": "^5.0.0",

apps/api/src/index.ts

@@ -10,6 +10,7 @@ import { aiRoutes } from './routes/ai';
 import { paymentRoutes, stripeWebhookRoute } from './routes/payments';
 import { internalRoutes } from './routes/internal';
 import { studentRoutes } from './routes/student';
+import { startCleanupCron } from './services/cleanup';
 
 // ── Fail-fast: vérifier les secrets critiques au démarrage ─────────────────────
 // Only WHATSAPP_VERIFY_TOKEN is strictly needed at startup (for Meta webhook validation).
@@ -203,6 +204,7 @@ server.get('/v1/privacy', async (_req, reply) => {
 const start = async () => {
     try {
         await setupRateLimit();
+        startCleanupCron();
         const port = parseInt(process.env.PORT || '8080');
         const isGateway = process.env.IS_GATEWAY === 'true' || process.env.HF_SPACE_ID !== undefined;
         logger.info(`[STARTUP] Mode: ${isGateway ? 'GATEWAY (Forwarding Only)' : 'DIRECT (Processing)'}`);

apps/api/src/services/cleanup.ts

@@ -0,0 +1,62 @@
+import { logger } from '../logger';
+import fs from 'fs/promises';
+import path from 'path';
+import cron from 'node-cron';
+
+/**
+ * Cleanup Service
+ * 
+ * Scans /tmp for old media files and deletes them to prevent disk saturation.
+ */
+export async function cleanTempFiles(maxAgeMs: number = 2 * 60 * 60 * 1000) {
+    const tempDir = '/tmp';
+    const now = Date.now();
+
+    try {
+        const folders = ['', 'audio', 'images', 'documents'];
+        
+        for (const folder of folders) {
+            const dirPath = path.join(tempDir, folder);
+            
+            // Check if directory exists
+            try {
+                await fs.access(dirPath);
+            } catch {
+                continue; 
+            }
+
+            const files = await fs.readdir(dirPath);
+            
+            for (const file of files) {
+                const filePath = path.join(dirPath, file);
+                
+                // Skip directories
+                const stats = await fs.stat(filePath);
+                if (stats.isDirectory()) continue;
+
+                // Check age
+                const age = now - stats.mtimeMs;
+                if (age > maxAgeMs) {
+                    await fs.unlink(filePath);
+                    logger.info(`[CLEANUP] Deleted old temp file: ${filePath} (${Math.round(age / 60000)} min old)`);
+                }
+            }
+        }
+    } catch (err: unknown) {
+        logger.error(`[CLEANUP] Error during temp file cleanup:`, (err instanceof Error ? err.message : String(err)));
+    }
+}
+
+/**
+ * Starts a cron job that runs every hour to clean up /tmp.
+ */
+export function startCleanupCron() {
+    // Run every hour at minute 0
+    cron.schedule('0 * * * *', () => {
+        logger.info('[CLEANUP] 🧹 Starting scheduled temp file cleanup...');
+        cleanTempFiles();
+    });
+    
+    // Also run once at startup
+    cleanTempFiles();
+}

apps/whatsapp-worker/src/index.ts

@@ -11,11 +11,13 @@ import { updateBehavioralScore } from './scoring';
 import { normalizeWolof } from './normalizeWolof';
 import { getApiUrl, getAdminApiKey, validateEnvironment, isFeatureEnabled } from './config';
 import { WhatsAppLogic } from './services/whatsapp-logic';
+import { startWorkerCleanupCron } from './services/cleanup';
 
 dotenv.config();
 
 // 🚀 CRITICAL: Validate environment variables at boot
 validateEnvironment();
+startWorkerCleanupCron();
 
 const prisma = new PrismaClient();
 
@@ -175,11 +177,11 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
                 // 🌟 Adaptive Pedagogy: Dynamic Remediation & Diagnostic Logic v1.1 🌟
                 // 🚨 RACE CONDITION FIX: Update UserProgress strictly BEFORE sending the message over WhatsApp.
                 let nextDay = currentDay + 1;
-                const currentProgress = await prisma.userProgress.findUnique({
+                const currentProgress = await (prisma as any).userProgress.findUnique({
                     where: { userId_trackId: { userId, trackId } },
                     include: { userBadges: true }
                 });
-                const currentBadges = currentProgress?.userBadges.map(b => b.name) || [];
+                const currentBadges = (currentProgress?.userBadges || []).map((b: any) => b.name);
                 let updatedBadges = [...currentBadges];
 
                 if (feedbackData?.isQualified === false) {
@@ -263,7 +265,7 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
                     if (!isTimeTravelMode) {
                         const newBadges = updatedBadges.filter(b => !currentBadges.includes(b));
                         
-                        await prisma.userProgress.update({
+                        await (prisma as any).userProgress.update({
                             where: { userId_trackId: { userId, trackId } },
                             data: {
                                 exerciseStatus: newStatus,
@@ -294,7 +296,7 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
                             // Let's do a clean replacement for the SQL relation to stay consistent with the JSON "replace" logic.
                             const profile = await prisma.businessProfile.findUnique({ where: { userId } });
                             if (profile) {
-                                await prisma.teamMember.deleteMany({ where: { businessProfileId: profile.id } });
+                                await (prisma as any).teamMember.deleteMany({ where: { businessProfileId: profile.id } });
                                 updatePayload.teamMembersList = {
                                     create: newMembers.map((m: any) => ({
                                         name: m.name || m.fullName || 'Unknown',

apps/whatsapp-worker/src/services/cleanup.ts

@@ -0,0 +1,55 @@
+import { logger } from '../logger';
+import fs from 'fs/promises';
+import path from 'path';
+import cron from 'node-cron';
+
+/**
+ * Worker Cleanup Service
+ * 
+ * Safety guard to purge any temporary files in /tmp on the worker instance.
+ */
+export async function cleanWorkerTempFiles(maxAgeMs: number = 2 * 60 * 60 * 1000) {
+    const tempDir = '/tmp';
+    const now = Date.now();
+
+    try {
+        const folders = ['', 'audio', 'images', 'documents'];
+        
+        for (const folder of folders) {
+            const dirPath = path.join(tempDir, folder);
+            
+            try {
+                await fs.access(dirPath);
+            } catch {
+                continue; 
+            }
+
+            const files = await fs.readdir(dirPath);
+            
+            for (const file of files) {
+                const filePath = path.join(dirPath, file);
+                const stats = await fs.stat(filePath);
+                if (stats.isDirectory()) continue;
+
+                const age = now - stats.mtimeMs;
+                if (age > maxAgeMs) {
+                    await fs.unlink(filePath);
+                    logger.info(`[CLEANUP-WORKER] Deleted old file: ${filePath} (${Math.round(age / 60000)} min old)`);
+                }
+            }
+        }
+    } catch (err: unknown) {
+        logger.error(`[CLEANUP-WORKER] Error:`, (err instanceof Error ? err.message : String(err)));
+    }
+}
+
+export function startWorkerCleanupCron() {
+    // Run every hour
+    cron.schedule('0 * * * *', () => {
+        logger.info('[CLEANUP-WORKER] 🧹 Starting cleanup...');
+        cleanWorkerTempFiles();
+    });
+    
+    // Initial run
+    cleanWorkerTempFiles();
+}

pnpm-lock.yaml

@@ -118,6 +118,9 @@ importers:
       ioredis:
         specifier: ^5.9.3
         version: 5.9.3
+      node-cron:
+        specifier: ^4.2.1
+        version: 4.2.1
       openai:
         specifier: ^4.0.0
         version: 4.104.0(ws@8.19.0)(zod@3.25.76)
@@ -149,6 +152,9 @@ importers:
       '@types/node':
         specifier: ^20.0.0
         version: 20.19.33
+      '@types/node-cron':
+        specifier: ^3.0.11
+        version: 3.0.11
       '@vitest/ui':
         specifier: ^4.0.18
         version: 4.0.18(vitest@4.0.18)