Upload main.py

main.py

@@ -12,7 +12,7 @@ PHONE_NUMBER_ID = os.getenv("PHONE_NUMBER_ID", "")
 WHATSAPP_API_TOKEN = os.getenv("WHATSAPP_API_TOKEN", "")
 RUMAS_API_URL = os.getenv("RUMAS_API_URL", "")
 
-async def forward_to_rumas(b64_str: str):
+async def forward_to_rumas(b64_str: str, wa_id: str):
     """Fire-and-forget call to RUMAS /api/process_id."""
     payload = {
         "data": [b64_str],
@@ -40,13 +40,17 @@ async def forward_to_rumas(b64_str: str):
             print(f"[RUMAS] ✔ {resp.status_code}")
             pretty_print_dict(body)
 
-            # OPTIONAL: notify user (comment out if you prefer silent)
-            wa_id = body.get("wa_id")          # supply wa_id if backend echoes it
-            if wa_id:
-                send_whatsapp_message(
-                    wa_id,
-                    "✅ ID processed, results ready."
+            # ── send parsed ID back to WhatsApp ──
+            if wa_id and data.get("status") == "success":
+                det = data["results"][0]["detections"][0]
+                reply = (
+                    "✅ *ID processed*\n"
+                    f"*Name*: {det.get('name','?')} {det.get('surname','')}\n"
+                    f"*ID No.*: {det.get('id_num','?')}\n"
+                    f"*DOB*: {det.get('date_of_birth','?')}\n"
+                    f"*Gender*: {det.get('gender','?')}"
                 )
+                send_whatsapp_message(wa_id, reply)
 
     except Exception as e:
         print(f"[RUMAS] ✘ error while sending '{short}…' →", e)
@@ -129,7 +133,7 @@ async def receive_update(req: Request):
         preview  = full_b64[:10]
 
         # 4) forward full string to RUMAS (non-blocking)
-        asyncio.create_task(forward_to_rumas(full_b64))
+        asyncio.create_task(forward_to_rumas(full_b64, wa_id))
 
         # 5) echo preview to the user
         send_whatsapp_message(wa_id, f"Base64: {preview}")