Store new reviews in Supabase and send angry ones to Slack

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

PLACE_ID = "your-google-place-id"
SUPABASE = "https://your-project.supabase.co/rest/v1"

def sb(method, path, **kw):
    key = credentials.secret("SUPABASE_KEY")
    r = http.request(method, f"{SUPABASE}/{path}", **kw, headers={"apikey": key, "Authorization": f"Bearer {key}", "Prefer": "return=representation,resolution=merge-duplicates"})
    return r.raise_for_status() or (r.json() if r.content else None)

@on_trigger
def run(event):
    place = http.get(f"https://places.googleapis.com/v1/places/{PLACE_ID}", headers={"X-Goog-Api-Key": credentials.secret("GOOGLE_PLACES_KEY"),
                     "X-Goog-FieldMask": "reviews"}).json()
    reviews = [{"id": r["name"], "rating": r["rating"], "text": r.get("text", {}).get("text", ""), "author": r["authorAttribution"]["displayName"]}
               for r in place.get("reviews", [])]
    known = {r["id"] for r in sb("GET", "reviews", params={"select": "id", "id": "in.(" + ",".join(f'"{r["id"]}"' for r in reviews) + ")"})} if reviews else set()
    new = [r for r in reviews if r["id"] not in known]
    report_fetched(len(new))
    if not new:
        return {"summary": "Nothing new"}
    listing = "\n".join(f"{i}. ({r['rating']}/5) {r['text'][:500]}" for i, r in enumerate(new))
    labels = ai.generate(f"Label each review positive, neutral or negative. One word per line.\n{listing}", max_output_tokens=8 * len(new)).text.split()
    for r, label in zip(new, labels):
        r["sentiment"] = label.lower()
    sb("POST", "reviews", json=new)
    for r in [r for r in new if r.get("sentiment") == "negative"]:
        notify.slack(f":warning: {r['rating']}★ review from {r['author']}: {r['text'][:400]}", channel="#customer-care")
    return {"new": len(new)}