Message a video idea to Telegram and get the finished video back

from googleapiclient.http import MediaInMemoryUpload
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_event, credentials, http, ai

MY_CHAT_ID, SHORTS_ID = 123456789, "your-shorts-folder-id"
VIDEO_API = "https://api.your-video-service.com/v1/videos"

@on_event
def handle(event):
    msg = event.event.get("message", {})
    if msg.get("chat", {}).get("id") != MY_CHAT_ID or not msg.get("text"):
        return {"ignored": True}
    bot = f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}"
    http.post(f"{bot}/sendMessage", json={"chat_id": MY_CHAT_ID, "text": "Making your video..."})
    prompt = ai.generate(f"Write a detailed prompt for a 15-second vertical video. Idea: {msg['text']}", max_output_tokens=300).text
    job = http.post(VIDEO_API, json={"prompt": prompt}, headers={"Authorization": f"Bearer {credentials.secret('VIDEO_API_KEY')}"},
                    timeout=300).json()
    video = http.get(job["video_url"], timeout=120).content
    drive = build("drive", "v3", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    drive.files().create(body={"name": f"{msg['text'][:50]}.mp4", "parents": [SHORTS_ID]},
                         media_body=MediaInMemoryUpload(video, mimetype="video/mp4")).execute()
    http.post(f"{bot}/sendVideo", data={"chat_id": MY_CHAT_ID, "caption": msg["text"][:200]},
              files={"video": ("short.mp4", video)}, timeout=120)
    return {"sent": True}