Transcribe voice notes sent to Telegram and save them to Drive

import io
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from googleapiclient.http import MediaIoBaseUpload
from clickruntime import on_event, credentials, http, state, ai

FOLDER_ID, ALLOWED_CHAT = "your-transcripts-folder-id", 123456789

@on_event
def handle(event):
    msg = (event.json or {}).get("message", {})
    audio = msg.get("voice") or msg.get("audio")
    if not audio or msg["chat"]["id"] != ALLOWED_CHAT or state.get(f"done:{event.event_id}"):
        return {"skipped": True}
    tg = f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}"
    path = http.get(f"{tg}/getFile", params={"file_id": audio["file_id"]}).json()["result"]["file_path"]
    data = 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": ("audio.ogg", data)}, data={"model": "whisper-1"}).json()["text"]
    summary = ai.generate(f"Summarise this voice note in 3 bullet points:\n{text[:12000]}", max_output_tokens=250).text
    http.post(f"{tg}/sendMessage", json={"chat_id": ALLOWED_CHAT, "text": f"Summary:\n{summary}\n\nTranscript:\n{text[:3500]}"})
    drive = build("drive", "v3", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    drive.files().create(body={"name": f"Voice note {event.received_at[:16]}", "parents": [FOLDER_ID], "mimeType": "application/vnd.google-apps.document"},
                         media_body=MediaIoBaseUpload(io.BytesIO(f"Summary\n{summary}\n\nTranscript\n{text}".encode()), mimetype="text/plain")).execute()
    state.set(f"done:{event.event_id}", True)
    return {"chars": len(text)}