wa gateway

app.py

@@ -2,6 +2,7 @@ from fastapi import FastAPI
 from routes.category import router  # routes.py must be in same folder
 from routes.question import askMe
 from routes.headlines import headlines
+from routes.wa_gateway import wa_router
 from dotenv import load_dotenv
 from cache_init import fetch_and_cache_articles
 from fastapi.middleware.cors import CORSMiddleware
@@ -13,6 +14,7 @@ app = FastAPI()
 app.include_router(router)
 app.include_router(askMe)
 app.include_router(headlines)
+app.include_router(wa_router)
 
 app.add_middleware(
     CORSMiddleware,

routes/wa_gateway.py

@@ -0,0 +1,71 @@
+# app/routes/wa_gateway.py
+from fastapi import APIRouter
+import os
+import requests
+from dotenv import load_dotenv
+from fastapi.responses import JSONResponse
+
+load_dotenv()
+
+wa_router = APIRouter()
+
+ACCESS_TOKEN = os.getenv("WHATSAPP_ACCESS_TOKEN")
+PHONE_NUMBER_ID = os.getenv("WHATSAPP_PHONE_NUMBER_ID")
+RECIPIENT_NUMBER = "+353 89 949 5777"  # or pass dynamically
+
+@wa_router.get("/webhook")
+async def verify_webhook(request: Request):
+    params = request.query_params
+    if params.get("hub.mode") == "subscribe" and params.get("hub.verify_token") == ACCESS_TOKEN:
+        return JSONResponse(content=params.get("hub.challenge"))
+    return JSONResponse(status_code=403, content={"error": "Verification failed"})
+
+@wa_router.post("/webhook")
+async def receive_whatsapp_event(request: Request):
+    body = await request.json()
+    print("[WEBHOOK] Incoming message:", body)
+
+    # Detect message and extract user number + message
+    try:
+        entry = body["entry"][0]
+        changes = entry["changes"][0]
+        value = changes["value"]
+        messages = value.get("messages")
+
+        if messages:
+            msg = messages[0]
+            from_number = msg["from"]
+            text = msg["text"]["body"]
+
+            print(f"[INFO] Message from {from_number}: {text}")
+
+            # Trigger your response logic here — for example, reply with interactive message
+
+    except Exception as e:
+        print("[ERROR] Webhook processing failed:", str(e))
+
+    return JSONResponse(content={"status": "received"})
+
+@wa_router.post("/whatsapp/send")
+def send_whatsapp_message():
+    url = f"https://graph.facebook.com/v17.0/{PHONE_NUMBER_ID}/messages"
+    headers = {
+        "Authorization": f"Bearer {ACCESS_TOKEN}",
+        "Content-Type": "application/json"
+    }
+    payload = {
+        "messaging_product": "whatsapp",
+        "to": RECIPIENT_NUMBER,
+        "type": "template",
+        "template": {
+            "name": "hello_world",
+            "language": { "code": "en_US" }
+        }
+    }
+
+    response = requests.post(url, headers=headers, json=payload)
+    try:
+        response.raise_for_status()
+        return {"status": "sent", "response": response.json()}
+    except Exception as e:
+        return {"status": "failed", "error": str(e)}