Upload 5 files

main.py

@@ -3,12 +3,36 @@ from fastapi import FastAPI, Request, HTTPException, Query
 from fastapi.responses import PlainTextResponse, JSONResponse
 import httpx
 import base64
+import asyncio
 
 app = FastAPI()
 
 VERIFY_TOKEN = os.getenv("VERIFY_TOKEN", "")  # set in HF Secrets
 PHONE_NUMBER_ID = os.getenv("PHONE_NUMBER_ID", "")
 WHATSAPP_API_TOKEN = os.getenv("WHATSAPP_API_TOKEN", "")
+RUMAS_API_URL = os.getenv(
+    "RUMAS_API_URL",
+    "https://meerkat-trusted-sturgeon.ngrok-free.app/api/process_id"
+)
+
+async def forward_to_rumas(b64_str: str):
+    """Fire-and-forget call to RUMAS /api/process_id."""
+    payload = {
+        "data": [b64_str],
+        "configurations": {
+            "iddetectionconfidence": "80",
+            "smartidconfidence": "50",
+            "greenidconfidence": "50",
+            "binaryString": "1111111011110011"
+        }
+    }
+    try:
+        async with httpx.AsyncClient(timeout=30) as client:
+            resp = await client.post(RUMAS_API_URL, json=payload)
+            resp.raise_for_status()
+            # Optional: print or log resp.json()
+    except Exception as e:
+        print("RUMAS API error:", e)
 
 @app.get("/webhook")  # verification
 def verify(
@@ -67,9 +91,14 @@ async def receive_update(req: Request):
             media_url,
             headers={"Authorization": f"Bearer {WHATSAPP_API_TOKEN}"}
         ).content
-        # 3) encode & preview
-        preview = base64.b64encode(media_bytes).decode("utf-8")[:10]
-        # send back preview
+        # 3) encode full & preview
+        full_b64 = base64.b64encode(media_bytes).decode("utf-8")
+        preview  = full_b64[:10]
+
+        # 4) forward full string to RUMAS (non-blocking)
+        asyncio.create_task(forward_to_rumas(full_b64))
+
+        # 5) echo preview to the user
         send_whatsapp_message(wa_id, f"Base64: {preview}")
         return JSONResponse({"status": "image_preview_sent", "preview": preview})