Lead-Qualified Viewer → Personalized Follow-up

import os, requests, time

WS = os.environ["WISTIA_API_TOKEN"]
MV = os.environ["MAVERA_API_KEY"]
WS_BASE = "https://api.wistia.com"
MV_BASE = "https://app.mavera.io/api/v1"
WS_H = {"Authorization": f"Bearer {WS}", "Accept": "application/json"}
MV_H = {"Authorization": f"Bearer {MV}", "Content-Type": "application/json"}

TARGET_MEDIA_IDS = ["abc123def4", "xyz789ghi0", "mno456pqr1"]
WATCH_THRESHOLD = 0.80

# Simulated CRM data (replace with your CRM API call)
CRM_DATA = {
    "jane@acme.com": {"name": "Jane Chen", "company": "Acme Corp", "role": "VP Marketing", "deal_stage": "Evaluation", "industry": "SaaS"},
    "mike@globex.com": {"name": "Mike Ross", "company": "Globex Inc", "role": "Director of Growth", "deal_stage": "Awareness", "industry": "Fintech"},
    "sarah@initech.com": {"name": "Sarah Kim", "company": "Initech", "role": "CMO", "deal_stage": "Consideration", "industry": "Healthcare"},
}

qualified_viewers = []

for media_id in TARGET_MEDIA_IDS:
    # 1. Get media details
    media = requests.get(
        f"{WS_BASE}/v1/medias/{media_id}.json", headers=WS_H
    ).json()
    media_name = media.get("name", media_id)
    media_duration = media.get("duration", 0)

    # 2. Get visitor-level stats for this media
    visitors_resp = requests.get(
        f"{WS_BASE}/v1/stats/medias/{media_id}/visitors.json",
        headers=WS_H, params={"per_page": 100},
    ).json()

    for visitor in visitors_resp if isinstance(visitors_resp, list) else []:
        percent_watched = visitor.get("percent_viewed", 0)
        email = visitor.get("visitor_identity", {}).get("email", "")

        if percent_watched < WATCH_THRESHOLD or not email:
            continue

        crm = CRM_DATA.get(email, {})
        qualified_viewers.append({
            "email": email,
            "name": crm.get("name", email.split("@")[0].title()),
            "company": crm.get("company", "Unknown"),
            "role": crm.get("role", "Unknown"),
            "deal_stage": crm.get("deal_stage", "Unknown"),
            "industry": crm.get("industry", "Unknown"),
            "video_watched": media_name,
            "percent_watched": round(percent_watched * 100, 1),
            "video_duration": media_duration,
            "last_viewed": visitor.get("last_event_at", ""),
        })
    time.sleep(0.3)

print(f"Qualified viewers (>{WATCH_THRESHOLD*100:.0f}% watched): {len(qualified_viewers)}")

# 3. Generate personalized follow-up for each viewer
emails = []
for viewer in qualified_viewers:
    follow_up = requests.post(f"{MV_BASE}/generate", headers=MV_H, json={
        "prompt": f"""Write a personalized sales follow-up email for this viewer.

VIEWER CONTEXT:
- Name: {viewer['name']}
- Company: {viewer['company']}
- Role: {viewer['role']}
- Industry: {viewer['industry']}
- Deal Stage: {viewer['deal_stage']}
- Video Watched: "{viewer['video_watched']}" ({viewer['percent_watched']}% completed)
- Video Duration: {viewer['video_duration']}s

RULES:
1. Reference the specific video they watched — show you know what they saw
2. Tailor the value proposition to their role and industry
3. Match the follow-up intensity to their deal stage:
   - Awareness: Light touch, offer more content
   - Consideration: Share case study from their industry
   - Evaluation: Offer a personalized demo or pilot
4. Keep it under 150 words
5. One clear CTA — not multiple asks
6. Sound human, not automated. No "I noticed you watched..." (creepy)
7. Subject line should create curiosity, not summarize the email""",
    }).json()

    emails.append({
        **viewer,
        "email_content": follow_up.get("content", ""),
    })
    time.sleep(0.5)

# 4. Output
print("\nLEAD-QUALIFIED VIEWER → PERSONALIZED FOLLOW-UP")
print("=" * 60)
for e in emails:
    print(f"\n{'─' * 60}")
    print(f"TO: {e['name']} <{e['email']}> | {e['role']} @ {e['company']}")
    print(f"SIGNAL: Watched \"{e['video_watched']}\" ({e['percent_watched']}%) | Stage: {e['deal_stage']}")
    print(f"\n{e['email_content'][:600]}")

const WS = process.env.WISTIA_API_TOKEN;
const MV = process.env.MAVERA_API_KEY;
const WS_BASE = "https://api.wistia.com";
const MV_BASE = "https://app.mavera.io/api/v1";
const WS_H = { Authorization: `Bearer ${WS}`, Accept: "application/json" };
const MV_H = { Authorization: `Bearer ${MV}`, "Content-Type": "application/json" };

const TARGET_MEDIA_IDS = ["abc123def4", "xyz789ghi0", "mno456pqr1"];
const WATCH_THRESHOLD = 0.80;

const CRM_DATA = {
  "jane@acme.com": { name: "Jane Chen", company: "Acme Corp", role: "VP Marketing", dealStage: "Evaluation", industry: "SaaS" },
  "mike@globex.com": { name: "Mike Ross", company: "Globex Inc", role: "Director of Growth", dealStage: "Awareness", industry: "Fintech" },
  "sarah@initech.com": { name: "Sarah Kim", company: "Initech", role: "CMO", dealStage: "Consideration", industry: "Healthcare" },
};

const qualifiedViewers = [];

for (const mediaId of TARGET_MEDIA_IDS) {
  // 1. Media details
  const media = await fetch(
    `${WS_BASE}/v1/medias/${mediaId}.json`, { headers: WS_H }
  ).then(r => r.json());

  // 2. Visitor stats
  const visitorsResp = await fetch(
    `${WS_BASE}/v1/stats/medias/${mediaId}/visitors.json?per_page=100`, { headers: WS_H }
  ).then(r => r.json());

  for (const visitor of Array.isArray(visitorsResp) ? visitorsResp : []) {
    const pctWatched = visitor.percent_viewed || 0;
    const email = visitor.visitor_identity?.email || "";
    if (pctWatched < WATCH_THRESHOLD || !email) continue;

    const crm = CRM_DATA[email] || {};
    qualifiedViewers.push({
      email, name: crm.name || email.split("@")[0],
      company: crm.company || "Unknown", role: crm.role || "Unknown",
      dealStage: crm.dealStage || "Unknown", industry: crm.industry || "Unknown",
      videoWatched: media.name || mediaId,
      percentWatched: Math.round(pctWatched * 1000) / 10,
      videoDuration: media.duration || 0,
      lastViewed: visitor.last_event_at || "",
    });
  }
  await new Promise(r => setTimeout(r, 300));
}

console.log(`Qualified viewers (>${WATCH_THRESHOLD * 100}%): ${qualifiedViewers.length}`);

// 3. Generate follow-ups
const emails = [];
for (const viewer of qualifiedViewers) {
  const followUp = await fetch(`${MV_BASE}/generate`, {
    method: "POST", headers: MV_H,
    body: JSON.stringify({
      prompt: `Personalized follow-up email.\n\nVIEWER:\n- ${viewer.name}, ${viewer.role} @ ${viewer.company} (${viewer.industry})\n- Stage: ${viewer.dealStage}\n- Watched: "${viewer.videoWatched}" (${viewer.percentWatched}% of ${viewer.videoDuration}s)\n\nRULES:\n1. Reference the specific video\n2. Tailor to role + industry\n3. Match intensity to deal stage (Awareness=light, Consideration=case study, Evaluation=demo offer)\n4. Under 150 words, one CTA\n5. Sound human, not automated\n6. Curiosity-driven subject line`,
    }),
  }).then(r => r.json());

  emails.push({ ...viewer, emailContent: followUp.content || "" });
  await new Promise(r => setTimeout(r, 500));
}

// 4. Output
console.log("\nLEAD-QUALIFIED VIEWER → PERSONALIZED FOLLOW-UP");
console.log("=".repeat(60));
for (const e of emails) {
  console.log(`\n${"─".repeat(60)}`);
  console.log(`TO: ${e.name} <${e.email}> | ${e.role} @ ${e.company}`);
  console.log(`SIGNAL: "${e.videoWatched}" (${e.percentWatched}%) | Stage: ${e.dealStage}`);
  console.log(`\n${e.emailContent.slice(0, 600)}`);
}