Upload Drive videos to YouTube with AI titles, descriptions and tags

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, notify

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

FOLDER_ID = "your-drive-folder-id"
STYLE = "Friendly, practical. Brand: Northwind Tools. Include keywords people would search for."

@on_trigger
def run(event):
    drive, done = api("drive", "v3").files(), set(state.get("done") or [])
    files = drive.list(q=f"'{FOLDER_ID}' in parents and mimeType contains 'video/' and trashed=false", fields="files(id,name,description)").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: {f['name']}\nNotes: {f.get('description', '')}", system=f"Write a YouTube title, description and 10 tags. {STYLE}",
                           json_schema={"type": "object", "properties": {"title": {"type": "string"}, "description": {"type": "string"}, "tags": {"type": "array", "items": {"type": "string"}}}}, max_output_tokens=400).json
        media = MediaIoBaseUpload(io.BytesIO(drive.get_media(fileId=f["id"]).execute()), mimetype="video/mp4", resumable=True)
        video = api("youtube", "v3").videos().insert(part="snippet,status", media_body=media,
                body={"snippet": meta, "status": {"privacyStatus": "public"}}).execute()
        notify.email_me(f"On YouTube: {meta['title']}", f"https://youtu.be/{video['id']}\n\nTags: {', '.join(meta['tags'])}")
        done.add(f["id"])
    state.set("done", sorted(done))
    return {"uploaded": len(new)}