Save form leads to Supabase and reply to them by email

import re
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, ai
SUPABASE = "https://your-project.supabase.co/rest/v1"

def sb(method, path, **kw):
    key = credentials.secret("SUPABASE_KEY")
    r = http.request(method, f"{SUPABASE}/{path}", **kw, headers={"apikey": key, "Authorization": f"Bearer {key}", "Prefer": "return=representation,resolution=merge-duplicates"})
    return r.raise_for_status() or (r.json() if r.content else None)

def send(to, subject, text):
    msg = EmailMessage()
    msg["To"], msg["Subject"] = to, subject
    msg.set_content(text)
    build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()

@on_event
def handle(event):
    lead = event.json or {}
    if not re.fullmatch(r"[^@\s]+@[^@\s]+\.[a-z]{2,}", lead.get("email", ""), re.I):
        return {"skipped": "invalid email"}
    score = 40 + (20 if int(lead.get("employees") or 0) >= 50 else 0) + (20 if lead.get("budget") else 0)
    try:
        score += int(ai.generate(f"Rate 0-20 how ready to buy this enquiry sounds. Reply with a number only.\n{lead.get('message', '')[:1500]}", max_output_tokens=5).text)
    except (ai.AIError, ValueError):
        pass
    sb("POST", "leads", json={**lead, "score": score, "event_id": event.event_id})
    send(lead["email"], "Thanks for getting in touch", f"Hi {lead.get('name', 'there')},\n\nThanks for your message. "
         "We'll reply properly within one working day.\n\nNorthwind team")
    if score >= 70:
        notify.email_me(f"High-value lead: {lead.get('company') or lead['email']} ({score})", f"{lead}")
    return {"score": score}