Upload queued videos to YouTube on a schedule

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

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

@on_event
def queue(event):
    q = state.get("queue") or []
    q.append({"url": event.json["url"], "topic": event.json.get("topic", "")})
    state.set("queue", q)
    return {"queued": len(q)}

@on_trigger
def upload_next(event):
    q = state.get("queue") or []
    if not q:
        return {"summary": "Queue empty"}
    item = q.pop(0)
    meta = ai.generate(f"Topic: {item['topic']}\nFile: {item['url']}", system="Write a YouTube title (max 80 chars) and a 3-sentence description.",
                       json_schema={"type": "object", "properties": {"title": {"type": "string"}, "description": {"type": "string"}}}, max_output_tokens=300).json
    h = {"Authorization": f"Bearer {credentials.connection('google', 'work')}"}
    session = http.post("https://www.googleapis.com/upload/youtube/v3/videos", headers=h,
                        params={"uploadType": "resumable", "part": "snippet,status"},
                        json={"snippet": meta, "status": {"privacyStatus": "private"}})
    video = http.put(session.headers["Location"], headers=h, data=http.get(item["url"], timeout=300).content, timeout=600).json()
    http.post(f"{YT}/playlistItems", headers=h, params={"part": "snippet"},
              json={"snippet": {"playlistId": PLAYLIST_ID, "resourceId": {"kind": "youtube#video", "videoId": video["id"]}}})
    state.set("queue", q)
    notify.email_me(f"Uploaded: {meta['title']}", f"https://youtu.be/{video['id']}\n{len(q)} left in the queue.")
    return {"video": video["id"], "left": len(q)}