Qualify WhatsApp leads and alert sales about hot ones

from clickruntime import on_event, credentials, http, notify, state, ai

QUESTIONS = ["What are you looking for?", "Roughly what budget do you have in mind?", "When would you like to start?"]
WA = "https://graph.facebook.com/v20.0/your-phone-number-id/messages"

def wa(to, text):
    http.post(WA, headers={"Authorization": f"Bearer {credentials.secret('WHATSAPP_TOKEN')}"},
              json={"messaging_product": "whatsapp", "to": to, "type": "text", "text": {"body": text}}).raise_for_status()
def incoming(event):
    changes = [c for e in (event.json or {}).get("entry", []) for c in e.get("changes", [])]
    return [(m["from"], m["text"]["body"]) for c in changes for m in c["value"].get("messages", []) if m.get("type") == "text"]

@on_event
def handle(event):
    for phone, text in incoming(event):
        lead = state.get(f"lead:{phone}") or {"answers": [], "done": False}
        if lead["done"]:
            continue
        lead["answers"].append(text)
        step = len(lead["answers"]) - 1
        if step < len(QUESTIONS):
            wa(phone, QUESTIONS[step])
        else:
            qa = "\n".join(f"{q} {a}" for q, a in zip(QUESTIONS, lead["answers"][1:]))
            score = ai.generate(qa, system="Score this lead 1-10 for a B2B design agency. Reply with the number only.", max_output_tokens=5).text.strip()
            if score.isdigit() and int(score) >= 7:
                notify.slack(f":fire: Hot WhatsApp lead +{phone} (score {score})\n{qa}", channel="#sales")
            wa(phone, "Thanks! We'll be in touch shortly.")
            lead["done"] = True
        state.set(f"lead:{phone}", lead)
    return {"ok": True}