Get a morning priorities email from Notion and Gmail

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

DB_ID = "your-notion-tasks-database-id"

@on_trigger
def run(event):
    n = {"Authorization": f"Bearer {credentials.connection('notion', 'work')}", "Notion-Version": "2022-06-28"}
    pages = http.post(f"https://api.notion.com/v1/databases/{DB_ID}/query", headers=n,
                      json={"filter": {"property": "Status", "status": {"does_not_equal": "Done"}}, "page_size": 50}).json()["results"]
    tasks = [p["properties"]["Name"]["title"][0]["plain_text"] for p in pages if p["properties"]["Name"]["title"]]
    g = {"Authorization": f"Bearer {credentials.connection('google', 'work')}"}
    base = "https://gmail.googleapis.com/gmail/v1/users/me/messages"
    ids = http.get(base, headers=g, params={"q": "is:unread is:important newer_than:2d", "maxResults": 20}).json().get("messages", [])
    emails = []
    for m in ids:
        hdrs = http.get(f"{base}/{m['id']}", headers=g, params={"format": "metadata", "metadataHeaders": ["From", "Subject"]}).json()["payload"]["headers"]
        emails.append(" | ".join(h["value"] for h in hdrs))
    listing = "Tasks:\n" + "\n".join(tasks) + "\n\nEmails:\n" + "\n".join(emails)
    try:
        body = ai.generate(listing, system="Write a short morning brief: top 3 priorities, emails needing a reply today, what can wait.", max_output_tokens=500).text
    except ai.AIError:
        body = listing
    notify.email_me(f"Today: {len(tasks)} open tasks, {len(emails)} important emails", body)
    return {"tasks": len(tasks), "emails": len(emails)}