Turn lead notification emails into HubSpot contacts and deals

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

QUERY = 'from:leads@portal.example newer_than:2d'
SCHEMA = {"type": "object", "properties": {k: {"type": "string"} for k in ["name", "email", "phone", "interest"]}, "required": ["email"]}

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)
    seen = set(state.get("seen") or [])
    ids = [m["id"] for m in g.users().messages().list(userId="me", q=QUERY).execute().get("messages", []) if m["id"] not in seen]
    report_fetched(len(ids))
    if not ids:
        return {"created": 0}
    for mid in ids:
        snippet = g.users().messages().get(userId="me", id=mid, format="full").execute()["snippet"]
        lead = ai.generate("Extract the lead's details from this email:\n" + snippet[:2000], json_schema=SCHEMA, max_output_tokens=150).json
        if lead.get("email"):
            c = hs("POST", "/crm/v3/objects/contacts/batch/upsert", json={"inputs": [{"idProperty": "email", "id": lead["email"],
                   "properties": {"email": lead["email"], "firstname": lead.get("name", ""), "phone": lead.get("phone", "")}}]})["results"][0]
            hs("POST", "/crm/v3/objects/deals", json={"properties": {"dealname": f"{lead.get('name')}: {lead.get('interest', '')}"[:100], "dealstage": "appointmentscheduled", "pipeline": "default"},
               "associations": [{"to": {"id": c["id"]}, "types": [{"associationCategory": "HUBSPOT_DEFINED", "associationTypeId": 3}]}]})
    state.set("seen", (list(seen) + ids)[-500:])
    return {"created": len(ids)}