Post new articles to X and get an email copy

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
import feedparser
from clickruntime import on_trigger, report_fetched, credentials, http, state, ai

FEED, ME = "https://blog.example.com/feed", "me@example.com"

def send_email(subject, text):
    msg = EmailMessage()
    msg["To"], msg["Subject"] = ME, subject
    msg.set_content(text)
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()

@on_trigger
def run(event):
    seen = state.get("seen")
    entries = feedparser.parse(FEED).entries[:20]
    new = [e for e in entries if seen is not None and e.link not in seen]
    report_fetched(len(new))
    if seen is None:
        state.set("seen", [e.link for e in entries])
    if not new:
        return {"posted": 0}
    for e in new:
        text = ai.generate(f"Summarise as an X post under 230 characters:\n{e.title}\n{e.get('summary', '')[:1500]}",
                           max_output_tokens=90).text.strip() + f"\n{e.link}"
        resp = http.post("https://api.x.com/2/tweets", headers={"Authorization": "Bearer " + credentials.connection("x", "main")}, json={"text": text})
        resp.raise_for_status()
        send_email(f"Posted on X: {e.title}", f"{text}\n\nhttps://x.com/i/status/{resp.json()['data']['id']}")
    state.set("seen", (seen + [e.link for e in new])[-300:])
    return {"posted": len(new)}