Get client follow-up reminders from Notion

from datetime import date, timedelta
from clickruntime import on_trigger, 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"])

CLIENTS = "clients-database-id"
DRAFTS = {
    7: "Hi {name}, it's been a week since we wrapped up. How is everything working on your side?",
    30: "Hi {name}, glad the project is up and running. Would you be happy to write a two-line testimonial we could share?",
}

@on_trigger
def run(event):
    lines = []
    for days, template in DRAFTS.items():
        finished = (date.today() - timedelta(days=days)).isoformat()
        rows = query(CLIENTS, {"filter": {"and": [
            {"property": "Project finished", "date": {"equals": finished}},
            {"property": f"Followed up {days}d", "checkbox": {"equals": False}}]}})
        for r in rows:
            lines.append(f"{title(r)} ({days} days):\n{template.format(name=title(r))}")
            http.patch(f"{NOTION}/pages/{r['id']}", headers=headers(),
                       json={"properties": {f"Followed up {days}d": {"checkbox": True}}}).raise_for_status()
    if lines:
        notify.email_me(f"{len(lines)} client follow-ups", "\n\n".join(lines))
    return {"follow_ups": len(lines)}