Summarise long comment threads in Notion

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

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"])

PROJECTS = "projects-database-id"

@on_trigger
def run(event):
    since = state.get("since") or "2026-01-01T00:00:00.000Z"
    highlights = []
    for page in query(PROJECTS):
        comments = http.get(f"{NOTION}/comments", headers=headers(), params={"block_id": page["id"]}).json()["results"]
        new = [c for c in comments if c["created_time"] > since]
        if not new:
            continue
        text = "\n".join("".join(t["plain_text"] for t in c["rich_text"]) for c in new)[:6000]
        summary = ai.generate("Summarise these comments in 2-3 lines:\n" + text, max_output_tokens=150).text
        http.post(f"{NOTION}/comments", headers=headers(), json={
            "parent": {"page_id": page["id"]}, "rich_text": [{"text": {"content": "Summary: " + summary}}]}).raise_for_status()
        highlights.append(f"{title(page)}: {summary}")
    state.set("since", event.scheduled_time or since)
    if highlights:
        notify.email_me(f"Comment summaries for {len(highlights)} projects", "\n\n".join(highlights))
    return {"pages": len(highlights)}