Store new reviews in Pinecone and flag bad ones on Telegram

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

REVIEWS_URL = "https://api.example-reviews.com/v1/reviews?business=northwind-bistro"
OWNER_CHAT_ID = 123456789

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    reviews = [r for r in http.get(REVIEWS_URL, headers={"Authorization": f"Bearer {credentials.secret('REVIEWS_API_KEY')}"}).json()["reviews"] if r["id"] not in seen]
    report_fetched(len(reviews))
    if not reviews:
        return {"new": 0}
    embeds = http.post("https://api.pinecone.io/embed", headers={"Api-Key": credentials.secret("PINECONE_API_KEY"), "X-Pinecone-API-Version": "2025-01"},
                       json={"model": "multilingual-e5-large", "inputs": [{"text": r["text"][:2000]} for r in reviews]}).json()["data"]
    http.post(f"https://{credentials.secret('PINECONE_HOST')}/vectors/upsert", headers={"Api-Key": credentials.secret("PINECONE_API_KEY")},
              json={"vectors": [{"id": r["id"], "values": e["values"], "metadata": {"text": r["text"][:2000], "rating": r["rating"], "date": r["date"]}} for r, e in zip(reviews, embeds)]})
    bad = [r for r in reviews if r["rating"] <= 2]
    for r in bad:
        summary = ai.generate(f"Summarise this complaint in one line:\n{r['text'][:2000]}", max_output_tokens=60).text.strip()
        http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage",
                  json={"chat_id": OWNER_CHAT_ID, "text": f"{'⭐' * r['rating']} review: {summary}\n{r.get('url', '')}"})
    state.set("seen", list(seen | {r["id"] for r in reviews})[-2000:])
    return {"new": len(reviews), "alerts": len(bad)}