Get alerted to refund and chargeback tickets

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

API = "https://northwind.gorgias.com/api"
KEYWORDS = ("refund", "chargeback", "broken")

@on_trigger
def run(event):
    auth = (credentials.secret("GORGIAS_EMAIL"), credentials.secret("GORGIAS_API_KEY"))
    last_id = state.get("last_id") or 0
    tickets = [t for t in http.get(f"{API}/tickets", auth=auth, params={"limit": 50, "order_by": "created_datetime:desc"}).json()["data"]
               if t["id"] > last_id]
    report_fetched(len(tickets))
    if not tickets:
        return {"new": 0}
    urgent = 0
    for t in tickets:
        msgs = http.get(f"{API}/tickets/{t['id']}/messages", auth=auth).json()["data"]
        text = f"{t.get('subject', '')} {msgs[0].get('body_text', '') if msgs else ''}"[:1500]
        hit = any(k in text.lower() for k in KEYWORDS)
        if not hit:  # catch paraphrases like "money back" or "arrived cracked"
            hit = ai.generate(f"Ticket: {text}\nIs this about a refund, chargeback or broken item? Answer yes or no.",
                              max_output_tokens=5).text.strip().lower().startswith("yes")
        if hit:
            urgent += 1
            notify.slack(f":rotating_light: {t['customer'].get('email')}: *{t.get('subject')}*\n"
                         f"https://northwind.gorgias.com/app/ticket/{t['id']}", channel="#support-urgent")
    state.set("last_id", max(t["id"] for t in tickets))
    return {"new": len(tickets), "urgent": urgent}