Score every new lead and post the hot ones to Slack

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

IDEAL = "B2B companies of 20-500 staff in logistics or retail, operations or finance roles"
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)

SCHEMA = {"type": "object", "properties": {"score": {"type": "integer"}, "reason": {"type": "string"}}}

@on_event
def handle(event):
    lead = event.json or {}
    if not lead.get("email"):
        return {"skipped": "no email"}
    s = ai.generate(f"Ideal customer: {IDEAL}\nScore this lead 0-100 with a one-line reason:\n"
                    f"{lead.get('company')} | {lead.get('role')} | {lead.get('message', '')[:1000]}", json_schema=SCHEMA, max_output_tokens=80).json
    sb("POST", "leads?on_conflict=email", json={"email": lead["email"].lower(), "name": lead.get("name"), "company": lead.get("company"),
                                                 "role": lead.get("role"), "message": lead.get("message"), **s})
    if s["score"] >= 70:
        notify.slack(f":fire: Hot lead ({s['score']}): {lead.get('name')}, {lead.get('role')} at {lead.get('company')} – {s['reason']}", channel="#sales")
    return s