Get a report on what Reddit says about a topic

from clickruntime import on_event, notify, http, credentials, ai

API = "https://oauth.reddit.com"

@on_event
def handle(event):
    keyword = (event.json or {}).get("keyword", "").strip()
    if not keyword:
        return {"report": False}
    headers = {"Authorization": "Bearer " + credentials.connection("reddit", "main"), "User-Agent": "clickruntime-insights/1.0"}
    posts = http.get(f"{API}/search", headers=headers, params={"q": keyword, "sort": "top", "t": "month", "limit": 15}).json()["data"]["children"]
    chunks = []
    for p in posts:
        post = p["data"]
        thread = http.get(f"{API}/comments/{post['id']}", headers=headers, params={"sort": "top", "limit": 5, "depth": 1}).json()
        comments = [c["data"].get("body", "")[:300] for c in thread[1]["data"]["children"] if c["kind"] == "t1"]
        chunks.append(f"POST: {post['title']}\n{post['selftext'][:500]}\nCOMMENTS: " + " | ".join(comments))
    report = ai.generate(
        f"These are Reddit posts about '{keyword}' from the last 30 days. Give the overall sentiment, "
        "the five most common complaints, and three product ideas.\n\n" + "\n\n".join(chunks),
        max_output_tokens=800,
    ).text
    notify.email_me(f"Reddit insights: {keyword}", report)
    return {"posts": len(posts)}