Find Reddit threads where your videos would help

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

TOPICS, SHEET_ID, RANGE = ["espresso grinder", "espresso dialing in"], "your-spreadsheet-id", "Threads!A:D"
SCHEMA = {"type": "object", "required": ["video", "comment"], "properties": {"video": {"type": "string"}, "comment": {"type": "string"}}}

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"]]

def append_rows(rows):
    sheets = build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    sheets.spreadsheets().values().append(spreadsheetId=SHEET_ID, range=RANGE, valueInputOption="RAW", body={"values": rows}).execute()

@on_trigger
def run(event):
    sheets = build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    videos = sheets.spreadsheets().values().get(spreadsheetId=SHEET_ID, range="Videos!A2:B").execute().get("values", [])
    seen = set(state.get("seen") or [])
    posts = [p for t in TOPICS for p in reddit("/search", q=t, sort="new", t="day", limit=15) if p["id"] not in seen]
    rows = []
    for p in posts:
        m = ai.generate(f"Videos:\n{videos}\n\nQuestion: {p['title']}\n{p['selftext'][:800]}", json_schema=SCHEMA, max_output_tokens=250,
                        system="Pick the video URL that answers this, or 'none'. Draft a comment that answers first, then mentions the video.").json
        if m["video"] != "none":
            rows.append([p["subreddit"], "https://reddit.com" + p["permalink"], m["video"], m["comment"]])
    if rows:
        append_rows(rows)
        notify.email_me(f"{len(rows)} Reddit threads for your videos", "\n\n".join(f"{r[1]}\n{r[3]}" for r in rows))
    state.set("seen", (list(seen) + [p["id"] for p in posts])[-2000:])
    return {"matches": len(rows)}