Turn people in your Airtable engagement table into HubSpot contacts

from clickruntime import on_trigger, credentials, http, report_fetched

BASE_ID = "appXXXXXXXXXXXXXX"
TABLE = "Engagement"

def at(method, path="", **kw):
    r = http.request(method, f"https://api.airtable.com/v0/{BASE_ID}/{path}", headers={"Authorization": f"Bearer {credentials.connection('airtable', 'work')}"}, **kw)
    return r.raise_for_status() or r.json()

@on_trigger
def run(event):
    recs = at("GET", TABLE, params={"filterByFormula": "AND({HubSpot ID} = '', {Email} != '')", "pageSize": 100})["records"]
    report_fetched(len(recs))
    if not recs:
        return {"synced": 0}
    inputs = [{"idProperty": "email", "id": r["fields"]["Email"].lower(), "properties": {
        "email": r["fields"]["Email"].lower(), "firstname": r["fields"].get("Name", ""), "company": r["fields"].get("Company", ""),
        "jobtitle": r["fields"].get("Title", ""), "lead_source_detail": "LinkedIn engagement"}} for r in recs]
    resp = http.post("https://api.hubapi.com/crm/v3/objects/contacts/batch/upsert", json={"inputs": inputs},
                     headers={"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"})
    resp.raise_for_status()
    ids = {c["properties"]["email"]: c["id"] for c in resp.json()["results"]}
    updates = [{"id": r["id"], "fields": {"HubSpot ID": ids.get(r["fields"]["Email"].lower(), "")}} for r in recs]
    for i in range(0, len(updates), 10):
        at("PATCH", TABLE, json={"records": updates[i:i + 10]})
    return {"synced": len(ids)}