Find Reddit threads for your new YouTube videos

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

CHANNEL_ID = "UCxxxxxxxxxxxxxxxx"

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):
    since = (datetime.now(timezone.utc) - timedelta(days=1)).strftime("%Y-%m-%dT%H:%M:%SZ")
    videos = http.get("https://www.googleapis.com/youtube/v3/search", params={"key": credentials.secret("YOUTUBE_API_KEY"),
        "channelId": CHANNEL_ID, "part": "snippet", "type": "video", "order": "date", "publishedAfter": since}).json()["items"]
    if not videos:
        return {"videos": 0}
    sections = []
    for v in videos:
        title = v["snippet"]["title"]
        threads = reddit("/search", q=title, sort="relevance", t="month", limit=10)
        listing = "\n".join(f"- {t['title']} https://reddit.com{t['permalink']}" for t in threads)
        picks = ai.generate(f"Video: {title}\nhttps://youtu.be/{v['id']['videoId']}\nThreads:\n{listing}", max_output_tokens=700,
                            system="Pick up to 3 threads where this video genuinely helps. For each: link and a helpful comment that answers first.").text
        sections.append(f"{title}\n{picks}")
    notify.email_me("Reddit threads for your new videos", "\n\n".join(sections))
    return {"videos": len(videos)}