Sort form entries and send only leads to Slack

from clickruntime import on_trigger, credentials, http, notify, state, report_fetched, ai

SITE_ID = "your-netlify-site-id"

def netlify(path, **params):
    resp = http.get(f"https://api.netlify.com/api/v1/sites/{SITE_ID}/{path}", params=params,
                    headers={"Authorization": f"Bearer {credentials.secret('NETLIFY_TOKEN')}"})
    resp.raise_for_status()
    return resp.json()

SCHEMA = {"type": "object", "properties": {"label": {"enum": ["spam", "lead", "support"]}, "summary": {"type": "string"}},
          "required": ["label", "summary"]}

@on_trigger
def run(event):
    last = state.get("last_created_at") or ""
    subs = [s for s in netlify("submissions", per_page=50) if s["created_at"] > last]
    report_fetched(len(subs))
    if not subs:
        return {"new": 0}
    leads = 0
    for s in subs:
        d = s["data"]
        result = ai.generate(f"From: {d.get('name')} <{d.get('email')}>\n{str(d.get('message'))[:1500]}",
                             system="Classify this contact form message and summarise it in one line.",
                             json_schema=SCHEMA, max_output_tokens=80).json
        if result["label"] == "lead":
            notify.slack(f"Lead: {d.get('name')} <{d.get('email')}> - {result['summary']}", channel="#sales")
            leads += 1
    state.set("last_created_at", max(s["created_at"] for s in subs))
    return {"new": len(subs), "leads": leads}