Collect Reddit pain points as business ideas

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

SUBS, SHEET_ID, RANGE = ["smallbusiness", "freelance", "Entrepreneur"], "your-spreadsheet-id", "Opportunities!A:D"
SCHEMA = {"type": "object", "properties": {"ideas": {"type": "array", "items": {"type": "object",
          "properties": {"n": {"type": "integer"}, "summary": {"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):
    seen = set(state.get("seen") or [])
    posts = [p for s in SUBS for p in reddit(f"/r/{s}/new", limit=50) if p["id"] not in seen]
    if not posts:
        return {"added": 0}
    listing = "\n".join(f"{i}. {p['title']} | {p['selftext'][:400]}" for i, p in enumerate(posts))
    ideas = ai.generate(listing, json_schema=SCHEMA, max_output_tokens=1200,
                        system="Return only posts describing a specific problem people would pay to solve, with a one-line summary.").json["ideas"]
    rows = [[posts[i["n"]]["subreddit"], i["summary"], posts[i["n"]]["title"], "https://reddit.com" + posts[i["n"]]["permalink"]]
            for i in ideas if 0 <= i["n"] < len(posts)]
    if rows:
        append_rows(rows)
    state.set("seen", (list(seen) + [p["id"] for p in posts])[-3000:])
    return {"checked": len(posts), "added": len(rows)}