Score new leads and assign them to a rep from your Airtable team table

from clickruntime import on_event, credentials, http, ai, state

BASE_ID = "appXXXXXXXXXXXXXX"
SCHEMA = {"type": "object", "properties": {"score": {"type": "integer"}, "size": {"type": "string", "enum": ["SMB", "Mid-market", "Enterprise"]}}, "required": ["score", "size"]}

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_event
def handle(event):
    lead = event.json or {}
    if not lead.get("email"):
        return {"skipped": "no email"}
    res = ai.generate(f"Score this lead 1-10 and estimate its size.\n{str(lead)[:1500]}", json_schema=SCHEMA, max_output_tokens=60).json
    region = lead.get("region", "EMEA")
    reps = at("GET", "Sales team", params={"filterByFormula": f"AND({{Active}}, {{Region}} = '{region}', FIND('{res['size']}', ARRAYJOIN({{Sizes}})))"})["records"]
    counts = state.get("counts") or {}
    rep = min(reps, key=lambda r: counts.get(r["id"], 0)) if reps else None
    props = {"email": lead["email"], "firstname": lead.get("name", ""), "company": lead.get("company", ""), "lead_score": str(res["score"])}
    if rep:
        props["hubspot_owner_id"] = rep["fields"]["HubSpot owner ID"]
        counts[rep["id"]] = counts.get(rep["id"], 0) + 1
        state.set("counts", counts)
    r = http.post("https://api.hubapi.com/crm/v3/objects/contacts", json={"properties": props},
                  headers={"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"})
    r.raise_for_status()
    at("POST", "Lead log", json={"records": [{"fields": {"Email": lead["email"], "Score": res["score"], "Size": res["size"],
       "Rep": rep["fields"]["Name"] if rep else "Unassigned", "HubSpot ID": r.json()["id"]}}]})
    return {"score": res["score"], "rep": rep["fields"]["Name"] if rep else None}