Get a weekly report on what your YouTube viewers say

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, http, credentials, ai, state, notify

YT = "https://www.googleapis.com/youtube/v3"

def yt(path, **params):
    return http.get(f"{YT}/{path}", params={**params, "key": credentials.secret("YOUTUBE_API_KEY")}).json().get("items", [])

def api(name, version):
    return build(name, version, credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)

SHEET_ID, UPLOADS = "your-spreadsheet-id", "UUxxxxxxxxxxxxxxxxxxxxxx"

@on_trigger
def run(event):
    seen, rows = set(state.get("seen") or []), []
    for v in yt("playlistItems", part="contentDetails", playlistId=UPLOADS, maxResults=10):
        vid = v["contentDetails"]["videoId"]
        for c in yt("commentThreads", part="snippet", videoId=vid, maxResults=100, order="time"):
            s = c["snippet"]["topLevelComment"]["snippet"]
            if c["id"] not in seen:
                rows.append([s["publishedAt"][:10], vid, s["authorDisplayName"], s["textOriginal"][:500]])
                seen.add(c["id"])
    if not rows:
        return {"comments": 0}
    api("sheets", "v4").spreadsheets().values().append(spreadsheetId=SHEET_ID, range="Comments!A:D", valueInputOption="RAW", body={"values": rows}).execute()
    report = ai.generate("\n".join(r[3] for r in rows[:400]), system="Summarise these YouTube comments: main themes, common questions, "
                         "complaints, and 5 video ideas. Plain text.", max_output_tokens=700).text
    notify.email_me(f"YouTube comments this week ({len(rows)})", report)
    state.set("seen", sorted(seen)[-5000:])
    return {"comments": len(rows)}