Flow Performance → Content Refresh

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",
}

r = requests.get(f"https://a.klaviyo.com/api/flows", headers=KH, params={
    "fields[flow]": "name,status,trigger_type",
})
if r.status_code == 429:
    time.sleep(int(r.headers.get("Retry-After", 10)))
    r = requests.get(f"https://a.klaviyo.com/api/flows", headers=KH, params={
        "fields[flow]": "name,status,trigger_type",
    })
r.raise_for_status()
flows = r.json().get("data", [])

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

flow_metrics = []
for flow in flows[:10]:
    flow_id = flow["id"]
    flow_name = flow["attributes"]["name"]
    flow_status = flow["attributes"].get("status", "unknown")

    metrics_r = requests.post(
        f"https://a.klaviyo.com/api/metric-aggregates",
        headers=KH,
        json={
            "data": {
                "type": "metric-aggregate",
                "attributes": {
                    "metric_id": "open",
                    "measurements": ["count", "unique"],
                    "interval": "month",
                    "page_size": 1,
                    "filter": [f"equals(flow_id,'{flow_id}')"],
                    "timeframe": {"key": "last_30_days"},
                },
            },
        },
    )

    open_data = {}
    if metrics_r.status_code == 200:
        agg = metrics_r.json().get("data", {}).get("attributes", {})
        open_data = {"opens": agg.get("data", [{}])[0] if agg.get("data") else {}}

    flow_metrics.append({
        "id": flow_id,
        "name": flow_name,
        "status": flow_status,
        "metrics": open_data,
    })
    time.sleep(0.5)

BENCHMARK = {"open_rate": 0.25, "click_rate": 0.035}

UNDERPERFORMERS = [
    {"name": "Welcome Series", "open_rate": 0.18, "click_rate": 0.02, "current_subject": "Welcome to our family!", "current_preview": "Here's what to expect..."},
    {"name": "Abandoned Cart", "open_rate": 0.15, "click_rate": 0.025, "current_subject": "You forgot something!", "current_preview": "Complete your purchase"},
    {"name": "Post-Purchase", "open_rate": 0.22, "click_rate": 0.018, "current_subject": "Thanks for your order", "current_preview": "Your order details inside"},
]

BRAND_VOICE_ID = os.environ.get("BRAND_VOICE_ID", "")

print("--- Flow Content Refresh ---\n")
for flow in UNDERPERFORMERS:
    prompt = (
        f"Rewrite the email content for our '{flow['name']}' flow. "
        f"Current performance is below benchmark:\n"
        f"  Open rate: {flow['open_rate']:.0%} (benchmark: {BENCHMARK['open_rate']:.0%})\n"
        f"  Click rate: {flow['click_rate']:.0%} (benchmark: {BENCHMARK['click_rate']:.0%})\n\n"
        f"Current subject: \"{flow['current_subject']}\"\n"
        f"Current preview: \"{flow['current_preview']}\"\n\n"
        f"Generate:\n"
        f"1. 3 subject line variants (each under 50 chars)\n"
        f"2. Preview text for each (under 90 chars)\n"
        f"3. Email body rewrite (150-200 words) that:\n"
        f"   - Hooks in the first line\n"
        f"   - Addresses the reader's emotional state at this flow stage\n"
        f"   - Has a clear, compelling CTA\n"
        f"4. Explain what's wrong with the current version"
    )

    payload = {"prompt": prompt}
    if BRAND_VOICE_ID:
        payload["brand_voice_id"] = BRAND_VOICE_ID

    gen = requests.post(f"{MB}/generations", headers=MH, json=payload).json()

    print(f"{'='*50}")
    print(f"Flow: {flow['name']}")
    print(f"Current: {flow['open_rate']:.0%} open / {flow['click_rate']:.0%} click")
    print(f"{'='*50}")
    print(gen.get("output", gen.get("content", ""))[:700])
    print()
    time.sleep(0.5)