Add form leads to HubSpot and email the good ones

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_event, credentials, http, notify

def gmail():
    return build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)

def send(g, to, subject, body):
    msg = EmailMessage(); msg["To"] = to; msg["Subject"] = subject; msg.set_content(body)
    g.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()

@on_event
def handle(event):
    lead = event.json or {}
    email = (lead.get("email") or "").strip().lower()
    if not email:
        return {"skipped": "no email"}
    props = {"email": email, "firstname": lead.get("name", ""), "company": lead.get("company", "")}
    r = http.post("https://api.hubapi.com/crm/v3/objects/contacts/batch/upsert",
                  headers={"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"},
                  json={"inputs": [{"idProperty": "email", "id": email, "properties": props}]})
    r.raise_for_status()
    qualified = "@gmail." not in email and int(lead.get("team_size") or 0) >= 10
    if qualified:
        send(gmail(), email, "Thanks for getting in touch",
             f"Hi {props['firstname'] or 'there'},\n\nThanks for your enquiry. When suits you for a quick call this week?")
        notify.email_me(f"Qualified lead: {props['company']}", f"{props['firstname']} <{email}> was emailed.")
    return {"qualified": qualified}