Set reminders by Telegram message and get them on time

from datetime import datetime, timezone
from clickruntime import on_event, on_trigger, credentials, http, ai, report_fetched
BASE_ID, CHAT_ID, TZ = "appXXXXXXXXXXXXXX", 123456789, "Europe/London"
API = f"https://api.airtable.com/v0/{BASE_ID}/Reminders"
SCHEMA = {"type": "object", "properties": {"what": {"type": "string"}, "due_utc": {"type": "string"}}, "required": ["what", "due_utc"]}
def headers(): return {"Authorization": f"Bearer {credentials.connection('airtable', 'work')}"}
def send(text): http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage", json={"chat_id": CHAT_ID, "text": text})
@on_event
def handle(event):
    msg = (event.json or {}).get("message") or {}
    if msg.get("chat", {}).get("id") != CHAT_ID or not msg.get("text"):
        return {"ignored": True}
    r = ai.generate(f"Now (UTC): {datetime.now(timezone.utc).isoformat(timespec='minutes')}. Time zone: {TZ}.\nMessage: {msg['text']}",
                    system="Extract the reminder text and due time as ISO 8601 UTC. Leave due_utc empty if unclear.",
                    json_schema=SCHEMA, max_output_tokens=100).json
    if not r["due_utc"]:
        return send("Sorry, when should I remind you?") or {"saved": False}
    http.post(API, headers=headers(), json={"records": [{"fields": {"Reminder": r["what"], "Due": r["due_utc"], "Status": "Pending"}}]}).raise_for_status()
    send(f"Saved: {r['what']} at {r['due_utc']} UTC")
    return {"saved": True}
@on_trigger
def run(event):
    due = http.get(API, headers=headers(), params={"filterByFormula": "AND({Status}='Pending', IS_BEFORE({Due}, NOW()))"}).json()["records"]
    report_fetched(len(due))
    if not due:
        return {"sent": 0}
    for rec in due:
        send(f"Reminder: {rec['fields'].get('Reminder')}")
        http.patch(API, headers=headers(), json={"records": [{"id": rec["id"], "fields": {"Status": "Done"}}]}).raise_for_status()
    return {"sent": len(due)}