Add, list and complete Notion tasks from Telegram

from datetime import date
from clickruntime import on_event, credentials, http, ai

DB, ALLOWED_CHAT = "your-database-id", 123456789
SCHEMA = {"type": "object", "properties": {"action": {"enum": ["add", "list", "done"]}, "title": {"type": "string"},
          "due": {"type": "string"}, "priority": {"enum": ["High", "Medium", "Low"]}}, "required": ["action"]}

@on_event
def handle(event):
    msg = (event.json or {}).get("message") or {}
    if msg.get("chat", {}).get("id") != ALLOWED_CHAT or not msg.get("text"):
        return {"skipped": True}
    nh = {"Authorization": f"Bearer {credentials.connection('notion', 'work')}", "Notion-Version": "2022-06-28"}
    intent = ai.generate(f"Today is {date.today()}. Parse this task request (due as YYYY-MM-DD): {msg['text']}", json_schema=SCHEMA, max_output_tokens=120).json
    if intent["action"] == "add":
        props = {"Name": {"title": [{"text": {"content": intent.get("title", msg["text"])}}]}, "Priority": {"select": {"name": intent.get("priority", "Medium")}}}
        if intent.get("due"):
            props["Due"] = {"date": {"start": intent["due"]}}
        http.post("https://api.notion.com/v1/pages", headers=nh, json={"parent": {"database_id": DB}, "properties": props})
        reply = f"Added: {intent.get('title')}"
    else:
        open_tasks = http.post(f"https://api.notion.com/v1/databases/{DB}/query", headers=nh,
                               json={"filter": {"property": "Done", "checkbox": {"equals": False}}}).json()["results"]
        names = {t["id"]: t["properties"]["Name"]["title"][0]["plain_text"] for t in open_tasks if t["properties"]["Name"]["title"]}
        if intent["action"] == "list":
            reply = "\n".join(f"- {n}" for n in names.values()) or "Nothing open."
        else:
            match = next((i for i, n in names.items() if intent.get("title", "").lower() in n.lower()), None)
            if match:
                http.patch(f"https://api.notion.com/v1/pages/{match}", headers=nh, json={"properties": {"Done": {"checkbox": True}}})
            reply = f"Done: {names[match]}" if match else "Couldn't find that task."
    http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage", json={"chat_id": ALLOWED_CHAT, "text": reply})
    return {"action": intent["action"]}