Draft helpful replies to Reddit posts

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

PRODUCT = "Brightloom, a cold email tool that warms up inboxes and schedules sequences"

@on_trigger
def run(event):
    headers = {"Authorization": "Bearer " + credentials.connection("reddit", "main"), "User-Agent": "clickruntime-replies/1.0"}
    seen = set(state.get("seen") or [])
    posts = [c["data"] for c in http.get("https://oauth.reddit.com/search", headers=headers,
             params={"q": '"cold email tools"', "sort": "new", "t": "day", "limit": 25}).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"}
    drafts = []
    for p in new:
        reply = ai.generate(
            f"Draft a helpful Reddit reply to this post. Mention {PRODUCT} only if it genuinely fits.\n\n"
            f"{p['title']}\n{p['selftext'][:1500]}",
            max_output_tokens=250,
        ).text.strip()
        drafts.append(f"{p['title']}\nhttps://reddit.com{p['permalink']}\n\n{reply}")
        seen.add(p["id"])
    state.set("seen", list(seen)[-1000:])
    notify.email_me(f"{len(drafts)} Reddit reply drafts", "\n\n---\n\n".join(drafts))
    return {"drafts": len(drafts)}