Get a morning digest of competitors' X posts

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

ACCOUNTS, ME = ["northwindapp", "acmehq"], "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):
    x = {"Authorization": "Bearer " + credentials.connection("x", "main")}
    since = (datetime.now(timezone.utc) - timedelta(days=1)).strftime("%Y-%m-%dT%H:%M:%SZ")
    seen, lines = set(state.get("seen") or []), []
    for handle in ACCOUNTS:
        uid = http.get(f"https://api.x.com/2/users/by/username/{handle}", headers=x).json()["data"]["id"]
        for p in http.get(f"https://api.x.com/2/users/{uid}/tweets", headers=x, params={"start_time": since, "max_results": 20}).json().get("data", []):
            if p["id"] not in seen:
                lines.append(f"@{handle}: {p['text']}")
                seen.add(p["id"])
    digest = ai.generate("\n".join(lines), system="Summarise competitors' posts by company. Put launches and pricing changes first.",
                         max_output_tokens=600).text if lines else "No new posts from your competitors yesterday."
    send_email("Competitor posts on X", digest)
    state.set("seen", list(seen)[-1000:])
    return {"posts": len(lines)}