fix: restore image forwarding and result propagation in internal routes

apps/api/src/routes/internal.ts

@@ -9,7 +9,7 @@ const WhatsAppMessageSchema = z.object({
     type: z.enum(['text', 'audio', 'image', 'video', 'document', 'sticker', 'reaction', 'interactive']),
     text: z.object({ body: z.string() }).optional(),
     audio: z.object({ id: z.string(), mime_type: z.string().optional() }).optional(),
-    image: z.object({ id: z.string() }).optional(),
+    image: z.object({ id: z.string(), caption: z.string().optional() }).optional(),
     interactive: z.object({
         type: z.enum(['button_reply', 'list_reply']),
         button_reply: z.object({
@@ -110,6 +110,33 @@ export async function internalRoutes(fastify: FastifyInstance) {
 
                                 fastify.log.info(`[INTERNAL-WEBHOOK] Audio ${message.audio.id} enqueued for Railway download`);
                                 continue;
+                            } else if (message.type === 'image' && message.image) {
+                                // ─── Image inbound: delegate download to Railway worker ────────────
+                                const accessToken = process.env.WHATSAPP_ACCESS_TOKEN || '';
+                                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 });
+
+                                fastify.log.info(`[INTERNAL-WEBHOOK] Image ${message.image.id} detected. Enqueuing download.`);
+                                
+                                await q.add('download-media', {
+                                    mediaId: message.image.id,
+                                    mimeType: 'image/jpeg',
+                                    phone,
+                                    caption: message.image.caption || undefined,
+                                    ...(accessToken ? { accessToken } : {})
+                                }, { priority: 1, attempts: 3, backoff: { type: 'exponential', delay: 2000 } });
+
+                                await q.add('send-message-direct', {
+                                    phone,
+                                    text: "⏳ J'analyse ton image..."
+                                });
+
+                                fastify.log.info(`[INTERNAL-WEBHOOK] Image ${message.image.id} enqueued for Railway download`);
+                                continue;
                             }
 
                             if (phone && text) {
@@ -126,7 +153,7 @@ export async function internalRoutes(fastify: FastifyInstance) {
 
     // ── Handle standard transcribed messages from worker (Railway) ───────────
     fastify.post<{
-        Body: { phone: string; text: string; audioUrl?: string }
+        Body: { phone: string; text: string; audioUrl?: string; imageUrl?: string }
     }>('/v1/internal/handle-message', {
         config: { requireAuth: true } as any,
         schema: {
@@ -136,12 +163,13 @@ export async function internalRoutes(fastify: FastifyInstance) {
                 properties: {
                     phone: { type: 'string' },
                     text: { type: 'string' },
-                    audioUrl: { type: 'string' }
+                    audioUrl: { type: 'string' },
+                    imageUrl: { type: 'string' }
                 }
             }
         }
     }, async (request, reply) => {
-        const { phone, text, audioUrl } = request.body;
+        const { phone, text, audioUrl, imageUrl } = request.body;
         const traceId = `[INTERNAL-TX-${phone.slice(-4)}]`;
 
         if (!phone || text === undefined) {
@@ -149,11 +177,11 @@ export async function internalRoutes(fastify: FastifyInstance) {
             return reply.code(400).send({ error: 'phone and text are required' });
         }
 
-        request.log.info(`${traceId} Received transcribed text: "${text.substring(0, 100)}..."`);
+        request.log.info(`${traceId} Received message text: "${text.substring(0, 100)}..." (Image: ${!!imageUrl})`);
 
         // Fire and await - ensuring the worker knows if it failed
         try {
-            await WhatsAppService.handleIncomingMessage(phone, text, audioUrl);
+            await WhatsAppService.handleIncomingMessage(phone, text, audioUrl, imageUrl);
             request.log.info(`${traceId} Successfully processed message`);
         } catch (err: unknown) {
             request.log.error(`${traceId} handleIncomingMessage error: ${(err instanceof Error ? (err instanceof Error ? err.message : String(err)) : String(err))}`);