/* Stratum Leads — Operations Console. Lead Intelligence: the source-discovery + scoring pipeline dashboard. Ported (UI/UX only) from the stale `stratum-lead-intelligence` concept — 100% mock, shaped to the Phase-2 read models (source_run_status, run_exception) so wiring is a drop-in. Workflow bridge: this surface produces freshly-scored candidates and hands them to Lead Review (leadops) via onPublishToReview — the same queue the verify/reject page consumes. That is the seam where the discovery workflow and the review workflow meet. */ /* Design-system components — each Babel script has its own scope, so every ops-*.jsx file must destructure what it needs from the namespace. */ const { NavItem, IconButton, Tabs, Button, Field, Card, Metric, StatusChip, TierBadge, ContactQuality, ProgressBar, SegmentedControl, Switch, EmptyState } = window.StratumLeadsDesignSystem_6367ed; const { I, Spinner } = window.OpsShared; const clone = (x) => JSON.parse(JSON.stringify(x)); const STAGE_TONE = { ok: "success", warn: "warning", blocked: "danger" }; const SOURCE_TONE = { healthy: "success", degraded: "warning", blocked: "danger" }; const SOURCE_LABEL = { healthy: "Healthy", degraded: "Degraded", blocked: "Blocked" }; const usdK = (n) => n ? "$" + Math.round(n / 1000).toLocaleString() + "k" : "—"; /* ---------------- Pipeline strip ---------------- */ function PipelineStrip({ pipeline, run, activeStage }) { return (
{pipeline.map((s, i) => { const isActive = run === "running" && i === activeStage; const isDone = run === "done" || run === "running" && i < activeStage; const dotTone = STAGE_TONE[s.status] || "neutral"; return (
{isActive ? : I(s.icon, { width: 15 })} {isDone ? I("check", { width: 15, color: "var(--success)" }) : }
{s.label} {s.count.toLocaleString()} {s.note}
{i < pipeline.length - 1 &&
{I("chevron-right", { width: 16 })}
} ); })}
); } /* ---------------- Tier distribution ---------------- */ function TierDistribution({ dist }) { const max = Math.max(...dist.map((d) => d.count), 1); const total = dist.reduce((a, d) => a + d.count, 0); return (
{dist.map((d) => { const pct = Math.round(d.count / max * 100); const share = Math.round(d.count / total * 100); return (
{d.count} · {share}%
); })}
); } /* ---------------- Source run-status table ---------------- */ function SourceTable({ sources }) { return (
SourceTypeMethodFoundNewStatus
{sources.map((s, i) =>
{s.name} {s.region} {s.issue && {s.issue}} {s.kind} {s.method} {s.discovered} {s.newCount} {SOURCE_LABEL[s.status]} {s.lastRun} · next {s.nextRun}
)}
); } /* ---------------- Candidate batch → Lead Review ---------------- */ function CandidateBatch({ candidates, onSend, onOpenReview, sentBatch }) { if (candidates.length === 0) { return ( Open Lead Review : null} />); } return (
{candidates.map((c) =>
{c.address} {c.cityZip} · {c.trigger} {c.score}/100 {usdK(c.estValue)}
)}
); } /* ---------------- Page ---------------- */ function LeadIntelPage({ intel, onPublishToReview, onNavigate, reviewPendingCount }) { const [equityFloor, setEquityFloor] = React.useState(intel.equityFloor); const [run, setRun] = React.useState("idle"); const [activeStage, setActiveStage] = React.useState(-1); const [candidates, setCandidates] = React.useState(() => clone(intel.candidates)); const [lastRun, setLastRun] = React.useState(() => clone(intel.lastRun)); const [sentBatch, setSentBatch] = React.useState(0); const timers = React.useRef([]); React.useEffect(refresh, [run, activeStage, candidates.length, sentBatch]); React.useEffect(() => () => timers.current.forEach(clearTimeout), []); const running = run === "running"; const runPass = () => { if (running) return; timers.current.forEach(clearTimeout); timers.current = []; setRun("running"); setActiveStage(0); setSentBatch(0); const stepMs = 520; intel.pipeline.forEach((_, i) => { timers.current.push(setTimeout(() => setActiveStage(i), i * stepMs)); }); timers.current.push(setTimeout(() => { setRun("done"); setActiveStage(intel.pipeline.length - 1); setLastRun((r) => ({ ...r, at: "Just now" })); setCandidates(clone(intel.candidates)); }, intel.pipeline.length * stepMs)); }; const sendToReview = () => { if (candidates.length === 0) return; onPublishToReview(candidates); setSentBatch(candidates.length); setCandidates([]); }; return (
: I("radar", { width: 15 })} onClick={runPass}> {running ? "Running pass…" : "Run Source Intelligence Pass"} } />
onNavigate("leadops")} onKeyDown={(e) => {if (e.key === "Enter" || e.key === " ") {e.preventDefault();onNavigate("leadops");}}} style={{ display: "grid", cursor: "pointer" }}>
Equity floor setEquityFloor(Number(v))} options={[{ value: "25000", label: "$25k" }, { value: "50000", label: "$50k" }, { value: "100000", label: "$100k" }]} />
}> a + d.count, 0)} scored leads, banded`}> 0 ? {candidates.length} new : null}> onNavigate("leadops")} sentBatch={sentBatch} />
); } Object.assign(window, { OpsIntel: { LeadIntelPage } });