Review Response Generation

import os, requests, time

TP_KEY = os.environ["TRUSTPILOT_API_KEY"]
MV = os.environ["MAVERA_API_KEY"]
BU_ID = os.environ["TRUSTPILOT_BU_ID"]
TP_BASE = "https://api.trustpilot.com/v1"
MV_BASE = "https://app.mavera.io/api/v1"
MV_H = {"Authorization": f"Bearer {MV}", "Content-Type": "application/json"}

# 1. Pull negative reviews without replies
negative = []
for stars in [1, 2, 3]:
    r = requests.get(f"{TP_BASE}/business-units/{BU_ID}/reviews",
        params={"apikey": TP_KEY, "stars": stars, "perPage": 20,
                 "orderBy": "createdat.desc"})
    r.raise_for_status()
    for rev in r.json().get("reviews", []):
        if not rev.get("companyReply"):
            negative.append(rev)
    time.sleep(0.2)

print(f"Found {len(negative)} unreplied negative reviews")

# 2. Create or load customer service brand voice
CS_VOICE_SAMPLES = [
    "We're sorry to hear about your experience. This isn't the standard we hold ourselves to.",
    "Thank you for taking the time to share this feedback. We take every review seriously.",
    "We'd love to make this right. Please reach out to support@company.com with your order number.",
    "Your satisfaction matters to us, and we're actively working on improving this.",
]

bv = requests.post(f"{MV_BASE}/brand-voices", headers=MV_H, json={
    "name": "Customer Service Voice",
    "samples": ["\n\n---\n\n".join(CS_VOICE_SAMPLES)],
    "preferred_terms": ["we appreciate", "make this right", "your experience matters"],
    "avoid_terms": ["unfortunately", "per our policy", "as stated in our terms"],
}).json()
bv_id = bv["id"]
print(f"Brand Voice: {bv_id}")
time.sleep(2)

# 3. Generate responses per review
responses = []
for rev in negative[:10]:
    stars = rev.get("stars", 0)
    title = rev.get("title", "No title")
    text = rev.get("text", "")[:500]
    reviewer = rev.get("consumer", {}).get("displayName", "Customer")
    review_id = rev.get("id", "")

    gen = requests.post(f"{MV_BASE}/generations", headers=MV_H, json={
        "brand_voice_id": bv_id,
        "prompt": (
            f"Write a response to this {stars}-star Trustpilot review.\n\n"
            f"Reviewer: {reviewer}\n"
            f"Title: {title}\n"
            f"Review: {text}\n\n"
            f"Rules:\n"
            f"- Acknowledge the SPECIFIC issue (not generic)\n"
            f"- Offer a concrete next step\n"
            f"- Keep under 80 words\n"
            f"- Never be defensive\n"
            f"- Use the customer's name\n"
            f"- End with a way to reach your team"
        ),
    }).json()

    response_text = gen.get("output", gen.get("content", gen.get("text", "")))
    responses.append({
        "review_id": review_id,
        "stars": stars,
        "title": title,
        "response": response_text,
    })
    print(f"\n[{stars}★] {title}")
    print(f"  Review: {text[:100]}...")
    print(f"  Response: {response_text[:200]}")
    time.sleep(0.5)

# 4. Post responses (requires OAuth — uncomment in production)
# TP_OAUTH_TOKEN = os.environ["TRUSTPILOT_OAUTH_TOKEN"]
# for resp in responses:
#     requests.post(
#         f"{TP_BASE}/private/reviews/{resp['review_id']}/reply",
#         headers={"Authorization": f"Bearer {TP_OAUTH_TOKEN}", "Content-Type": "application/json"},
#         json={"message": resp["response"]})

const TP_KEY = process.env.TRUSTPILOT_API_KEY;
const MV = process.env.MAVERA_API_KEY;
const BU_ID = process.env.TRUSTPILOT_BU_ID;
const TP_BASE = "https://api.trustpilot.com/v1";
const MV_BASE = "https://app.mavera.io/api/v1";
const MV_H = { Authorization: `Bearer ${MV}`, "Content-Type": "application/json" };

// 1. Unreplied negative reviews
const negative = [];
for (const stars of [1, 2, 3]) {
  const res = await fetch(
    `${TP_BASE}/business-units/${BU_ID}/reviews?apikey=${TP_KEY}&stars=${stars}&perPage=20&orderBy=createdat.desc`
  );
  for (const rev of (await res.json()).reviews || []) {
    if (!rev.companyReply) negative.push(rev);
  }
  await new Promise((r) => setTimeout(r, 200));
}
console.log(`${negative.length} unreplied negative reviews`);

// 2. Brand Voice
const bv = await fetch(`${MV_BASE}/brand-voices`, {
  method: "POST", headers: MV_H,
  body: JSON.stringify({
    name: "CS Voice",
    samples: ["We're sorry about your experience. We take every review seriously.\n\n---\n\nWe'd love to make this right. Reach out to support@company.com."],
    preferred_terms: ["make this right", "your experience matters"],
    avoid_terms: ["unfortunately", "per our policy"],
  }),
}).then((r) => r.json());
await new Promise((r) => setTimeout(r, 2000));

// 3. Generate responses
for (const rev of negative.slice(0, 10)) {
  const gen = await fetch(`${MV_BASE}/generations`, {
    method: "POST", headers: MV_H,
    body: JSON.stringify({
      brand_voice_id: bv.id,
      prompt: `Respond to this ${rev.stars}-star review:\n\nReviewer: ${rev.consumer?.displayName || "Customer"}\nTitle: ${rev.title}\nReview: ${(rev.text || "").slice(0, 500)}\n\nAcknowledge specific issue. Concrete next step. Under 80 words. Not defensive. Use their name.`,
    }),
  }).then((r) => r.json());

  console.log(`\n[${rev.stars}★] ${rev.title}`);
  console.log(`  Response: ${(gen.output || gen.content || gen.text || "").slice(0, 200)}`);
  await new Promise((r) => setTimeout(r, 500));
}