Qualify WhatsApp enquiries into HubSpot

from clickruntime import on_event, credentials, http, state, ai, notify
API = "https://api.hubapi.com/crm/v3/objects/contacts"
WA = "https://graph.facebook.com/v21.0/123456789012345/messages"  # your phone number ID
SCHEMA = {"type": "object", "properties": {k: {"type": "string"} for k in ["name", "need", "budget", "reply"]} | {
          "score": {"type": "integer"}}, "required": ["name", "need", "budget", "score", "reply"]}
@on_event
def handle(event):
    value = event.json["entry"][0]["changes"][0]["value"]
    if "messages" not in value:
        return {"skipped": "status update"}
    sender = (msg := value["messages"][0])["from"]
    chat = (state.get(f"chat:{sender}") or []) + [f"Customer: {msg.get('text', {}).get('body', '')}"]
    out = ai.generate("\n".join(chat[-16:]), json_schema=SCHEMA, max_output_tokens=300, system=(
        "You qualify sales enquiries on WhatsApp. Fill in name, need and budget if known (else empty), "
        "score the lead 1-10, and write a short friendly reply asking for whatever is still missing.")).json
    http.post(WA, headers={"Authorization": f"Bearer {credentials.secret('WHATSAPP_TOKEN')}"}, json={
        "messaging_product": "whatsapp", "to": sender, "type": "text", "text": {"body": out["reply"]}}).raise_for_status()
    state.set(f"chat:{sender}", (chat + [f"Us: {out['reply']}"])[-16:])
    headers = {"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"}
    props = {"phone": f"+{sender}", "firstname": out["name"],
             "message": f"Need: {out['need']}\nBudget: {out['budget']}\nAI score: {out['score']}/10"}
    found = http.post(f"{API}/search", headers=headers, json={"filterGroups": [{"filters": [
        {"propertyName": "phone", "operator": "EQ", "value": f"+{sender}"}]}]}).json()["results"]
    url, call = (f"{API}/{found[0]['id']}", http.patch) if found else (API, http.post)
    call(url, headers=headers, json={"properties": props}).raise_for_status()
    if out["score"] >= 8 and not state.get(f"alerted:{sender}"):
        notify.slack(f"Hot WhatsApp lead ({out['score']}/10): {out['name'] or '+' + sender}\n"
                     f"Need: {out['need']} | Budget: {out['budget']}", channel="#sales")
        state.set(f"alerted:{sender}", True)
    return {"score": out["score"], "contact_existed": bool(found)}