Find Reddit posts from likely customers and email the best ones

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

SEARCH = "https://www.reddit.com/r/smallbusiness+freelance/search.json"
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)

@on_trigger
def run(event):
    posts = [c["data"] for c in http.get(SEARCH, params={"q": "scheduling tool", "restrict_sr": 1, "sort": "new", "t": "day"},
             headers={"User-Agent": "northwind-leads/1.0"}).json()["data"]["children"]]
    known = {r["id"] for r in sb("GET", "reddit_posts?select=id&id=in.(" + ",".join(p["id"] for p in posts) + ")")} if posts else set()
    new = [p for p in posts if p["id"] not in known]
    report_fetched(len(new))
    if not new:
        return {"summary": "Nothing new"}
    lines = "\n".join(f"{i}. {p['title']} — {p['selftext'][:300]}" for i, p in enumerate(new))
    scores = ai.generate(f"Score each post 1-10 for intent to buy a scheduling tool. One integer per line.\n{lines}", max_output_tokens=10 * len(new)).text.split()
    rows = [{"id": p["id"], "title": p["title"], "url": "https://reddit.com" + p["permalink"], "score": int(s)} for p, s in zip(new, scores)]
    sb("POST", "reddit_posts", json=rows)
    hot = [r for r in rows if r["score"] >= 7]
    if hot:
        notify.email_me(f"{len(hot)} hot Reddit leads", "\n\n".join(f"[{r['score']}] {r['title']}\n{r['url']}" for r in hot))
    return {"new": len(rows), "hot": len(hot)}