Approve replies to Google reviews from Slack

from slack_sdk import WebClient
from clickruntime import on_trigger, credentials, http, state, ai

LOCATION = "accounts/1234567890/locations/9876543210"
CHANNEL = "C0123REVIEWS"
SCHEMA = {"type": "object", "properties": {"mood": {"type": "string"}, "reply": {"type": "string"}}}

@on_trigger
def run(event):
    auth = {"Authorization": f"Bearer {credentials.connection('google', 'work')}"}
    slack, pending = WebClient(token=credentials.connection("slack", "work")), state.get("pending") or {}
    for ts, p in list(pending.items()):
        msg = slack.reactions_get(channel=CHANNEL, timestamp=ts)["message"]
        if any(r["name"] == "white_check_mark" for r in msg.get("reactions", [])):
            http.put(f"https://mybusiness.googleapis.com/v4/{p['review']}/reply", headers=auth, json={"comment": p["reply"]})
            slack.chat_postMessage(channel=CHANNEL, thread_ts=ts, text="Reply published on Google.")
            del pending[ts]
    reviews = http.get(f"https://mybusiness.googleapis.com/v4/{LOCATION}/reviews", headers=auth).json().get("reviews", [])
    last = state.get("last") or ""
    for r in [r for r in reviews if r["createTime"] > last and "reviewReply" not in r]:
        out = ai.generate(f"Label the mood (positive, mixed, negative) and draft a short, kind reply from Acme Dental:\n"
                          f"{r.get('comment', '')[:1500]}", json_schema=SCHEMA, max_output_tokens=200).json
        posted = slack.chat_postMessage(channel=CHANNEL, text=f"*{r['starRating'].title()} stars* · {out['mood']} · "
                 f"{r['reviewer']['displayName']}\n>{r.get('comment', '(no text)')}\nDraft: {out['reply']}\nReact ✅ to publish.")
        pending[posted["ts"]] = {"review": r["name"], "reply": out["reply"]}
        last = max(last, r["createTime"])
    state.set("pending", pending)
    state.set("last", last)
    return {"pending": len(pending)}