Welcome new customers when a HubSpot deal is won

import base64, time
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, ai, report_fetched
CSM_OWNER_ID = "12345678"
def hs(method, path, **kw):
    r = http.request(method, f"https://api.hubapi.com{path}", headers={"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"}, **kw)
    return r.raise_for_status() or (r.json() if r.content else {})
def send(to, subject, body):
    msg = EmailMessage(); msg["To"] = to; msg["Subject"] = subject; msg.set_content(body)
    build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
@on_trigger
def run(event):
    since = str(state.get("since") or int((time.time() - 86400) * 1000))
    deals = hs("POST", "/crm/v3/objects/deals/search", json={"filterGroups": [{"filters": [{"propertyName": "dealstage", "operator": "EQ", "value": "closedwon"},
               {"propertyName": "closedate", "operator": "GTE", "value": since}]}], "properties": ["dealname"], "limit": 50})["results"]
    done = set(state.get("done") or []); deals = [d for d in deals if d["id"] not in done]
    report_fetched(len(deals))
    if not deals: return {"welcomed": 0}
    for d in deals:
        hs("PATCH", f"/crm/v3/objects/deals/{d['id']}", json={"properties": {"hubspot_owner_id": CSM_OWNER_ID}})
        for link in hs("GET", f"/crm/v4/objects/deals/{d['id']}/associations/contacts").get("results", [])[:1]:
            c = hs("GET", f"/crm/v3/objects/contacts/{link['toObjectId']}?properties=email,firstname")["properties"]
            body = ai.generate(f"Write a short, warm welcome email to {c.get('firstname')}, who just bought {d['properties']['dealname']}. Say a kickoff call comes next.", max_output_tokens=300).text
            send(c["email"], "Welcome aboard", body)
        done.add(d["id"])
    state.set("done", list(done)[-500:]); state.set("since", int(time.time() * 1000) - 3600000)
    return {"welcomed": len(deals)}