Sort lead replies in Gmail into Pipedrive follow-ups

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

API = "https://api.pipedrive.com"
SCHEMA = {"type": "object", "properties": {"intent": {"type": "string"}, "urgent": {"type": "boolean"}, "summary": {"type": "string"}}}

@on_trigger
def run(event):
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    seen = set(state.get("seen") or [])
    new = [m["id"] for m in gmail.users().messages().list(userId="me", q="in:inbox newer_than:1d").execute().get("messages", []) if m["id"] not in seen]
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    headers = {"Authorization": f"Bearer {credentials.connection('pipedrive', 'work')}"}
    for mid in new:
        msg = gmail.users().messages().get(userId="me", id=mid, format="metadata", metadataHeaders=["From", "Subject"]).execute()
        sender = {x["name"]: x["value"] for x in msg["payload"]["headers"]}.get("From", "").split("<")[-1].strip("> ")
        found = http.get(f"{API}/api/v2/persons/search", headers=headers, params={"term": sender, "fields": "email", "exact_match": "true"}).json()["data"]["items"]
        deals = http.get(f"{API}/api/v2/deals", headers=headers, params={"person_id": found[0]["item"]["id"], "status": "open"}).json()["data"] if found else []
        if deals:
            r = ai.generate(f"Classify this sales reply by intent and urgency:\n{msg['snippet']}", json_schema=SCHEMA, max_output_tokens=150).json
            http.post(f"{API}/v1/notes", headers=headers, json={"deal_id": deals[0]["id"], "content": f"{r['intent']}: {r['summary']}"})
            http.post(f"{API}/v1/activities", headers=headers, json={"subject": f"Follow up: {r['intent']}", "type": "email", "deal_id": deals[0]["id"]})
            if r["urgent"]:
                notify.slack(f"Hot reply from {sender} on {deals[0]['title']}: {r['summary']}", channel="#sales")
    state.set("seen", (list(seen) + new)[-500:])
    return {"new": len(new)}