Save Telegram messages and voice notes to Notion

from clickruntime import on_event, credentials, http, ai

DATABASE_ID = "your-inbox-database-id"

@on_event
def handle(event):
    msg = (event.json or {}).get("message") or {}
    tg = f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}"
    text = msg.get("text") or msg.get("caption") or ""
    if "voice" in msg:
        path = http.get(f"{tg}/getFile", params={"file_id": msg["voice"]["file_id"]}).json()["result"]["file_path"]
        audio = http.get(f"https://api.telegram.org/file/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/{path}").content
        text = http.post("https://api.openai.com/v1/audio/transcriptions", headers={"Authorization": f"Bearer {credentials.secret('OPENAI_API_KEY')}"},
                         files={"file": ("voice.ogg", audio)}, data={"model": "whisper-1"}).json()["text"]
    if not text:
        return {"skipped": True}
    out = ai.generate(f"Give a short title and a 2-3 sentence summary of this note:\n{text[:8000]}", max_output_tokens=200,
                      json_schema={"type": "object", "properties": {"title": {"type": "string"}, "summary": {"type": "string"}}, "required": ["title", "summary"]}).json
    page = http.post("https://api.notion.com/v1/pages", headers={"Authorization": f"Bearer {credentials.connection('notion', 'work')}",
                     "Notion-Version": "2022-06-28"}, json={"parent": {"database_id": DATABASE_ID},
                     "properties": {"Name": {"title": [{"text": {"content": out["title"][:200]}}]}},
                     "children": [{"paragraph": {"rich_text": [{"text": {"content": c}}]}} for c in (out["summary"], text[:1900])]}).json()
    http.post(f"{tg}/sendMessage", json={"chat_id": msg["chat"]["id"], "text": f"Saved: {page['url']}"})
    return {"page": page["id"]}