Pain Point Discovery for Messaging

import os, requests, time

# --- Auth setup same as Job 1 ---

CATEGORY = "project management software"
SUBS = ["projectmanagement", "productivity", "startups", "smallbusiness"]
QUERIES = [f"frustrated with {CATEGORY}", f"hate {CATEGORY}", f"problem with {CATEGORY}",
           f"switching from {CATEGORY}", f"alternative to {CATEGORY}"]

# 1. Collect problem threads
threads = []
for q in QUERIES:
    for sub in SUBS:
        r = requests.get(f"{RD}/r/{sub}/search", headers=RD_H,
            params={"q": q, "restrict_sr": "true", "sort": "relevance", "t": "year", "limit": 5, "raw_json": 1})
        if r.status_code == 429: time.sleep(int(r.headers.get("X-Ratelimit-Reset", 60))); continue
        if not r.ok: continue
        for p in r.json().get("data",{}).get("children",[]):
            d = p["data"]
            if d.get("selftext") or d.get("title"):
                threads.append({"title": d["title"], "text": d.get("selftext","")[:400],
                    "subreddit": d.get("subreddit",""), "score": d.get("score",0)})
        time.sleep(0.7)

enriched = [f"[/r/{t['subreddit']}] {t['title']}\n{t['text'][:300]}"
            for t in sorted(threads, key=lambda x: -x["score"])[:15]]
print(f"Collected {len(threads)} problem threads across {len(SUBS)} subreddits")

# 2. Extract pain points
extraction = requests.post(f"{MV_BASE}/mave/chat", headers=MV_H, json={
    "message": f"Analyze these Reddit complaints about {CATEGORY}. Extract top 10 pain points.\n\n"
        + "\n".join(enriched)
        + "\n\nFor each: name (3-5 words), frequency, emotional intensity (1-10), representative quote, underlying need. Rank by frequency × intensity."
}).json()
pain_text = extraction.get("content", "")
print(pain_text[:1200])

# 3. Generate ad copy per pain point
ads = requests.post(f"{MV_BASE}/generations", headers=MV_H, json={
    "prompt": f"From these Reddit pain points about {CATEGORY}, write targeted ad copy.\n\n{pain_text[:2000]}\n\n"
        "For each pain point:\n- Facebook: Headline (40 chars) + Primary text (125 chars) + Description (30 chars)\n"
        "- Google: H1 (30 chars) + H2 (30 chars) + Description (90 chars)\n"
        "- LinkedIn: Intro (150 chars) + Headline (70 chars)\n\nUse EXACT Reddit vocabulary. Address pain first.",
}).json()
print(f"\n{'='*60}\nAD COPY LIBRARY\n{'='*60}")
print(ads.get("output", ads.get("content", ""))[:1500])

// --- Auth setup same as Job 1 ---

const CATEGORY = "project management software";
const SUBS = ["projectmanagement", "productivity", "startups", "smallbusiness"];
const QUERIES = [`frustrated with ${CATEGORY}`, `hate ${CATEGORY}`, `problem with ${CATEGORY}`,
  `switching from ${CATEGORY}`, `alternative to ${CATEGORY}`];

// 1. Problem threads
const threads = [];
for (const q of QUERIES) {
  for (const sub of SUBS) {
    const r = await fetch(
      `${RD}/r/${sub}/search?q=${encodeURIComponent(q)}&restrict_sr=true&sort=relevance&t=year&limit=5&raw_json=1`,
      { headers: RD_H });
    if (r.status === 429) { await new Promise(res => setTimeout(res, 60000)); continue; }
    if (!r.ok) continue;
    for (const p of (await r.json()).data?.children || []) {
      const d = p.data;
      if (d.selftext || d.title)
        threads.push({ title: d.title, text: (d.selftext||"").slice(0,400), subreddit: d.subreddit||"", score: d.score||0 });
    }
    await new Promise(r => setTimeout(r, 700));
  }
}

const enriched = threads.sort((a,b) => b.score-a.score).slice(0,15)
  .map(t => `[/r/${t.subreddit}] ${t.title}\n${t.text.slice(0,300)}`);
console.log(`Collected ${threads.length} problem threads`);

// 2. Extract pain points
const extraction = await fetch(`${MV_BASE}/mave/chat`, { method: "POST", headers: MV_H,
  body: JSON.stringify({ message: `Analyze Reddit complaints about ${CATEGORY}. Top 10 pain points.\n\n${enriched.join("\n")}\n\nFor each: name, frequency, intensity (1-10), quote, need. Rank by freq × intensity.` }),
}).then(r => r.json());
const painText = extraction.content || "";
console.log(painText.slice(0, 1200));

// 3. Ad copy
const ads = await fetch(`${MV_BASE}/generations`, { method: "POST", headers: MV_H,
  body: JSON.stringify({ prompt: `Reddit pain points about ${CATEGORY} → ad copy.\n\n${painText.slice(0,2000)}\n\nPer point: Facebook (headline 40ch + primary 125ch), Google (H1 30ch + H2 30ch + desc 90ch), LinkedIn (intro 150ch + headline 70ch). Use Reddit vocabulary. Pain first.` }),
}).then(r => r.json());
console.log(`\n${"=".repeat(60)}\nAD COPY LIBRARY\n${"=".repeat(60)}`);
console.log((ads.output || ads.content || "").slice(0, 1500));