Create follow-ups when a lead replies with interest

from datetime import date, timedelta
from clickruntime import on_trigger, credentials, http, ai, state, notify, report_fetched

API = "https://api.pipedrive.com"

@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 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 []
        latest = msgs[-1] if msgs else {}
        if t.get("deal_id") and latest.get("snippet"):
            label = ai.generate(latest["snippet"][:1500], max_output_tokens=5,
                                system="Does this email show interest in a meeting or call? Answer yes or no.").text.strip().lower()
            if label.startswith("yes"):
                http.post(f"{API}/api/v2/activities", headers=headers, json={
                    "subject": f"Call: {t['subject']}", "type": "call", "deal_id": t["deal_id"],
                    "due_date": (date.today() + timedelta(days=1)).isoformat()}).raise_for_status()
                notify.email_me(f"Interested reply: {t['subject']}", latest["snippet"][:500])
        seen[str(t["id"])] = t["update_time"]
    state.set("seen", seen)
    return {"checked": len(new)}