Turn videos and docs into a blog post and an X thread

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

FEED, SITE = "https://www.youtube.com/feeds/videos.xml?channel_id=UCxxxxxxxx", "https://blog.example.com"
SCHEMA = {"type": "object", "required": ["title", "html", "thread"], "properties": {"title": {"type": "string"},
          "html": {"type": "string"}, "thread": {"type": "array", "items": {"type": "string"}}}}

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    new = [e for e in feedparser.parse(FEED).entries[:5] if e.link not in seen]
    report_fetched(len(new))
    if not new:
        return {"done": 0}
    x = {"Authorization": "Bearer " + credentials.connection("x", "main")}
    for e in new:
        out = ai.generate(f"{e.title}\n{e.get('summary', '')[:5000]}", json_schema=SCHEMA, max_output_tokens=2048,
                          system="Write a blog post (title, HTML body) and an X thread of 4 posts under 260 characters each.").json
        link = http.post(f"{SITE}/wp-json/wp/v2/posts", auth=("editor", credentials.secret("WP_APP_PASSWORD")),
                         json={"title": out["title"], "content": out["html"], "status": "publish"}).json()["link"]
        reply_to = None
        for text in out["thread"][:4] + [f"Full write-up: {link}"]:
            body = {"text": text[:280], **({"reply": {"in_reply_to_tweet_id": reply_to}} if reply_to else {})}
            reply_to = http.post("https://api.x.com/2/tweets", headers=x, json=body).json()["data"]["id"]
        seen.add(e.link)
    state.set("seen", list(seen)[-300:])
    return {"done": len(new)}