Get the hottest crypto Reddit posts in Telegram

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

SUBS, CHAT, THRESHOLD = ["CryptoCurrency", "ethfinance"], 123456789, 8
SCHEMA = {"type": "object", "properties": {"scores": {"type": "array", "items": {"type": "object",
          "properties": {"n": {"type": "integer"}, "score": {"type": "integer"}, "why": {"type": "string"}}}}}}

def reddit(path, **params):
    headers = {"Authorization": "Bearer " + credentials.connection("reddit", "main"), "User-Agent": "clickruntime/1.0"}
    return [c["data"] for c in http.get(f"https://oauth.reddit.com{path}", headers=headers, params=params).json()["data"]["children"]]

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    posts = [p for s in SUBS for p in reddit(f"/r/{s}/rising", limit=25) if p["id"] not in seen]
    report_fetched(len(posts))
    if not posts:
        return {"sent": 0}
    listing = "\n".join(f"{i}. {p['title']} | {p['selftext'][:200]}" for i, p in enumerate(posts))
    scores = ai.generate(listing, json_schema=SCHEMA, max_output_tokens=800,
                         system="Score each post 1-10 for market significance (security, exchanges, regulation) with a one-line reason.").json["scores"]
    hot = [s for s in scores if s["score"] >= THRESHOLD and 0 <= s["n"] < len(posts)]
    for s in hot:
        p = posts[s["n"]]
        http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage",
                  json={"chat_id": CHAT, "text": f"🔥 {s['score']}/10 {p['title']}\n{s['why']}\nhttps://reddit.com{p['permalink']}"})
    state.set("seen", (list(seen) + [p["id"] for p in posts])[-3000:])
    return {"sent": len(hot)}