Score inbound leads, add them to HubSpot and log them in a sheet

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from datetime import datetime, timezone
from clickruntime import on_event, credentials, http, ai, notify
SHEET_ID = "1AbCdEfGhIjKlMnOpQrStUvWxYz"
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 rule_score(lead):
    return 3 + (3 if "@gmail." not in lead["email"] else 0) + (4 if int(lead.get("team_size") or 0) >= 50 else 0)

@on_event
def handle(event):
    lead = event.json or {}
    if not lead.get("email"):
        return {"skipped": "no email"}
    try:
        score = int(ai.generate(f"Score this B2B lead 1-10 for fit and intent. Reply with a number only.\n{str(lead)[:1500]}", max_output_tokens=5).text.strip())
    except (ai.AIError, ValueError):
        score = rule_score(lead)
    c = hs("POST", "/crm/v3/objects/contacts/batch/upsert", json={"inputs": [{"idProperty": "email", "id": lead["email"],
           "properties": {"email": lead["email"], "firstname": lead.get("name", ""), "company": lead.get("company", ""), "lead_score": str(score)}}]})["results"][0]
    row = [datetime.now(timezone.utc).date().isoformat(), lead.get("name"), lead["email"], lead.get("company"), lead.get("source"), score, c["id"]]
    build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).spreadsheets().values().append(
        spreadsheetId=SHEET_ID, range="Leads!A1", valueInputOption="RAW", body={"values": [row]}).execute()
    if score >= 8:
        notify.slack(f"Hot lead ({score}/10): {lead.get('name')} at {lead.get('company')} <{lead['email']}>", channel="#sales")
    return {"score": score, "contact": c["id"]}