Upload main.py

main.py

@@ -12,6 +12,8 @@ PHONE_NUMBER_ID = os.getenv("PHONE_NUMBER_ID", "")
 WHATSAPP_API_TOKEN = os.getenv("WHATSAPP_API_TOKEN", "")
 RUMAS_API_URL = os.getenv("RUMAS_API_URL", "")
 
+processed_message_ids = set()
+
 async def forward_to_rumas(b64_str: str, wa_id: str):
     """Fire-and-forget call to RUMAS /api/process_id."""
     payload = {
@@ -51,6 +53,7 @@ async def forward_to_rumas(b64_str: str, wa_id: str):
                     f"*Gender*: {det.get('gender','?')}"
                 )
                 send_whatsapp_message(wa_id, reply)
+                send_whatsapp_message(wa_id, f"Full RUMAS response:\n{json.dumps(data, indent=2)[:4000]}")
 
     except Exception as e:
         print(f"[RUMAS] ✘ error while sending '{short}…' →", e)
@@ -113,6 +116,12 @@ async def receive_update(req: Request):
         print("Malformed webhook payload:", e)
         return JSONResponse({"status": "ignored", "reason": "malformed payload"})
 
+    msg_id = msg.get("id")
+    if msg_id in processed_message_ids:
+        print(f"Duplicate message {msg_id}, skipping.")
+        return JSONResponse({"status": "duplicate", "id": msg_id})
+    processed_message_ids.add(msg_id)
+
     # IMAGE: if user sent an image, convert to Base64 preview
     if msg["type"] == "image":
         media_id = msg["image"]["id"]
@@ -136,7 +145,6 @@ async def receive_update(req: Request):
         asyncio.create_task(forward_to_rumas(full_b64, wa_id))
 
         # 5) echo preview to the user
-        send_whatsapp_message(wa_id, f"Base64: {preview}")
         return JSONResponse({"status": "image_preview_sent", "preview": preview})
 
     # TEXT: simple echo