Draft email replies using the customer's HubSpot record

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from email.utils import parseaddr
from clickruntime import on_trigger, credentials, http, state, ai, notify, report_fetched
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 {})
@on_trigger
def run(event):
    g = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users()
    seen = set(state.get("seen") or [])
    ids = [m["id"] for m in g.messages().list(userId="me", q="in:inbox newer_than:1d").execute().get("messages", []) if m["id"] not in seen]
    report_fetched(len(ids))
    if not ids:
        return {"drafts": 0}
    for mid in ids:
        m = g.messages().get(userId="me", id=mid, format="full").execute()
        h = {x["name"]: x["value"] for x in m["payload"]["headers"]}; sender = parseaddr(h.get("From", ""))[1]
        hit = hs("POST", "/crm/v3/objects/contacts/search", json={"filterGroups": [{"filters": [{"propertyName": "email", "operator": "EQ", "value": sender}]}],
                 "properties": ["firstname", "company", "lifecyclestage", "plan", "renewal_date"]})["results"]
        if hit:
            reply = ai.generate(f"Customer record: {hit[0]['properties']}\nTheir email: {m['snippet'][:1500]}\nDraft a helpful, brief reply.", max_output_tokens=400).text
            msg = EmailMessage(); msg["To"] = sender; msg["Subject"] = "Re: " + h.get("Subject", ""); msg.set_content(reply)
            g.drafts().create(userId="me", body={"message": {"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode(), "threadId": m["threadId"]}}).execute()
            notify.slack(f"Reply draft ready for {hit[0]['properties'].get('company')}: {h.get('Subject')}", channel="#inbox")
    state.set("seen", (list(seen) + ids)[-500:])
    return {"checked": len(ids)}