Upload 5 files

main.py

@@ -19,25 +19,22 @@ def verify(
         return PlainTextResponse(hub_challenge)
     raise HTTPException(status_code=403, detail="Invalid token")
 
-@app.post("/webhook")  # incoming messages
+@app.post("/webhook")
 async def receive_update(req: Request):
     data = await req.json()
-    # log the raw update
-    print("WA update:", json.dumps(data))
-
-    # drill into the first WhatsApp message
     change = data["entry"][0]["changes"][0]["value"]
     wa_id  = change["contacts"][0]["wa_id"]
     msg    = change["messages"][0]
 
-    # prepare reply
-    if msg["type"] == "text":
-        incoming = msg["text"]["body"]
-        reply     = f"You said: {incoming}"
-    else:
-        reply = "Please send me a text message."
+    # 1) Ignore non-text messages
+    if msg["type"] != "text":
+        print(f"Ignoring message type: {msg['type']}")
+        return JSONResponse({"status": "ignored", "type": msg["type"]})
+
+    # 2) Handle text as before
+    incoming = msg["text"]["body"]
+    reply    = f"You said: {incoming}"
 
-    # send the reply back via the WhatsApp Cloud API
     url = f"https://graph.facebook.com/v23.0/{PHONE_NUMBER_ID}/messages"
     headers = {
         "Authorization": f"Bearer {WHATSAPP_API_TOKEN}",
@@ -49,8 +46,12 @@ async def receive_update(req: Request):
         "type": "text",
         "text": {"body": reply}
     }
-    resp = httpx.post(url, headers=headers, json=payload)
-    resp.raise_for_status()
+
+    try:
+        resp = httpx.post(url, headers=headers, json=payload)
+        resp.raise_for_status()
+    except httpx.HTTPStatusError as e:
+        print("Failed to send reply:", e)
 
     return JSONResponse({"status": "replied"})