Send new Instagram comments to Slack

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

IG = "https://graph.instagram.com/v21.0"

@on_trigger
def run(event):
    token = credentials.connection("instagram", "work")
    seen = set(state.get("seen") or [])
    media = http.get(f"{IG}/me/media", params={"fields": "id,permalink", "limit": 10, "access_token": token}).json()["data"]
    new = [(m, c) for m in media for c in http.get(f"{IG}/{m['id']}/comments", params={
        "fields": "id,text,username", "access_token": token}).json()["data"] if c["id"] not in seen]
    report_fetched(len(new))
    if not new:
        return {"summary": "Nothing new"}
    numbered = "\n".join(f"{i}. {c['text'][:300]}" for i, (_, c) in enumerate(new))
    try:
        labels = ai.generate("For each comment answer yes if it is a question, else no. One per line.\n" + numbered,
                             max_output_tokens=5 * len(new)).text.lower().split()
    except (ai.AINotIncluded, ai.AILimitReached):
        labels = ["yes" if "?" in c["text"] else "no" for _, c in new]
    for (m, c), q in zip(new, labels):
        notify.slack(f"{':question: ' if q == 'yes' else ''}@{c['username']}: {c['text']}\n{m['permalink']}", channel="#social")
    state.set("seen", list(seen | {c["id"] for _, c in new})[-2000:])
    return {"posted": len(new)}