Save a daily research digest to Notion

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

NOTION = "https://api.notion.com/v1"

def headers():
    return {"Authorization": f"Bearer {credentials.secret('NOTION_TOKEN')}", "Notion-Version": "2022-06-28"}

def query(db, body=None):
    resp = http.post(f"{NOTION}/databases/{db}/query", headers=headers(), json=body or {})
    resp.raise_for_status()
    return resp.json()["results"]

def title(page, prop="Name"):
    return "".join(t["plain_text"] for t in page["properties"][prop]["title"])

READING = "reading-database-id"
FEEDS = ["https://blog.example.com/feed", "https://news.example.org/rss"]
SCHEMA = {"type": "object", "properties": {"summary": {"type": "string"}, "topic": {"type": "string"}},
          "required": ["summary", "topic"]}

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    new = [e for url in FEEDS for e in feedparser.parse(url).entries[:20] if e.link not in seen]
    for e in new[:20]:
        d = ai.generate(f"Summarise in three lines and give a one-word topic:\n{e.title}\n{e.get('summary', '')[:2000]}",
                        json_schema=SCHEMA, max_output_tokens=200).json
        http.post(f"{NOTION}/pages", headers=headers(), json={"parent": {"database_id": READING}, "properties": {
            "Name": {"title": [{"text": {"content": e.title[:200]}}]},
            "URL": {"url": e.link},
            "Summary": {"rich_text": [{"text": {"content": d["summary"]}}]},
            "Topic": {"select": {"name": d["topic"]}},
        }}).raise_for_status()
        seen.add(e.link)
    state.set("seen", sorted(seen)[-2000:])
    return {"added": min(len(new), 20)}