feat(admin): human-in-the-loop dashboard base, add PENDING_REVIEW logic and audio overdrive worker

apps/api/src/routes/admin.ts

@@ -1,5 +1,6 @@
 import { FastifyInstance } from 'fastify';
 import { prisma } from '../services/prisma';
+import { whatsappQueue } from '../services/queue';
 import { z } from 'zod';
 
 // ─── Zod Schemas ───────────────────────────────────────────────────────────────
@@ -25,6 +26,14 @@ const TrackDaySchema = z.object({
     unlockCondition: z.string().optional(),
 });
 
+const OverrideFeedbackSchema = z.object({
+    userId: z.string(),
+    trackId: z.string(),
+    transcription: z.string().min(1),
+    overrideAudioUrl: z.string().url(),
+    adminId: z.string()
+});
+
 export async function adminRoutes(fastify: FastifyInstance) {
 
     // ── Dashboard Stats ────────────────────────────────────────────────────────
@@ -70,6 +79,90 @@ export async function adminRoutes(fastify: FastifyInstance) {
         return enrollments;
     });
 
+    // ── Human-in-the-Loop / Audio Overdrive ────────────────────────────────────
+
+    // LIVE FEED : Students blocked waiting for manual review
+    fastify.get('/admin/live-feed', async () => {
+        const pendingReviews = await prisma.userProgress.findMany({
+            where: {
+                exerciseStatus: 'PENDING_REVIEW',
+                user: { language: 'WOLOF' } // Currently only focusing on Wolof interceptions
+            },
+            include: {
+                user: { select: { id: true, name: true, phone: true, activity: true, language: true } },
+                track: { select: { id: true, title: true } }
+            },
+            orderBy: { updatedAt: 'asc' }
+        });
+
+        // Map the raw payload to find the actual response audio for each pending review
+        const liveFeed = await Promise.all(pendingReviews.map(async (progress) => {
+            const enrollment = await prisma.enrollment.findFirst({
+                where: { userId: progress.userId, trackId: progress.trackId, status: 'ACTIVE' }
+            });
+
+            // If no active enrollment found, fallback gracefully
+            if (!enrollment) return { ...progress, lastResponse: null };
+
+            // Find the most recent response from this user for this enrollment
+            const lastResponse = await prisma.response.findFirst({
+                where: { userId: progress.userId, enrollmentId: enrollment.id },
+                orderBy: { createdAt: 'desc' }
+            });
+
+            return {
+                ...progress,
+                audioUrl: lastResponse?.mediaUrl || null,
+                content: lastResponse?.content || null,
+                dayNumber: lastResponse?.dayNumber || Math.floor(enrollment.currentDay)
+            };
+        }));
+
+        return liveFeed;
+    });
+
+    // OVERRIDE ACTION : Admin posts the manual review
+    fastify.post('/admin/override-feedback', async (req, reply) => {
+        const body = OverrideFeedbackSchema.safeParse(req.body);
+        if (!body.success) return reply.code(400).send({ error: body.error.flatten() });
+
+        const { userId, trackId, transcription, overrideAudioUrl, adminId } = body.data;
+
+        // 1. Update UserProgress status & logs
+        const progress = await prisma.userProgress.update({
+            where: { userId_trackId: { userId, trackId } },
+            data: {
+                exerciseStatus: 'COMPLETED',
+                adminTranscription: transcription,
+                overrideAudioUrl: overrideAudioUrl,
+                reviewedBy: adminId
+            }
+        });
+
+        // 2. Update BusinessProfile with human-cleaned transcription
+        const enrollment = await prisma.enrollment.findFirst({
+            where: { userId, trackId, status: 'ACTIVE' }
+        });
+
+        const currentDay = enrollment ? Math.floor(enrollment.currentDay) : 0;
+
+        await prisma.businessProfile.upsert({
+            where: { userId },
+            update: { lastUpdatedFromDay: currentDay },
+            create: { userId, lastUpdatedFromDay: currentDay }
+        });
+
+        // 3. Dispatch Background Job (Audio Delivery + Next Day Increment)
+        await whatsappQueue.add('send-admin-audio-override', {
+            userId,
+            trackId,
+            overrideAudioUrl,
+            adminId
+        });
+
+        return reply.code(200).send({ ok: true, progress });
+    });
+
     // ══════════════════════════════════════════════════════════════════════════
     // TRACKS CRUD
     // ══════════════════════════════════════════════════════════════════════════

apps/whatsapp-worker/src/index.ts

@@ -60,6 +60,19 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
             });
 
             console.log(`[WORKER] Generating expert feedback for User ${userId}`);
+
+            // 🚨 HUMAN-IN-THE-LOOP INTERCEPTION
+            // If the user's language is WOLOF, we pause AI interpretation and wait for an Admin Review
+            if (language === 'WOLOF') {
+                console.log(`[WORKER] Intercepting WOLOF audio for User ${userId}. Shifting to PENDING_REVIEW.`);
+                await prisma.userProgress.upsert({
+                    where: { userId_trackId: { userId, trackId } },
+                    update: { exerciseStatus: 'PENDING_REVIEW' as any },
+                    create: { userId, trackId, exerciseStatus: 'PENDING_REVIEW' as any }
+                });
+                await sendTextMessage(user.phone, "🎙️ Nyangi jaxas sa kàddu. Xamle dina la tontu ci kanam ! (En cours d'analyse)");
+                return; // Stop job execution, wait for Admin
+            }
             const AI_API_BASE_URL = getApiUrl();
             const apiKey = getAdminApiKey();
 
@@ -696,6 +709,36 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
                 }
             }
         }
+        else if (job.name === 'send-admin-audio-override') {
+            const { userId, trackId, overrideAudioUrl, adminId } = job.data;
+            const user = await prisma.user.findUnique({ where: { id: userId } });
+
+            if (user?.phone) {
+                // 1. Send the Admin's Voice Message
+                const { sendAudioMessage } = await import('./whatsapp-cloud');
+                await sendAudioMessage(user.phone, overrideAudioUrl);
+
+                // 2. Send transition prompt
+                await sendTextMessage(user.phone,
+                    user.language === 'WOLOF'
+                        ? "Baax na ! Yónnee *SUITE* ngir dem ci kanam."
+                        : "Bravo ! Envoyez *SUITE* pour passer à la leçon suivante."
+                );
+
+                console.log(`[WORKER] Admin ${adminId} Audio Overdrive sent to User ${userId}.`);
+
+                // 3. Increment the logic via Queue so that user doesn't fall behind.
+                const enrollment = await prisma.enrollment.findFirst({
+                    where: { userId, trackId, status: 'ACTIVE' }
+                });
+
+                if (enrollment) {
+                    const nextDay = Math.floor(enrollment.currentDay) + 1;
+                    const q = new Queue('whatsapp-queue', { connection: connection as any });
+                    await q.add('send-content', { userId, trackId, dayNumber: nextDay }, { delay: 2000 });
+                }
+            }
+        }
     } catch (error) {
         console.error(`Job ${job.id} failed:`, error);
         throw error;

packages/database/prisma/schema.prisma

@@ -101,6 +101,9 @@ model UserProgress {
   exerciseStatus  ExerciseStatus @default(PENDING)
   badges          Json?          // Array of strings: ["CLARTE", "CONFIANCE"]
   behavioralScoring Json?         // { discipline_financiere: 0, organisation: 0, ... }
+  adminTranscription String?
+  overrideAudioUrl   String?
+  reviewedBy         String?
   createdAt       DateTime       @default(now())
   updatedAt       DateTime       @updatedAt
 
@@ -212,5 +215,6 @@ enum ExerciseType {
 enum ExerciseStatus {
   PENDING
   PENDING_REMEDIATION
+  PENDING_REVIEW
   COMPLETED
 }