Create a Notion onboarding page when an Airtable lead is won

from clickruntime import on_trigger, credentials, http, notify, report_fetched

BASE, TABLE, NOTION_DB = "your-airtable-base-id", "Clients", "your-notion-database-id"
CHECKLIST = ["Send welcome email", "Book kickoff call", "Collect access and logins", "Share project plan"]

@on_trigger
def run(event):
    at = {"Authorization": f"Bearer {credentials.secret('AIRTABLE_TOKEN')}"}
    url = f"https://api.airtable.com/v0/{BASE}/{TABLE}"
    records = http.get(url, headers=at, params={"filterByFormula": "AND({Status}='Won', {Notion URL}='')"}).json()["records"]
    report_fetched(len(records))
    if not records:
        return {"new": 0}
    n = {"Authorization": f"Bearer {credentials.connection('notion', 'work')}", "Notion-Version": "2022-06-28"}
    made = []
    for r in records:
        f = r["fields"]
        todos = [{"object": "block", "type": "to_do", "to_do": {"rich_text": [{"text": {"content": t}}]}} for t in CHECKLIST]
        info = {"object": "block", "type": "paragraph", "paragraph": {"rich_text": [{"text": {"content": f"Contact: {f.get('Contact', '')} {f.get('Email', '')}"}}]}}
        page = http.post("https://api.notion.com/v1/pages", headers=n, json={"parent": {"database_id": NOTION_DB},
                         "properties": {"Name": {"title": [{"text": {"content": f.get("Name", "New client")}}]}}, "children": [info] + todos}).json()
        http.patch(f"{url}/{r['id']}", headers=at, json={"fields": {"Notion URL": page["url"]}})
        made.append(f"{f.get('Name', '')}: {page['url']}")
    notify.email_me(f"{len(made)} new onboarding page(s)", "\n".join(made))
    return {"created": len(made)}