Write descriptions, tags and chapters for new uploads

from clickruntime import on_trigger, credentials, http, state, ai, notify, report_fetched

YT = "https://www.googleapis.com/youtube/v3"

@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.connection('google', 'work')}"}
    uploads = http.get(f"{YT}/channels", headers=h, params={"part": "contentDetails", "mine": "true"}).json()["items"][0]["contentDetails"]["relatedPlaylists"]["uploads"]
    items = http.get(f"{YT}/playlistItems", headers=h, params={"part": "contentDetails", "playlistId": uploads, "maxResults": 10}).json()["items"]
    done = state.get("done") or []
    new = [i["contentDetails"]["videoId"] for i in items if i["contentDetails"]["videoId"] not in done]
    report_fetched(len(new))
    if not new:
        return {"summary": "Nothing new"}
    for vid in new:
        caps = http.get(f"{YT}/captions", headers=h, params={"part": "snippet", "videoId": vid}).json()["items"]
        if not caps:
            continue
        srt = http.get(f"{YT}/captions/{caps[0]['id']}", headers=h, params={"tfmt": "srt"}).text[:20000]
        meta = ai.generate(srt, system="From these captions write a YouTube description with timestamped chapters, and up to 10 tags.",
                           json_schema={"type": "object", "properties": {"description": {"type": "string"}, "tags": {"type": "array", "items": {"type": "string"}}}},
                           max_output_tokens=900).json
        video = http.get(f"{YT}/videos", headers=h, params={"part": "snippet", "id": vid}).json()["items"][0]
        snippet = {**video["snippet"], "description": meta["description"], "tags": meta["tags"]}
        http.put(f"{YT}/videos", headers=h, params={"part": "snippet"}, json={"id": vid, "snippet": snippet})
        notify.email_me(f"Updated: {snippet['title']}", f"{meta['description']}\n\nTags: {', '.join(meta['tags'])}")
        done.append(vid)
    state.set("done", done[-500:])
    return {"updated": len(new)}