Campaign Event Analysis → Messaging Strategy

import os, requests, base64, time

CIO_APP = os.environ["CIO_APP_KEY"]
MV = os.environ["MAVERA_API_KEY"]
APP_BASE = "https://api.customer.io/v1"
MB = "https://app.mavera.io/api/v1"
APP_H = {"Authorization": f"Bearer {CIO_APP}"}
MV_H = {"Authorization": f"Bearer {MV}", "Content-Type": "application/json"}

# 1. List campaigns
campaigns = requests.get(f"{APP_BASE}/campaigns",
    headers=APP_H).json().get("campaigns", [])

# 2. Pull metrics for each active campaign
ranked = []
for camp in campaigns:
    if camp.get("state") != "active":
        continue
    cid = camp["id"]
    metrics = requests.get(f"{APP_BASE}/campaigns/{cid}/metrics",
        headers=APP_H, params={"period": "days", "steps": 30})
    if metrics.status_code == 429:
        time.sleep(1)
        metrics = requests.get(f"{APP_BASE}/campaigns/{cid}/metrics",
            headers=APP_H, params={"period": "days", "steps": 30})
    metrics.raise_for_status()
    data = metrics.json()

    series = data.get("series", {})
    sent = sum(series.get("sent", [0]))
    clicked = sum(series.get("clicked", [0]))
    converted = sum(series.get("converted", [0]))
    ctr = clicked / max(sent, 1)

    ranked.append({
        "id": cid,
        "name": camp.get("name", "Untitled"),
        "type": camp.get("type", "email"),
        "sent": sent, "clicked": clicked, "converted": converted,
        "ctr": ctr,
    })
    time.sleep(0.12)

ranked.sort(key=lambda x: -x["ctr"])
top = ranked[:5]
bottom = ranked[-3:] if len(ranked) >= 8 else []

# 3. Pull message content for top campaigns
top_copy = []
for camp in top:
    actions = requests.get(f"{APP_BASE}/campaigns/{camp['id']}/actions",
        headers=APP_H).json().get("actions", [])
    for act in actions[:2]:
        body = act.get("body", "")[:500]
        subject = act.get("subject", act.get("name", ""))
        if subject or body:
            top_copy.append(
                f"Campaign: {camp['name']} (CTR: {camp['ctr']:.1%})\n"
                f"Subject: {subject}\n{body}"
            )

# 4. Mave pattern analysis
analysis = requests.post(f"{MB}/mave/chat", headers=MV_H, json={
    "message": f"""Analyze these top-performing Customer.io campaign messages.
Identify: 1) Common structural patterns 2) Tone and voice traits
3) Subject line formulas 4) CTA patterns 5) What the bottom performers lack

TOP PERFORMERS:
{chr(10).join(top_copy[:8])}

BOTTOM PERFORMERS (for contrast):
{chr(10).join(f"- {c['name']} (CTR: {c['ctr']:.1%})" for c in bottom)}"""
}).json()

print("=== Pattern Analysis ===")
print(analysis.get("content", "")[:1500])

# 5. Generate new variations
gen = requests.post(f"{MB}/generations", headers=MV_H, json={
    "prompt": (
        f"Based on these winning patterns from our email campaigns, "
        f"generate 5 new email subject line + 100-word body variations. "
        f"Topic: product feature announcement. "
        f"Patterns to follow: {analysis.get('content', '')[:800]}"
    ),
    "count": 5,
}).json()

print("\n=== New Variations ===")
for i, g in enumerate(gen.get("results", [gen]), 1):
    print(f"\nVariant {i}:\n{g.get('content', g.get('text', ''))[:300]}")

const CIO_APP = process.env.CIO_APP_KEY;
const MV = process.env.MAVERA_API_KEY;
const APP_BASE = "https://api.customer.io/v1";
const MB = "https://app.mavera.io/api/v1";
const appH = { Authorization: `Bearer ${CIO_APP}` };
const mvH = { Authorization: `Bearer ${MV}`, "Content-Type": "application/json" };

// 1. List campaigns
const { campaigns } = await fetch(`${APP_BASE}/campaigns`,
  { headers: appH }).then(r => r.json());

// 2. Pull metrics
const ranked = [];
for (const camp of campaigns) {
  if (camp.state !== "active") continue;
  let res = await fetch(
    `${APP_BASE}/campaigns/${camp.id}/metrics?period=days&steps=30`,
    { headers: appH });
  if (res.status === 429) {
    await new Promise(r => setTimeout(r, 1000));
    res = await fetch(
      `${APP_BASE}/campaigns/${camp.id}/metrics?period=days&steps=30`,
      { headers: appH });
  }
  const data = await res.json();
  const series = data.series || {};
  const sum = (a) => (a || [0]).reduce((s, v) => s + v, 0);
  const sent = sum(series.sent), clicked = sum(series.clicked),
        converted = sum(series.converted);
  ranked.push({
    id: camp.id, name: camp.name || "Untitled", type: camp.type || "email",
    sent, clicked, converted, ctr: clicked / Math.max(sent, 1),
  });
  await new Promise(r => setTimeout(r, 120));
}

ranked.sort((a, b) => b.ctr - a.ctr);
const top = ranked.slice(0, 5);
const bottom = ranked.length >= 8 ? ranked.slice(-3) : [];

// 3. Pull message content for top campaigns
const topCopy = [];
for (const camp of top) {
  const { actions } = await fetch(`${APP_BASE}/campaigns/${camp.id}/actions`,
    { headers: appH }).then(r => r.json());
  for (const act of (actions || []).slice(0, 2)) {
    const subject = act.subject || act.name || "";
    const body = (act.body || "").slice(0, 500);
    if (subject || body)
      topCopy.push(`Campaign: ${camp.name} (CTR: ${(camp.ctr * 100).toFixed(1)}%)\nSubject: ${subject}\n${body}`);
  }
}

// 4. Mave pattern analysis
const analysis = await fetch(`${MB}/mave/chat`, {
  method: "POST", headers: mvH,
  body: JSON.stringify({
    message: `Analyze these top-performing Customer.io campaign messages.
Identify: 1) Structural patterns 2) Tone traits 3) Subject line formulas 4) CTA patterns 5) What bottom performers lack

TOP PERFORMERS:
${topCopy.slice(0, 8).join("\n\n")}

BOTTOM PERFORMERS:
${bottom.map(c => `- ${c.name} (CTR: ${(c.ctr * 100).toFixed(1)}%)`).join("\n")}`,
  }),
}).then(r => r.json());

console.log("=== Pattern Analysis ===");
console.log((analysis.content || "").slice(0, 1500));

// 5. Generate variations
const gen = await fetch(`${MB}/generations`, {
  method: "POST", headers: mvH,
  body: JSON.stringify({
    prompt: `Based on winning patterns from our emails, generate 5 subject + 100-word body variations. Topic: product feature announcement. Patterns: ${(analysis.content || "").slice(0, 800)}`,
    count: 5,
  }),
}).then(r => r.json());

console.log("\n=== New Variations ===");
(gen.results || [gen]).forEach((g, i) =>
  console.log(`\nVariant ${i + 1}:\n${(g.content || g.text || "").slice(0, 300)}`)
);