Upload 5 files

main.py

@@ -1,10 +1,13 @@
 import os, json
 from fastapi import FastAPI, Request, HTTPException, Query
 from fastapi.responses import PlainTextResponse, JSONResponse
+import httpx
 
 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", "")
 
 @app.get("/webhook")  # verification
 def verify(
@@ -19,8 +22,37 @@ def verify(
 @app.post("/webhook")  # incoming messages
 async def receive_update(req: Request):
     data = await req.json()
-    print("WA update:", json.dumps(data)[:300])
-    return JSONResponse({"status": "received"})
+    # 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."
+
+    # 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}",
+        "Content-Type": "application/json"
+    }
+    payload = {
+        "messaging_product": "whatsapp",
+        "to": wa_id,
+        "type": "text",
+        "text": {"body": reply}
+    }
+    resp = httpx.post(url, headers=headers, json=payload)
+    resp.raise_for_status()
+
+    return JSONResponse({"status": "replied"})
 
 @app.get("/ping")      # health check
 def ping():