Event Stream → Real-Time Persona Triggers

import os, requests, json, time
from http.server import HTTPServer, BaseHTTPRequestHandler

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

TRIGGER_EVENTS = {
    "trial_started": {
        "action": "create_persona",
        "persona_template": {
            "name_prefix": "Segment RT: Trial User",
            "description_template": "Real-time persona created when user {user_id} started a trial. Plan: {plan}. Source: {source}.",
        },
    },
    "plan_upgraded": {
        "action": "research",
        "research_template": "A user just upgraded from {previous_plan} to {new_plan}. Research: What motivates users to upgrade at this point in their journey? What features do they expect immediately after upgrading? What's the #1 risk of churn in the first 7 days post-upgrade?",
    },
    "feature_milestone": {
        "action": "create_persona",
        "persona_template": {
            "name_prefix": "Segment RT: Feature Champion",
            "description_template": "Power user who reached {milestone} milestone for feature {feature_name}. This user has deeply adopted {feature_name}.",
        },
    },
    "churn_signal": {
        "action": "research",
        "research_template": "A user with LTV ${ltv} just triggered a churn signal: {signal_type}. They've been a customer for {tenure_days} days. Research: What retention intervention works best for users at this LTV and tenure? Draft 3 personalized re-engagement messages.",
    },
}

class WebhookHandler(BaseHTTPRequestHandler):
    def do_POST(self):
        length = int(self.headers.get("Content-Length", 0))
        body = json.loads(self.rfile.read(length)) if length else {}

        event_type = body.get("event", body.get("type", ""))
        properties = body.get("properties", {})
        traits = body.get("traits", body.get("context", {}).get("traits", {}))
        user_id = body.get("userId", body.get("anonymousId", "unknown"))

        merged = {**properties, **traits, "user_id": user_id}

        if event_type in TRIGGER_EVENTS:
            config = TRIGGER_EVENTS[event_type]
            print(f"\n[TRIGGER] {event_type} from user {user_id}")

            if config["action"] == "create_persona":
                tmpl = config["persona_template"]
                name = f"{tmpl['name_prefix']} — {user_id[:12]}"
                desc = tmpl["description_template"].format(**{k: merged.get(k, "unknown") for k in ["user_id", "plan", "source", "milestone", "feature_name"]})

                persona = requests.post(f"{MB}/personas", headers=MH, json={
                    "name": name,
                    "description": desc,
                    "psychographic": {"trigger_event": event_type, **{k: v for k, v in merged.items() if isinstance(v, (str, int, float))}},
                }).json()
                print(f"  Created persona: {persona.get('id')} — {name}")

            elif config["action"] == "research":
                safe_vals = {k: str(merged.get(k, "unknown")) for k in ["previous_plan", "new_plan", "ltv", "signal_type", "tenure_days"]}
                message = config["research_template"].format(**safe_vals)

                mave = requests.post(f"{MB}/mave/chat", headers=MH, json={"message": message}).json()
                print(f"  Research result: {mave.get('content', '')[:200]}")

        self.send_response(200)
        self.end_headers()
        self.wfile.write(b'{"status":"ok"}')

    def log_message(self, format, *args):
        pass

PORT = int(os.environ.get("WEBHOOK_PORT", "8080"))
print(f"Listening for Segment webhooks on port {PORT}")
print(f"Trigger events: {', '.join(TRIGGER_EVENTS.keys())}")
server = HTTPServer(("0.0.0.0", PORT), WebhookHandler)
server.serve_forever()

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

const TRIGGERS = {
  trial_started: {
    action: "create_persona",
    namePrefix: "Segment RT: Trial User",
    descTemplate: (d) => `Trial started by ${d.user_id}. Plan: ${d.plan || "unknown"}. Source: ${d.source || "unknown"}.`,
  },
  plan_upgraded: {
    action: "research",
    msgTemplate: (d) => `User upgraded from ${d.previous_plan || "free"} to ${d.new_plan || "paid"}. Research: upgrade motivations, expected features, churn risk in first 7 days post-upgrade.`,
  },
  feature_milestone: {
    action: "create_persona",
    namePrefix: "Segment RT: Feature Champion",
    descTemplate: (d) => `Power user reached ${d.milestone || "unknown"} milestone for ${d.feature_name || "unknown"}.`,
  },
  churn_signal: {
    action: "research",
    msgTemplate: (d) => `Churn signal from user with LTV $${d.ltv || 0}: ${d.signal_type || "unknown"}. Tenure: ${d.tenure_days || 0} days. Research retention interventions + 3 re-engagement messages.`,
  },
};

const http = await import("http");
const PORT = parseInt(process.env.WEBHOOK_PORT || "8080");

const server = http.createServer(async (req, res) => {
  if (req.method !== "POST") { res.writeHead(405); res.end(); return; }

  let body = "";
  for await (const chunk of req) body += chunk;
  const data = JSON.parse(body || "{}");

  const eventType = data.event || data.type || "";
  const merged = { ...(data.properties || {}), ...(data.traits || {}), user_id: data.userId || data.anonymousId || "unknown" };

  if (TRIGGERS[eventType]) {
    const cfg = TRIGGERS[eventType];
    console.log(`\n[TRIGGER] ${eventType} from ${merged.user_id}`);

    if (cfg.action === "create_persona") {
      const name = `${cfg.namePrefix} — ${merged.user_id.slice(0, 12)}`;
      const p = await fetch(`${MB}/personas`, { method: "POST", headers: MH,
        body: JSON.stringify({
          name, description: cfg.descTemplate(merged),
          psychographic: { trigger_event: eventType },
        }),
      }).then((r) => r.json());
      console.log(`  Created persona: ${p.id}`);
    } else {
      const mave = await fetch(`${MB}/mave/chat`, { method: "POST", headers: MH,
        body: JSON.stringify({ message: cfg.msgTemplate(merged) }),
      }).then((r) => r.json());
      console.log(`  Research: ${(mave.content || "").slice(0, 200)}`);
    }
  }

  res.writeHead(200, { "Content-Type": "application/json" });
  res.end('{"status":"ok"}');
});

server.listen(PORT, () => {
  console.log(`Listening for Segment webhooks on port ${PORT}`);
  console.log(`Triggers: ${Object.keys(TRIGGERS).join(", ")}`);
});