Email billing about payment tickets as they arrive

import base64
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, report_fetched, http, credentials, ai, state

ZD, AGENT = "https://yourcompany.zendesk.com/api/v2", "you@yourcompany.com"

def zd(method, path, **kw):
    r = http.request(method, ZD + path, auth=(f"{AGENT}/token", credentials.secret("ZENDESK_API_TOKEN")), **kw)
    return r.raise_for_status() or (r.json() if r.content else None)


def send_gmail(to, subject, text):
    raw = base64.urlsafe_b64encode(f"To: {to}\r\nSubject: {subject}\r\nContent-Type: text/plain; charset=utf-8\r\n\r\n{text}".encode()).decode()
    build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users().messages().send(userId="me", body={"raw": raw}).execute()

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    new = [t for t in (page := zd("GET", "/incremental/tickets/cursor.json", params={"cursor": state.get("cursor")} if state.get("cursor") else {"start_time": 0}))["tickets"]
           if t["id"] not in seen and t["status"] == "new"]
    report_fetched(len(new))
    if not new:
        return {"summary": "No new tickets"}
    for t in new:
        label = ai.generate(f"{t['subject']}\n{t['description'][:1500]}", system="Reply yes if this is about a payment, charge, refund or invoice, else no.",
                            max_output_tokens=3).text.strip().lower()
        if label.startswith("yes"):
            zd("PUT", f"/tickets/{t['id']}", json={"ticket": {"priority": "urgent", "additional_tags": ["billing"]}})
            send_gmail("billing@yourcompany.com", f"Payment ticket #{t['id']}: {t['subject']}",
                       f"https://yourcompany.zendesk.com/agent/tickets/{t['id']}\n\n{t['description'][:1500]}")
        seen.add(t["id"])
    state.set("seen", sorted(seen)[-2000:])
    state.set("cursor", page["after_cursor"])
    return {"checked": len(new)}