fix: restore missing loops and fix syntax in whatsapp route

apps/api/src/routes/whatsapp.ts

@@ -101,6 +101,7 @@ export async function whatsappRoutes(fastify: FastifyInstance) {
     // ── POST /webhook — Incoming Meta events ────────────────────────────────
     fastify.post('/webhook', async (request, reply) => {
         // ── 1. HMAC Signature Verification ──────────────────────────────────
+        console.log("[RAW-WHATSAPP-PAYLOAD]", JSON.stringify(request.body, null, 2));
         const appSecret = process.env.WHATSAPP_APP_SECRET;
 
         if (appSecret) {
@@ -173,9 +174,10 @@ export async function whatsappRoutes(fastify: FastifyInstance) {
         }
 
         // ── 4. Background Processing (enqueue to Worker) ──
+        const body = request.body;
         setImmediate(async () => {
             try {
-                const parsed = WebhookPayloadSchema.safeParse(body); // Use 'body' here
+                const parsed = WebhookPayloadSchema.safeParse(body);
                 if (!parsed.success) {
                     fastify.log.warn(`[WEBHOOK] Failed to parse webhook payload: ${parsed.error.message}`);
                     return;
@@ -184,54 +186,70 @@ export async function whatsappRoutes(fastify: FastifyInstance) {
                 const { scheduleInboundMessage } = await import('../services/queue');
                 const payload = parsed.data;
 
-                                } else if (message.interactive.type === 'list_reply' && message.interactive.list_reply) {
-                                    text = message.interactive.list_reply.id;
+                for (const entry of payload.entry || []) {
+                    for (const change of entry.changes || []) {
+                        if (change.value?.messages) {
+                            for (const message of change.value.messages) {
+                                const phone = message.from;
+                                const messageId = message.id;
+                                console.log("[WEBHOOK-TRACE] Processing message for phone:", phone);
+
+                                let text: string | undefined;
+                                if (message.type === 'text' && message.text) {
+                                    text = message.text.body;
+                                } else if (message.type === 'interactive' && message.interactive) {
+                                    if (message.interactive.type === 'button_reply' && message.interactive.button_reply) {
+                                        text = message.interactive.button_reply.id;
+                                    } else if (message.interactive.type === 'list_reply' && message.interactive.list_reply) {
+                                        text = message.interactive.list_reply.id;
+                                    }
+                                }
+
+                                if (text) {
+                                    await scheduleInboundMessage({ phone, text, messageId });
+                                } else if (message.type === 'audio' && message.audio) {
+                                    const accessToken = process.env.WHATSAPP_ACCESS_TOKEN || undefined;
+                                    const { Queue } = await import('bullmq');
+                                    const Redis = (await import('ioredis')).default;
+                                    const conn = process.env.REDIS_URL
+                                        ? new Redis(process.env.REDIS_URL, { maxRetriesPerRequest: null })
+                                        : new Redis({ host: process.env.REDIS_HOST || 'localhost', port: parseInt(process.env.REDIS_PORT || '6379'), maxRetriesPerRequest: null });
+                                    const q = new Queue('whatsapp-queue', { connection: conn as any });
+                                    
+                                    await q.add('download-media', {
+                                        mediaId: message.audio.id,
+                                        mimeType: message.audio.mime_type || 'audio/ogg',
+                                        phone,
+                                        ...(accessToken ? { accessToken } : {})
+                                    }, { priority: 1, attempts: 3, backoff: { type: 'exponential', delay: 2000 } });
+
+                                    await q.add('send-message-direct', {
+                                        phone,
+                                        text: "⏳ J'analyse ton audio..."
+                                    });
+                                } else if (message.type === 'image' && message.image) {
+                                    console.log(`[IMAGE-FLOW] Image detected! ID: ${message.image.id}`);
+                                    const accessToken = process.env.WHATSAPP_ACCESS_TOKEN || undefined;
+                                    const { Queue } = await import('bullmq');
+                                    const Redis = (await import('ioredis')).default;
+                                    const conn = process.env.REDIS_URL
+                                        ? new Redis(process.env.REDIS_URL, { maxRetriesPerRequest: null })
+                                        : new Redis({ host: process.env.REDIS_HOST || 'localhost', port: parseInt(process.env.REDIS_PORT || '6379'), maxRetriesPerRequest: null });
+                                    const q = new Queue('whatsapp-queue', { connection: conn as any });
+                                    
+                                    console.log(`[IMAGE-FLOW] Enqueuing for download...`);
+                                    await q.add('download-media', {
+                                        mediaId: message.image.id,
+                                        mimeType: 'image/jpeg',
+                                        phone,
+                                        ...(accessToken ? { accessToken } : {})
+                                    }, { priority: 1, attempts: 3, backoff: { type: 'exponential', delay: 2000 } });
+
+                                    await q.add('send-message-direct', {
+                                        phone,
+                                        text: "⏳ J'analyse ton image..."
+                                    });
                                 }
-                                if (text) await scheduleInboundMessage({ phone, text, messageId });
-
-                            } else if (message.type === 'audio' && message.audio) {
-                                // Existing audio logic (queues download-media)
-                                const accessToken = process.env.WHATSAPP_ACCESS_TOKEN || undefined;
-                                const { Queue } = await import('bullmq');
-                                const Redis = (await import('ioredis')).default;
-                                const conn = process.env.REDIS_URL
-                                    ? new Redis(process.env.REDIS_URL, { maxRetriesPerRequest: null })
-                                    : new Redis({ host: process.env.REDIS_HOST || 'localhost', port: parseInt(process.env.REDIS_PORT || '6379'), maxRetriesPerRequest: null });
-                                const q = new Queue('whatsapp-queue', { connection: conn as any });
-                                
-                                await q.add('download-media', {
-                                    mediaId: message.audio.id,
-                                    mimeType: message.audio.mime_type || 'audio/ogg',
-                                    phone,
-                                    ...(accessToken ? { accessToken } : {})
-                                }, { priority: 1, attempts: 3, backoff: { type: 'exponential', delay: 2000 } });
-
-                                await q.add('send-message-direct', {
-                                    phone,
-                                    text: "⏳ J'analyse ton audio..."
-                                });
-                            } else if (message.type === 'image' && message.image) {
-                                console.log(`[IMAGE-FLOW] Image detected! ID: ${message.image.id}`);
-                                const accessToken = process.env.WHATSAPP_ACCESS_TOKEN || undefined;
-                                const { Queue } = await import('bullmq');
-                                const Redis = (await import('ioredis')).default;
-                                const conn = process.env.REDIS_URL
-                                    ? new Redis(process.env.REDIS_URL, { maxRetriesPerRequest: null })
-                                    : new Redis({ host: process.env.REDIS_HOST || 'localhost', port: parseInt(process.env.REDIS_PORT || '6379'), maxRetriesPerRequest: null });
-                                const q = new Queue('whatsapp-queue', { connection: conn as any });
-                                
-                                console.log(`[IMAGE-FLOW] Enqueuing for download...`);
-                                await q.add('download-media', {
-                                    mediaId: message.image.id,
-                                    mimeType: 'image/jpeg',
-                                    phone,
-                                    ...(accessToken ? { accessToken } : {})
-                                }, { priority: 1, attempts: 3, backoff: { type: 'exponential', delay: 2000 } });
-
-                                await q.add('send-message-direct', {
-                                    phone,
-                                    text: "⏳ J'analyse ton image..."
-                                });
                             }
                         }
                     }