Get a daily digest of new releases for the tools you use

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

REPOS = ["psf/requests", "pallets/flask", "tiangolo/fastapi"]
TELEGRAM_CHAT = "your-telegram-chat-id"

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    new = []
    for repo in REPOS:
        for r in http.get(f"https://api.github.com/repos/{repo}/releases", params={"per_page": 5}).json():
            if not r["draft"] and not r["prerelease"] and str(r["id"]) not in seen:
                new.append((repo, r))
    report_fetched(len(new))
    if not new:
        return {"summary": "No new releases"}
    parts = []
    for repo, r in new:
        try:
            s = ai.generate(f"Summarise in 2-3 lines, flag breaking changes and security fixes:\n{(r['body'] or '')[:4000]}", max_output_tokens=150).text.strip()
        except ai.AIError:
            s = (r["body"] or "")[:300]
        parts.append(f"*{repo} {r['tag_name']}*\n{s}\n{r['html_url']}")
        seen.add(str(r["id"]))
    digest = "Release digest\n\n" + "\n\n".join(parts)
    WebClient(token=credentials.connection("slack", "work")).chat_postMessage(channel="#eng", text=digest)
    http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage", json={"chat_id": TELEGRAM_CHAT, "text": digest[:4000]})
    state.set("seen", sorted(seen)[-1000:])
    return {"summary": f"{len(new)} releases"}