fix: Implement 5-minute re-validation window and Flow Sync Logging

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

@@ -269,13 +269,38 @@ export class WhatsAppLogic {
                 }
             }
 
+            // 🚨 FLOW-SYNC: Identify current pedagogical state
+            const userProgress = await prisma.userProgress.findUnique({
+                where: { userId_trackId: { userId: user.id, trackId: activeEnrollment.trackId } }
+            });
+
+            console.log(`[FLOW-SYNC] User ${user.id} at Day ${activeEnrollment.currentDay}, status: ${userProgress?.exerciseStatus}`);
+
+            const fiveMinutesAgo = new Date(Date.now() - 5 * 60 * 1000);
+            const isRecentlyCompleted = userProgress?.exerciseStatus === 'COMPLETED' && userProgress.updatedAt > fiveMinutesAgo;
+            const shouldForceRevalidation = !!imageUrl || isRecentlyCompleted;
+
+            if (shouldForceRevalidation && userProgress?.exerciseStatus === 'COMPLETED') {
+                console.log(`[FLOW-SYNC] 🔄 Re-validation triggered for User ${user.id} (Reason: ${imageUrl ? 'New Image' : 'Recent Correction'})`);
+                // Briefly reset to PENDING to allow the analysis block below to pick it up
+                await prisma.userProgress.update({
+                    where: { id: userProgress.id },
+                    data: { exerciseStatus: 'PENDING' }
+                });
+            }
+
             const pendingProgress = await prisma.userProgress.findFirst({
-                where: { userId: user.id, exerciseStatus: { in: ['PENDING', 'PENDING_REMEDIATION', 'PENDING_DEEPDIVE'] }, trackId: activeEnrollment.trackId },
+                where: { 
+                    userId: user.id, 
+                    exerciseStatus: { in: ['PENDING', 'PENDING_REMEDIATION', 'PENDING_DEEPDIVE'] }, 
+                    trackId: activeEnrollment.trackId 
+                },
             });
 
             if (pendingProgress) {
                 const trackDay = await prisma.trackDay.findFirst({ where: { trackId: activeEnrollment.trackId, dayNumber: activeEnrollment.currentDay } });
                 if (trackDay) {
+                    console.log(`[FLOW-SYNC] 🧠 User ${user.id} is at Day ${activeEnrollment.currentDay}, processing response for Day ${activeEnrollment.currentDay}.`);
                     const isDeepDiveAction = pendingProgress.exerciseStatus === 'PENDING_DEEPDIVE';
                     const wordCount = (text || '').trim().split(/\s+/).length;
                     if (wordCount < 3) {

tasks/lessons.md

@@ -13,6 +13,7 @@ Ce fichier archive les échecs et solutions liées à la **stabilité technique*
 - **[QUEUES] Payload Sync** : S'assurer que les noms de champs dans `whatsappQueue.add` (producteur) matchent exactement le destructuring dans le worker (consommateur). Préférer `currentDay` partout pour la consistance.
 - **[DB] Enrollment ID** : Toujours passer l'ID d'inscription (`enrollmentId`) au job de feedback pour permettre la persistance des réponses sans crash Prisma.
 - **[JSON] Null Safety & Expansion** : Toujours vérifier la présence de données (Null Safety) lors de l'extension des schémas JSON, sous peine de briser le pipeline des jours précédents (Utiliser des guards `currentDay >= X`).
+- **[FLOW] Re-validation Window** : Ne jamais bloquer une analyse entrante sous prétexte que le statut est COMPLETED si le délai depuis la dernière validation est inférieur à 5 minutes (cas de correction immédiate par l'utilisateur) ou si un nouvel élément multimédia est présent.
 - **[UX] Guidance Post-Validation** : Si un utilisateur envoie un message alors qu'il est en statut `COMPLETED`, le système ne doit pas rester muet. Il doit lui renvoyer un message de navigation (ex: "Tape SUITE pour continuer").
 
 ## 🛡️ Règle d'Or de l'Intégrité