fix: re-validate COMPLETED→PENDING for text exercise responses + guard businessProfile.upsert at Day 10+

apps/api/src/services/whatsapp.ts

@@ -459,6 +459,23 @@ export class WhatsAppService {
                 return;
             }
 
+            // 🚨 TEXT RE-VALIDATION: Mirror the Worker-side `shouldForceRevalidation` logic.
+            // Image/Audio flows reset PENDING via WhatsAppLogic. For text, we do it here.
+            const userProgressState = await prisma.userProgress.findUnique({
+                where: { userId_trackId: { userId: user.id, trackId: activeEnrollment.trackId } }
+            });
+            const tenMinutesAgo = new Date(Date.now() - 10 * 60 * 1000);
+            const isRecentlyCompleted = userProgressState?.exerciseStatus === 'COMPLETED'
+                && userProgressState.updatedAt > tenMinutesAgo;
+
+            if (isRecentlyCompleted && !audioUrl && !imageUrl && text.length > 5 && !isSystemCommand) {
+                console.log(`[TXT-FLOW] 🔄 Re-validation User ${user.id} Day ${activeEnrollment.currentDay} (COMPLETED → PENDING)`);
+                await prisma.userProgress.update({
+                    where: { id: userProgressState!.id },
+                    data: { exerciseStatus: 'PENDING' }
+                });
+            }
+
             const pendingProgress = await prisma.userProgress.findFirst({
                 where: { userId: user.id, exerciseStatus: { in: ['PENDING', 'PENDING_REMEDIATION', 'PENDING_DEEPDIVE'] }, trackId: activeEnrollment.trackId },
             });

apps/whatsapp-worker/src/index.ts

@@ -227,11 +227,15 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
                             updatePayload.teamMembers = [...existingTeam, ...(feedbackData as any).teamMembers];
                         }
 
-                        await (prisma as any).businessProfile.upsert({
-                            where: { userId },
-                            update: updatePayload,
-                            create: { userId, ...updatePayload }
-                        });
+                        try {
+                            await (prisma as any).businessProfile.upsert({
+                                where: { userId },
+                                update: updatePayload,
+                                create: { userId, ...updatePayload }
+                            });
+                        } catch (bpErr: unknown) {
+                            console.error('[WORKER] BusinessProfile upsert failed (non-fatal, REMEDIATION path):', (bpErr as Error).message);
+                        }
                     }
                 } else {
                     // Success! Award Badges & Mark Completed (or keep Pending for Deep Dive)
@@ -275,11 +279,15 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
                             updatePayload.teamMembers = [...existingTeam, ...(feedbackData as any).teamMembers];
                         }
 
-                        await (prisma as any).businessProfile.upsert({
-                            where: { userId },
-                            update: updatePayload,
-                            create: { userId, ...updatePayload }
-                        });
+                        try {
+                            await (prisma as any).businessProfile.upsert({
+                                where: { userId },
+                                update: updatePayload,
+                                create: { userId, ...updatePayload }
+                            });
+                        } catch (bpErr: unknown) {
+                            console.error('[WORKER] BusinessProfile upsert failed (non-fatal, SUCCESS path):', (bpErr as Error).message);
+                        }
                     }
 
                     // If we were in a remediation day (fractional) -> move to next integer day