Announce each new YouTube video on X

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

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

def yt(path, **params):
    return http.get(f"{YT}/{path}", params={**params, "key": credentials.secret("YOUTUBE_API_KEY")}).json().get("items", [])

UPLOADS = "UUxxxxxxxxxxxxxxxxxxxxxx"

@on_trigger
def run(event):
    seen = state.get("seen")
    items = yt("playlistItems", part="snippet", playlistId=UPLOADS, maxResults=5)
    new = [i["snippet"] for i in items if seen is not None and i["snippet"]["resourceId"]["videoId"] not in seen]
    report_fetched(len(new))
    if not new:
        if seen is None:
            state.set("seen", [i["snippet"]["resourceId"]["videoId"] for i in items])
        return {"summary": "No new videos"}
    for s in new:
        vid = s["resourceId"]["videoId"]
        text = ai.generate(f"{s['title']}\n\n{s['description'][:1500]}", system="Write one X post under 240 characters announcing "
                           "this video. Plain, friendly, no more than one hashtag. No link.", max_output_tokens=100).text.strip()
        post = f"{text[:250]} https://youtu.be/{vid}"
        http.post("https://api.x.com/2/tweets", headers={"Authorization": f"Bearer {credentials.connection('x', 'main')}"}, json={"text": post}).raise_for_status()
        notify.email_me("Posted on X", post)
        seen.append(vid)
    state.set("seen", seen[-500:])
    return {"posted": len(new)}