Upload finished Shorts to YouTube and hear about it on Telegram

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

def api(name, version):
    return build(name, version, credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)

CHAT_ID = "123456789"

def tg(method, **params):
    r = http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/{method}", json=params)
    return r.raise_for_status() or r.json()["result"]

@on_event
def handle(event):
    job = event.json or {}
    if state.get(f"done:{event.event_id}"):
        return {"duplicate": True}
    meta = ai.generate(f"Topic: {job.get('topic', '')}\nScript: {job.get('script', '')[:2000]}",
                       system="Write a YouTube Shorts title (max 70 chars) and a 2-line description ending with 3 hashtags including #Shorts.",
                       json_schema={"type": "object", "properties": {"title": {"type": "string"}, "description": {"type": "string"}}}, max_output_tokens=200).json
    media = MediaIoBaseUpload(io.BytesIO(http.get(job["video_url"], timeout=120).content), mimetype="video/mp4", resumable=True)
    video = api("youtube", "v3").videos().insert(part="snippet,status", media_body=media, body={
        "snippet": {"title": meta["title"], "description": meta["description"]}, "status": {"privacyStatus": "public"}}).execute()
    tg("sendMessage", chat_id=CHAT_ID, text=f"✅ Live: {meta['title']}\nhttps://youtube.com/shorts/{video['id']}")
    state.set(f"done:{event.event_id}", video["id"])
    return {"video": video["id"]}