Segment Overlap Analysis

import os, requests, time

KL_KEY = os.environ["KLAVIYO_API_KEY"]
MV = os.environ["MAVERA_API_KEY"]
MB = "https://app.mavera.io/api/v1"
MH = {"Authorization": f"Bearer {MV}", "Content-Type": "application/json"}
KH = {
    "Authorization": f"Klaviyo-API-Key {KL_KEY}",
    "Content-Type": "application/json",
    "revision": "2024-10-15",
}

segments = []
url = "https://a.klaviyo.com/api/segments"
params = {"fields[segment]": "name,definition,created,updated,is_active,profile_count"}

for page_num in range(3):
    r = requests.get(url, headers=KH, params=params if page_num == 0 else None)
    if r.status_code == 429:
        time.sleep(int(r.headers.get("Retry-After", 10)))
        continue
    r.raise_for_status()
    data = r.json()
    segments.extend(data.get("data", []))
    url = data.get("links", {}).get("next")
    if not url:
        break
    params = None
    time.sleep(0.5)

print(f"Found {len(segments)} segments\n")

segment_info = []
for seg in segments:
    attrs = seg.get("attributes", {})
    segment_info.append({
        "id": seg["id"],
        "name": attrs.get("name", ""),
        "count": attrs.get("profile_count", 0),
        "active": attrs.get("is_active", True),
        "definition": str(attrs.get("definition", ""))[:200],
        "created": attrs.get("created", "")[:10],
        "updated": attrs.get("updated", "")[:10],
    })

segment_info.sort(key=lambda s: s["count"], reverse=True)
total_profiles = sum(s["count"] for s in segment_info)

segment_block = "\n".join(
    f"- **{s['name']}**: {s['count']:,} profiles | Active: {s['active']} | Created: {s['created']}\n"
    f"  Definition: {s['definition'][:150]}{'...' if len(s['definition']) > 150 else ''}"
    for s in segment_info
)

mave = requests.post(f"{MB}/mave/chat", headers=MH, json={
    "message": f"""Analyze our Klaviyo segments for redundancy and recommend a simplified segmentation strategy.

CURRENT SEGMENTS ({len(segment_info)} total, {total_profiles:,} total profile memberships):

{segment_block}

Analyze:
1. Which segments likely have significant overlap? (based on names, definitions, and member counts)
2. Which segments are redundant and could be merged? Suggest specific merges.
3. Are there gaps — behavioral groups that should have segments but don't?
4. Recommend a simplified structure with max 8-10 segments. Name each and describe its purpose.
5. Which segments are stale (created long ago, rarely updated) and should be archived?
6. How should these segments map to email/SMS flows?

Goal: Reduce segment count by 40-60% while maintaining targeting precision.""",
}).json()

print("--- Segment Overlap Analysis ---")
print(mave.get("content", "")[:3000])

const KL_KEY = process.env.KLAVIYO_API_KEY;
const MV = process.env.MAVERA_API_KEY;
const MB = "https://app.mavera.io/api/v1";
const MH = { Authorization: `Bearer ${MV}`, "Content-Type": "application/json" };
const KH = { Authorization: `Klaviyo-API-Key ${KL_KEY}`, "Content-Type": "application/json", revision: "2024-10-15" };

const segments = [];
let url = "https://a.klaviyo.com/api/segments?fields[segment]=name,definition,created,updated,is_active,profile_count";
for (let i = 0; i < 3; i++) {
  const res = await fetch(url, { headers: KH });
  if (res.status === 429) { await new Promise((r) => setTimeout(r, parseInt(res.headers.get("Retry-After") || "10") * 1000)); continue; }
  const data = await res.json();
  segments.push(...(data.data || []));
  url = data.links?.next;
  if (!url) break;
  await new Promise((r) => setTimeout(r, 500));
}

console.log(`Found ${segments.length} segments\n`);

const segInfo = segments
  .map((s) => ({
    name: s.attributes?.name || "", count: s.attributes?.profile_count || 0,
    active: s.attributes?.is_active ?? true, definition: String(s.attributes?.definition || "").slice(0, 200),
    created: (s.attributes?.created || "").slice(0, 10),
  }))
  .sort((a, b) => b.count - a.count);

const total = segInfo.reduce((s, seg) => s + seg.count, 0);
const block = segInfo.map((s) => `- **${s.name}**: ${s.count.toLocaleString()} profiles | Active: ${s.active} | Created: ${s.created}\n  Def: ${s.definition.slice(0, 150)}`).join("\n");

const mave = await fetch(`${MB}/mave/chat`, { method: "POST", headers: MH,
  body: JSON.stringify({
    message: `Analyze ${segInfo.length} Klaviyo segments (${total.toLocaleString()} total memberships) for overlap.\n\n${block}\n\nAnalyze: 1) Overlaps 2) Merge candidates 3) Gaps 4) Simplified 8-10 segment structure 5) Stale segments 6) Flow mapping.\n\nGoal: reduce by 40-60%.`,
  }),
}).then((r) => r.json());

console.log("--- Segment Analysis ---");
console.log((mave.content || "").slice(0, 3000));