Add reply function

app/main.py

@@ -45,66 +45,67 @@ message_cache = MessageCache()
 async def webhook(request: Request):
     request_id = f"req_{int(time.time()*1000)}"
     logger.info(f"Processing webhook request {request_id}")
-    # Parse incoming request
     payload = await request.json()
 
     processed_count = 0
     error_count = 0
     results = []
 
-    changes = payload.get("entry", [])[0].get("changes", [])
-    
-    for change in changes:
-        messages = change.get("value", {}).get("messages", [])
-        
-        for message in messages:
-            message_id = message.get("id")
-            timestamp = message.get("timestamp")
-            content = message.get("text", {}).get("body")
-            sender_id = message.get("from")
-            
-            # Check for duplicate message ID
-                # Check for duplicate message
-            if message_cache.exists(message_id):
-                logger.info(f"Duplicate message detected: {message_id}")
-                continue
-            
-            try:
+    entries = payload.get("entry", [])
+
+    for entry in entries:
+        entry_id = entry.get("id")
+        logger.info(f"Processing entry_id: {entry_id}")
+
+        changes = entry.get("changes", [])
+        for change in changes:
+            messages = change.get("value", {}).get("messages", [])
+            for message in messages:
+                message_id = message.get("id")
+                timestamp = message.get("timestamp")
+                content = message.get("text", {}).get("body")
+                sender_id = message.get("from")
+
+                # Deduplicate messages based on message_id
+                if message_cache.exists(message_id):
+                    logger.info(f"Duplicate message detected and skipped: {message_id}")
+                    continue
+
+                try:
                     # Process message with retry logic
                     result = await process_message_with_retry(
                         sender_id,
                         content,
                         timestamp
                     )
+                    # Add the message ID to the cache
                     message_cache.add(message_id)
                     processed_count += 1
                     results.append(result)
-                    
-            except Exception as e:
-                error_count += 1
-                logger.error(
-                    f"Failed to process message {message_id}: {str(e)}",
-                    exc_info=True
-                )
-                results.append({
-                    "status": "error",
-                    "message_id": message_id,
-                    "error": str(e)
-                })
-
-    # Return detailed response
+                except Exception as e:
+                    error_count += 1
+                    logger.error(
+                        f"Failed to process message {message_id}: {str(e)}",
+                        exc_info=True
+                    )
+                    results.append({
+                        "status": "error",
+                        "message_id": message_id,
+                        "error": str(e)
+                    })
+
     response_data = {
         "request_id": request_id,
         "processed": processed_count,
         "errors": error_count,
         "results": results
     }
-    
+
     logger.info(
         f"Webhook processing completed - "
         f"Processed: {processed_count}, Errors: {error_count}"
     )
-    
+
     return JSONResponse(
         content=response_data,
         status_code=status.HTTP_200_OK