Reply to Google reviews from a Slack thread

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

LOCATION = "accounts/1234567890/locations/9876543210"  # Rosa's Bakery
CHANNEL_ID = "C0123REVIEWS"  # #reviews
STARS = {"ONE": 1, "TWO": 2, "THREE": 3, "FOUR": 4, "FIVE": 5}

def slack(method, **params):
    r = http.post(f"https://slack.com/api/{method}", json=params,
                  headers={"Authorization": f"Bearer {credentials.connection('slack', 'work')}"}) if method == "chat.postMessage" \
        else http.get(f"https://slack.com/api/{method}", params=params,
                      headers={"Authorization": f"Bearer {credentials.connection('slack', 'work')}"})
    return r.json()

@on_trigger
def run(event):
    g = {"Authorization": f"Bearer {credentials.connection('google', 'work')}"}
    threads = state.get("threads") or {}  # slack ts -> review name
    last = state.get("last_create") or ""
    reviews = http.get(f"https://mybusiness.googleapis.com/v4/{LOCATION}/reviews",
                       params={"orderBy": "updateTime desc"}, headers=g).json().get("reviews", [])
    for r in sorted((r for r in reviews if r["createTime"] > last), key=lambda r: r["createTime"]):
        s = STARS[r["starRating"]]
        msg = slack("chat.postMessage", channel=CHANNEL_ID,
                    text=f"{'★' * s}{'☆' * (5 - s)} from {r['reviewer']['displayName']}\n{r.get('comment', '(no text)')}\n"
                         "Reply in this thread with \"reply: your text\" to answer on Google.")
        threads[msg["ts"]] = r["name"]
        last = max(last, r["createTime"])
    posted = 0
    for ts, review in list(threads.items()):
        replies = slack("conversations.replies", channel=CHANNEL_ID, ts=ts).get("messages", [])[1:]
        answer = next((m["text"][6:].strip() for m in replies if m.get("text", "").lower().startswith("reply:")), None)
        if answer:
            http.put(f"https://mybusiness.googleapis.com/v4/{review}/reply", json={"comment": answer},
                     headers=g).raise_for_status()
            slack("chat.postMessage", channel=CHANNEL_ID, thread_ts=ts, text=":white_check_mark: Reply posted on Google.")
            del threads[ts]
            posted += 1
    state.set("threads", dict(list(threads.items())[-100:]))
    state.set("last_create", last)
    return {"replies_posted": posted}