Turn lead replies into the right Pipedrive follow-up

from clickruntime import on_trigger, credentials, http, ai, state, notify, report_fetched

API = "https://api.pipedrive.com"
TASKS = {"meeting": ("call", "Book the meeting"), "pricing": ("email", "Send pricing"), "later": ("task", "Check back")}

@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('pipedrive', 'work')}"}
    threads = http.get(f"{API}/v1/mailbox/mailThreads", headers=headers, params={"folder": "inbox", "limit": 50}).json()["data"] or []
    seen = state.get("seen") or {}
    new = [t for t in threads if t.get("deal_id") and seen.get(str(t["id"])) != t["update_time"]]
    report_fetched(len(new))
    if not new:
        return {"checked": 0}
    for t in new:
        msgs = http.get(f"{API}/v1/mailbox/mailThreads/{t['id']}/mailMessages", headers=headers).json()["data"] or []
        intent = ai.generate((msgs[-1].get("snippet") or "")[:1500], max_output_tokens=5,
                             system="Reply with one word: meeting, pricing, later or none.").text.strip().lower()
        if intent in TASKS:
            kind, subject = TASKS[intent]
            http.post(f"{API}/v1/activities", headers=headers, json={"subject": subject, "type": kind, "deal_id": t["deal_id"]})
            notify.slack(f"Reply on '{t.get('subject')}': {intent}. Added '{subject}' in Pipedrive.", channel="#sales")
        seen[str(t["id"])] = t["update_time"]
    state.set("seen", seen)
    return {"handled": len(new)}