Find sales leads on Reddit and Hacker News and track them in Asana

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

SUBREDDITS = ["freelance", "smallbusiness"]
OFFER = "a simple bookkeeping app for freelancers"
PROJECT_ID = "your-asana-project-id"

@on_trigger
def run(event):
    seen = state.get("seen") or []
    posts = []
    for sub in SUBREDDITS:
        for p in http.get(f"https://www.reddit.com/r/{sub}/new.json?limit=25", headers={"User-Agent": "clickruntime"}).json()["data"]["children"]:
            posts.append((p["data"]["id"], p["data"]["title"], p["data"].get("selftext", "")[:800], "https://reddit.com" + p["data"]["permalink"]))
    for h in http.get("https://hn.algolia.com/api/v1/search_by_date", params={"query": "bookkeeping", "tags": "story"}).json()["hits"]:
        posts.append((h["objectID"], h["title"], "", f"https://news.ycombinator.com/item?id={h['objectID']}"))
    new = [p for p in posts if p[0] not in seen]
    report_fetched(len(new))
    if not new:
        return {"summary": "Nothing new"}
    digest = state.get("digest") or []
    for pid, title, body, url in new:
        score = ai.generate(f"I sell {OFFER}. Score 0-10 how likely this poster wants it. Reply with a number only.\n{title}\n{body}", max_output_tokens=5).text.strip()
        if score.isdigit() and int(score) >= 7:
            http.post("https://app.asana.com/api/1.0/tasks", headers={"Authorization": f"Bearer {credentials.secret('ASANA_TOKEN')}"},
                      json={"data": {"name": title[:200], "notes": url, "projects": [PROJECT_ID]}})
            digest.append(f"{title}\n{url}")
    if event.type == "schedule" and datetime.now(timezone.utc).hour < 4 and digest:
        notify.email_me("Today's lead digest", "\n\n".join(digest))
        digest = []
    state.set("digest", digest)
    state.set("seen", (seen + [p[0] for p in new])[-2000:])
    return {"summary": f"{len(new)} checked"}