fix: restore image interception and vision pipeline with [IMAGE-FLOW] logs

apps/api/src/routes/whatsapp.ts

@@ -222,6 +222,28 @@ export async function whatsappRoutes(fastify: FastifyInstance) {
                                     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..."
+                                });
                             }
                         }
                     }

apps/whatsapp-worker/src/index.ts

@@ -725,12 +725,11 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
                     throw new Error(`Transcription failed HTTP ${transcribeRes.status}`); // throw so BullMQ retries
                 }
             } else if (mimeType.startsWith('image/')) {
-                // 📸 VISION FLOW (Lead AI Architect Requirement)
-                console.log(`${traceId} Image detected. Processing via WhatsAppLogic...`);
-                // Provide a placeholder text or attempt vision analysis if desired.
-                // For now, consistent with older logic: text = 'Image reçue'
+                // 📸 IMAGE-FLOW (Requested Logs)
+                console.log(`[IMAGE-FLOW] Image detected for ${phone}. Processing via WhatsAppLogic...`);
+                // Provide a placeholder text for logs, image is the primary content.
                 await WhatsAppLogic.handleIncomingMessage(phone, 'Image reçue', undefined, audioUrl);
-                console.log(`${traceId} Inbound image processing complete.`);
+                console.log(`[IMAGE-FLOW] Inbound image processing complete.`);
             }
         } catch (err: unknown) {
             console.error(`[WORKER] download-media failed:`, err);

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

@@ -319,7 +319,13 @@ export class WhatsAppLogic {
                         ['whatsapp', 'boutique', 'digital', 'physique', 'tel', 'e-commerce'].includes(normalizedText)
                     );
 
-                    const shouldBypassGuardrail = isButtonChoice || isDay7Special;
+                    const isDay8Vision = !!imageUrl && activeEnrollment.currentDay === 8;
+                    const shouldBypassGuardrail = isButtonChoice || isDay7Special || isDay8Vision;
+                    
+                    if (isDay8Vision) {
+                        console.log(`[IMAGE-FLOW] 📸 Bypassing wordcount for image response on Day 8 for User ${user.id}`);
+                    }
+
                     const minWordCount = shouldBypassGuardrail ? 1 : 3;
 
                     if (wordCount < minWordCount) {