Publish videos dropped into a Drive folder and get the links on Telegram

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, ai, report_fetched

TO_POST, POSTED, CHAT_ID = "to-post-folder-id", "posted-folder-id", "your-telegram-chat-id"
POST_API = "https://api.your-posting-service.com/v1/posts"

@on_trigger
def run(event):
    token = credentials.connection("google", "work")
    drive = build("drive", "v3", credentials=Credentials(token), cache_discovery=False)
    files = drive.files().list(q=f"'{TO_POST}' in parents and mimeType contains 'video/' and trashed=false",
                               fields="files(id,name,description)").execute()["files"]
    report_fetched(len(files))
    if not files:
        return {"posted": 0}
    bot = f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage"
    for f in files:
        caption = ai.generate(f"Write a short social caption with 3 hashtags for a video called '{f['name']}'. Notes: {f.get('description', '')}",
                              max_output_tokens=120).text
        video = http.get(f"https://www.googleapis.com/drive/v3/files/{f['id']}?alt=media", headers={"Authorization": f"Bearer {token}"}, timeout=120)
        res = http.post(POST_API, headers={"Authorization": f"Bearer {credentials.secret('POSTING_API_KEY')}"},
                        files={"video": (f["name"], video.content)}, data={"caption": caption}, timeout=300).json()
        drive.files().update(fileId=f["id"], addParents=POSTED, removeParents=TO_POST).execute()
        http.post(bot, json={"chat_id": CHAT_ID, "text": f"Posted {f['name']}\n{caption}\n" + "\n".join(res.get("links", []))})
    return {"posted": len(files)}