Get Reddit brand mentions in Slack with reply drafts

from clickruntime import on_trigger, report_fetched, credentials, http, state, ai, notify

QUERY = '"Acme Helpdesk"'
SCHEMA = {"type": "object", "required": ["sentiment", "reply"], "properties": {
    "sentiment": {"enum": ["positive", "neutral", "negative"]}, "reply": {"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"]]

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    posts = [p for p in reddit("/search", q=QUERY, sort="new", limit=25) if p["id"] not in seen]
    report_fetched(len(posts))
    if not posts:
        return {"mentions": 0}
    icons = {"positive": "🟢", "neutral": "⚪", "negative": "🔴"}
    for p in posts:
        r = ai.generate(f"{p['title']}\n{p['selftext'][:1500]}", json_schema=SCHEMA, max_output_tokens=250,
                        system="Rate sentiment toward Acme Helpdesk and draft a short, helpful reply from the Acme team.").json
        notify.slack(f"{icons[r['sentiment']]} r/{p['subreddit']}: {p['title']}\nhttps://reddit.com{p['permalink']}\n"
                     f"Suggested reply: {r['reply']}", channel="#brand")
    state.set("seen", (list(seen) + [p["id"] for p in posts])[-2000:])
    return {"mentions": len(posts)}