Find Reddit posts asking for what you sell

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

SUBS = "smallbusiness+Entrepreneur"

@on_trigger
def run(event):
    headers = {"Authorization": "Bearer " + credentials.connection("reddit", "main"), "User-Agent": "clickruntime-leads/1.0"}
    seen = set(state.get("seen") or [])
    posts = [c["data"] for c in http.get(f"https://oauth.reddit.com/r/{SUBS}/new", headers=headers, params={"limit": 50}).json()["data"]["children"]]
    new = [p for p in posts if p["id"] not in seen]
    report_fetched(len(new))
    if not new:
        return {"summary": "No new posts"}
    matches = []
    for p in new:
        result = ai.generate(
            "Score 0-10 how likely this person needs an invoicing tool for freelancers, then give a one-line reason.\n\n"
            f"{p['title']}\n{p['selftext'][:1500]}",
            json_schema={"type": "object", "properties": {"score": {"type": "integer"}, "reason": {"type": "string"}}, "required": ["score", "reason"]},
            max_output_tokens=80,
        ).json
        if result["score"] >= 7:
            matches.append(f"[{result['score']}] {p['title']}\n{result['reason']}\nhttps://reddit.com{p['permalink']}")
        seen.add(p["id"])
    state.set("seen", list(seen)[-1000:])
    if matches:
        notify.email_me(f"{len(matches)} Reddit leads", "\n\n".join(matches))
    return {"checked": len(new), "leads": len(matches)}