Get a morning email of Reddit and YouTube mentions

from datetime import datetime, timedelta, timezone
from clickruntime import on_trigger, credentials, http, state, ai, notify

TOPIC = "Northwind Bikes"

def reddit(path, **params):
    headers = {"Authorization": "Bearer " + credentials.connection("reddit", "main"), "User-Agent": "clickruntime/1.0"}
    return [c["data"] for c in http.get(f"https://oauth.reddit.com{path}", headers=headers, params=params).json()["data"]["children"]]

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    since = (datetime.now(timezone.utc) - timedelta(days=1)).strftime("%Y-%m-%dT%H:%M:%SZ")
    posts = [p for p in reddit("/search", q=f'"{TOPIC}"', sort="new", t="day", limit=25) if p["id"] not in seen]
    videos = [v for v in http.get("https://www.googleapis.com/youtube/v3/search", params={"key": credentials.secret("YOUTUBE_API_KEY"),
              "q": TOPIC, "part": "snippet", "type": "video", "publishedAfter": since, "maxResults": 20}).json()["items"]
              if v["id"]["videoId"] not in seen]
    lines = [f"Reddit: {p['title']} https://redd.it/{p['id']}" for p in posts]
    lines += [f"YouTube: {v['snippet']['title']} – {v['snippet']['description'][:200]} https://youtu.be/{v['id']['videoId']}" for v in videos]
    if not lines:
        notify.email_me(f"{TOPIC}: no new mentions", "Nothing new on Reddit or YouTube yesterday.")
        return {"mentions": 0}
    summary = ai.generate("\n".join(lines), max_output_tokens=700,
                          system=f"Summarise what was said about {TOPIC}, give overall sentiment, and list each item with its link.").text
    notify.email_me(f"{TOPIC}: {len(lines)} new mentions", summary)
    state.set("seen", (list(seen) + [p["id"] for p in posts] + [v["id"]["videoId"] for v in videos])[-3000:])
    return {"mentions": len(lines)}