Export finished Notion pages to Markdown

from clickruntime import on_trigger, report_fetched, credentials, http, 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"])

BLOG = "blog-database-id"
PREFIX = {"heading_1": "# ", "heading_2": "## ", "heading_3": "### ", "bulleted_list_item": "- ",
          "numbered_list_item": "1. ", "quote": "> ", "paragraph": ""}

def to_markdown(page_id):
    blocks = http.get(f"{NOTION}/blocks/{page_id}/children", headers=headers(), params={"page_size": 100}).json()["results"]
    lines = []
    for b in blocks:
        rich = b.get(b["type"], {}).get("rich_text", [])
        if b["type"] in PREFIX:
            lines.append(PREFIX[b["type"]] + "".join(t["plain_text"] for t in rich))
    return "\n\n".join(lines)

@on_trigger
def run(event):
    pages = query(BLOG, {"filter": {"property": "Status", "select": {"equals": "Ready"}}})
    report_fetched(len(pages))
    if not pages:
        return {"summary": "Nothing ready"}
    for p in pages:
        notify.email_me(f"Exported: {title(p)}", f"# {title(p)}\n\n{to_markdown(p['id'])}")
        http.patch(f"{NOTION}/pages/{p['id']}", headers=headers(),
                   json={"properties": {"Status": {"select": {"name": "Exported"}}}}).raise_for_status()
    return {"exported": len(pages)}