Post Notion database changes to Slack

from clickruntime import on_trigger, report_fetched, credentials, http, state, 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):
    pages = query(PROJECTS)
    current = {p["id"]: [title(p), (p["properties"]["Status"]["select"] or {}).get("name", "")] for p in pages}
    before = state.get("status")
    if before is None:  # first run: remember what's there
        state.set("status", current)
    changes = [] if before is None else [
        f"New project: {name} ({status})" if pid not in before else f"{name}: {before[pid][1]} → {status}"
        for pid, (name, status) in current.items() if pid not in before or before[pid][1] != status]
    report_fetched(len(changes))
    if not changes:
        return {"summary": "No changes"}
    notify.slack("\n".join(changes), channel="#projects")
    state.set("status", current)
    return {"changes": len(changes)}