Publish videos from a Drive folder with AI titles and a Telegram ping

import io
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from googleapiclient.http import MediaIoBaseUpload
from clickruntime import on_trigger, report_fetched, 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"]

FOLDER_ID = "your-drive-folder-id"

@on_trigger
def run(event):
    done = set(state.get("done") or [])
    files = api("drive", "v3").files().list(q=f"'{FOLDER_ID}' in parents and mimeType contains 'video/' and trashed=false", fields="files(id,name)").execute()["files"]
    new = [f for f in files if f["id"] not in done]
    report_fetched(len(new))
    if not new:
        return {"summary": "No new videos"}
    for f in new:
        meta = ai.generate(f"File name: {f['name']}", system="Write a YouTube title (max 90 chars) and a 3-sentence description.",
                           json_schema={"type": "object", "properties": {"title": {"type": "string"}, "description": {"type": "string"}}}, max_output_tokens=250).json
        data = api("drive", "v3").files().get_media(fileId=f["id"]).execute()
        video = api("youtube", "v3").videos().insert(part="snippet,status", body={"snippet": meta, "status": {"privacyStatus": "public"}},
                media_body=MediaIoBaseUpload(io.BytesIO(data), mimetype="video/mp4", resumable=True)).execute()
        tg("sendMessage", chat_id=CHAT_ID, text=f"📺 {meta['title']}\nhttps://youtu.be/{video['id']}")
        done.add(f["id"])
    state.set("done", sorted(done))
    return {"published": len(new)}