WhatsApp Click-to-Chat Ad Infrastructure

[ User Taps Meta Click-to-WhatsApp Ad (Instagram / Facebook) ]
                               │
                               ▼
[ Instant WhatsApp Chat Window Opens with Pre-Filled Prompt ]
  (e.g., "Hi! I am interested in Enterprise AI Automation for our clinic.")
                               │
                               ▼
[ KaamLabs Autonomous AI SDR Agent (Meta Cloud API + FastAPI) ]
  • Greets prospect in natural English, Hindi, or Hinglish (< 2 sec)
  • Collects qualification data: Company Name, Role, Budget, Timeline
  • Validates Indian phone number and authenticates identity
                               │
        ┌──────────────────────┴──────────────────────┐
        │                                             │
        ▼ (Sales Pipeline)                            ▼ (Ad Attribution)
[ CRM Synchronization ]                       [ Meta CAPI Offline Event ]
• Pushes Lead to Zoho / HubSpot / Salesforce  • Fires qualified Lead event to Meta
• Alerts Sales Director via WhatsApp PUSH     • Optimizes ad bidding algorithm

# app/routers/whatsapp_webhook.py
from fastapi import APIRouter, Request, BackgroundTasks
import httpx
import os

router = APIRouter()
META_TOKEN = os.getenv("META_WA_ACCESS_TOKEN")
PHONE_NUMBER_ID = os.getenv("META_PHONE_NUMBER_ID")

async def process_incoming_lead(sender_phone: str, message_text: str):
    # 1. Evaluate lead with AI Qualification Agent
    ai_reply = f"Thank you for contacting KaamLabs! We have received your briefing regarding: '{message_text}'. Our engineering team will review your scope within 30 minutes."

    # 2. Dispatch response via WhatsApp Cloud API
    url = f"https://graph.facebook.com/v21.0/{PHONE_NUMBER_ID}/messages"
    headers = {"Authorization": f"Bearer {META_TOKEN}"}
    payload = {
        "messaging_product": "whatsapp",
        "to": sender_phone,
        "type": "text",
        "text": {"body": ai_reply}
    }

    async with httpx.AsyncClient() as client:
        await client.post(url, json=payload, headers=headers)

@router.post("/webhook")
async def receive_whatsapp_event(request: Request, background_tasks: BackgroundTasks):
    data = await request.json()
    entry = data.get("entry", [])[0]
    changes = entry.get("changes", [])[0]
    value = changes.get("value", {})
    messages = value.get("messages", [])

    if messages:
        sender = messages[0].get("from")
        text = messages[0].get("text", {}).get("body", "")
        background_tasks.add_task(process_incoming_lead, sender, text)

    return {"status": "ok"}