Save relevant RSS articles to Notion with Telegram alerts

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

FEEDS = ["https://example.com/feed.xml", "https://blog.example.org/rss"]
TOPICS, DATABASE_ID, CHAT_ID = "retail media, privacy regulation, B2B pricing", "your-database-id", "your-chat-id"
SCHEMA = {"type": "array", "items": {"type": "object", "properties": {"n": {"type": "integer"}, "score": {"type": "integer"},
          "summary": {"type": "string"}}, "required": ["n", "score", "summary"]}}

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    items = [e for f in FEEDS for e in feedparser.parse(http.get(f).content).entries if e.link not in seen]
    report_fetched(len(items))
    if not items:
        return {"summary": "Nothing new"}
    listing = "\n".join(f"{i}. {e.title}: {e.get('summary', '')[:300]}" for i, e in enumerate(items[:40]))
    picks = ai.generate(f"Topics: {TOPICS}\nReturn only articles relevant to the topics, with a 0-10 score and one-sentence summary:\n{listing}",
                        max_output_tokens=1500, json_schema=SCHEMA).json
    for p in picks:
        e = items[p["n"]]
        http.post("https://api.notion.com/v1/pages", headers={"Authorization": f"Bearer {credentials.connection('notion', 'work')}",
                  "Notion-Version": "2022-06-28"}, json={"parent": {"database_id": DATABASE_ID}, "properties": {
                  "Name": {"title": [{"text": {"content": e.title[:200]}}]}, "URL": {"url": e.link},
                  "Summary": {"rich_text": [{"text": {"content": p["summary"]}}]}, "Score": {"number": p["score"]}}})
    top = [f"{items[p['n']].title}\n{items[p['n']].link}" for p in sorted(picks, key=lambda p: -p["score"])[:3] if p["score"] >= 7]
    if top:
        http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage",
                  json={"chat_id": CHAT_ID, "text": "Worth reading:\n\n" + "\n\n".join(top)})
    state.set("seen", (list(seen) + [e.link for e in items])[-2000:])
    return {"new": len(items), "saved": len(picks)}