Pipeline-Aware Content Generation

import os, requests
from collections import Counter

SF   = os.environ["SALESFORCE_INSTANCE"]
SF_T = os.environ["SALESFORCE_ACCESS_TOKEN"]
MV_K = os.environ["MAVERA_API_KEY"]
SF_H = {"Authorization": f"Bearer {SF_T}"}
MV_H = {"Authorization": f"Bearer {MV_K}", "Content-Type": "application/json"}

opps = requests.get(
    f"https://{SF}/services/data/v66.0/query", headers=SF_H,
    params={"q": "SELECT StageName, Industry, Amount FROM Opportunity WHERE IsClosed = false ORDER BY Amount DESC LIMIT 100"},
).json()["records"]

seg_counts = Counter((o.get("StageName", "Unknown"), o.get("Industry", "Unknown")) for o in opps)
top_segments = seg_counts.most_common(5)

for (stage, industry), count in top_segments:
    seg_value = sum(o.get("Amount", 0) for o in opps if o.get("StageName") == stage and o.get("Industry") == industry)
    context = f"{count} open deals in '{stage}' stage, {industry} industry. Pipeline value: ${seg_value:,.0f}."

    gen = requests.post(
        "https://app.mavera.io/api/v1/generations", headers=MV_H,
        json={
            "input_data": context,
            "prompt": (
                f"Generate a nurture email for prospects in the '{stage}' stage, "
                f"{industry} industry. Address common concerns at this stage, "
                f"provide social proof, include a clear next-step CTA."
            ),
        },
    ).json()

    print(f"\n{'='*50}")
    print(f"Stage: {stage} | Industry: {industry} | Deals: {count}")
    print(f"{'='*50}")
    print(gen.get("output", ""))

const SF   = process.env.SALESFORCE_INSTANCE;
const SF_T = process.env.SALESFORCE_ACCESS_TOKEN;
const MV_K = process.env.MAVERA_API_KEY;

const { records: opps } = await fetch(
  `https://${SF}/services/data/v66.0/query?q=${encodeURIComponent(
    "SELECT StageName, Industry, Amount FROM Opportunity WHERE IsClosed = false ORDER BY Amount DESC LIMIT 100"
  )}`,
  { headers: { Authorization: `Bearer ${SF_T}` } }
).then((r) => r.json());

const segCounts = {};
for (const o of opps) {
  const key = `${o.StageName || "Unknown"}|${o.Industry || "Unknown"}`;
  segCounts[key] = (segCounts[key] || 0) + 1;
}
const topSegments = Object.entries(segCounts).sort(([, a], [, b]) => b - a).slice(0, 5);

for (const [key, count] of topSegments) {
  const [stage, industry] = key.split("|");
  const segValue = opps
    .filter((o) => o.StageName === stage && o.Industry === industry)
    .reduce((s, o) => s + (o.Amount || 0), 0);

  const gen = await fetch("https://app.mavera.io/api/v1/generations", {
    method: "POST",
    headers: { Authorization: `Bearer ${MV_K}`, "Content-Type": "application/json" },
    body: JSON.stringify({
      input_data: `${count} open deals in '${stage}' stage, ${industry}. Value: $${segValue.toLocaleString()}.`,
      prompt: `Generate a nurture email for '${stage}' stage, ${industry}. Address stage concerns, social proof, clear CTA.`,
    }),
  }).then((r) => r.json());

  console.log(`\n${"=".repeat(50)}`);
  console.log(`Stage: ${stage} | Industry: ${industry} | Deals: ${count}`);
  console.log(gen.output || "");
}