/* ProofSource — Operator Console. Real editable question, smart routing. Exports window.AppConsole. */ const RUN_BUY_KEYWORDS = ['licens', 'copyright', 'creator', 'content', 'royalt', 'publish', 'journalist', 'pay', 'citation', 'attribution', 'monetiz', 'writer', 'article', 'source', 'knowledge']; const RUN_SKIP_KEYWORDS = ['recipe', 'food', 'cook', 'sport', 'weather', 'movie', 'song', 'celebrity', 'game', 'bread', 'cake', 'pizza']; function decideBuyReuseSkip(question, prevQuestions) { const q = question.toLowerCase(); // REUSE: very similar to a previous question const similar = prevQuestions.find((p) => { const words = q.split(/\s+/).filter((w) => w.length > 4); const matches = words.filter((w) => p.toLowerCase().includes(w)); return matches.length >= Math.min(3, Math.floor(words.length * 0.5)); }); if (similar) return 'royalties'; // maps to REUSE scenario // SKIP: clearly off-topic if (RUN_SKIP_KEYWORDS.some((k) => q.includes(k))) return 'sourdough'; // maps to SKIP // BUY: relevant topic if (RUN_BUY_KEYWORDS.some((k) => q.includes(k))) return 'licensing'; // maps to BUY // default: BUY for unknown topics return 'licensing'; } function RelBar({ v }) { return (
{Math.round(v * 100)}%
); } const ACTION_COLOR = { BUY: 'var(--buy)', REUSE: 'var(--reuse)', SKIP: 'var(--faint)', BLOCK: 'var(--block)' }; function AppConsole({ go }) { const session = useStore((s) => s.session); const operator = useStore((s) => s.operator); const { mandate, spent, runs } = operator; const totals = window.Store.operatorTotals(); const workspaceId = session?.workspaceId || 'ws_demo'; const [question, setQuestion] = useState(''); const [running, setRunning] = useState(false); const [reached, setReached] = useState(-1); const [editMandate, setEditMandate] = useState(false); const [mandateDraft, setMandateDraft] = useState(mandate); const [error, setError] = useState(''); const [apiRemaining, setApiRemaining] = useState(null); // real remaining budget from API // Load real mandate + remaining budget from API on mount useEffect(() => { window.PS_API.getMandate(workspaceId).then((m) => { if (m.error) return; window.Store.setMandate({ budget: Number(m.budgetUsdc || mandate.budget), ceiling: Number(m.perTaskMaxUsdc || mandate.ceiling), maxPer: Number(m.maxPricePerSourceUsdc || mandate.maxPer), requireCite: m.requireCitation ?? mandate.requireCite }); if (m.budgetRemainingUsdc != null) setApiRemaining(Number(m.budgetRemainingUsdc)); }).catch(() => {}); }, [workspaceId]); const [result, setResult] = useState(null); const [replaySteps, setReplaySteps] = useState([]); const [receiptChain, setReceiptChain] = useState(null); // { explorerUrl, transactionHash } const GENERIC_STEPS = ['discover', 'decide', 'policy', 'authorize', 'deliver', 'verify', 'release', 'receipt']; const steps = replaySteps.length > 0 ? replaySteps : GENERIC_STEPS; const done = result && reached >= steps.length && reached > 0; const showTable = (reached >= 2 || done) && !!result; const idle = reached <= 0 && !running && !result; // Replay animation tick useEffect(() => { if (!running || reached < 0) return; if (reached >= steps.length) { setRunning(false); return; } const tid = setTimeout(() => setReached((r) => r + 1), 420); return () => clearTimeout(tid); }, [running, reached, steps.length]); async function startRun() { const q = question.trim(); if (!q) return; setError(''); setResult(null); setReceiptChain(null); setReached(0); setRunning(true); try { const data = await window.PS_API.runAgent({ workspaceId, agentId: 'agent_research_01', question: q }); setResult(data); // Pipeline renders each step as plain text (and compares it against // gateStep === 'verify' for highlighting) -- it must be an array of // lowercase step-name strings, not objects. Passing {label,status,detail} // objects here crashed React ("Objects are not valid as a React child") // the instant a real run completed, taking the whole page blank. const realSteps = (data.trace || []).map((t) => t.step); setReplaySteps(realSteps.length > 0 ? realSteps : GENERIC_STEPS); setReached(0); const action = data.decision?.action || 'SKIP'; const amount = Number(data.spend?.totalUsdc || 0); window.Store.recordRun({ q, action, amount, paid: data.sources?.[0]?.providerName || null, verified: data.sources?.[0]?.paymentStatus === 'released' }); // Update remaining budget from API response if (data.decision?.budgetRemainingUsdc != null) setApiRemaining(Number(data.decision.budgetRemainingUsdc)); // Fetch receipt to get Arc explorer URL const receiptId = data.sources?.[0]?.receiptId; if (receiptId) { window.PS_API.request('/receipts/' + receiptId).then((r) => { if (r.chainReference?.explorerUrl) setReceiptChain(r.chainReference); }).catch(() => {}); } } catch (err) { setError(err.message || 'Agent run failed.'); setRunning(false); setReached(-1); } } async function saveMandate() { const patch = { workspaceId, budgetUsdc: String(mandateDraft.budget), perTaskMaxUsdc: String(mandateDraft.ceiling), maxPricePerSourceUsdc: String(mandateDraft.maxPer), requireCitation: mandateDraft.requireCite }; try { await window.PS_API.setMandate(patch); setApiRemaining(+mandateDraft.budget); } catch {} window.Store.setMandate({ budget: +mandateDraft.budget, ceiling: +mandateDraft.ceiling, maxPer: +mandateDraft.maxPer, requireCite: mandateDraft.requireCite }); setEditMandate(false); } // Derive display values from real API result only — no fake fallbacks const action = result?.decision?.action || null; const badgeTone = action === 'BUY' ? 'buy' : action === 'REUSE' ? 'reuse' : 'skip'; const reasoning = result?.decision?.reasoning || ''; const candidates = result?.decision?.scores?.map((s) => ({ work: s.title || s.resourceId, creator: s.providerId, rel: s.relevance || 0, price: Number(s.priceUsdc || 0), tone: s.verdict === 'bought' ? 'buy' : s.verdict === 'reused' ? 'reuse' : 'skip', verdict: s.verdict || 'skipped', })) || []; const answer = result?.answer || ''; const paidSource = result?.sources?.[0]; const receiptId = paidSource?.receiptId; const deliveryHash = paidSource?.deliveryHash; const settledAmount = Number(result?.spend?.totalUsdc || 0); // When the agent decided BUY but nothing settled, the real reason lives in the trace // (policy rejected the purchase, verification failed, or release errored) — not in // decision.reasoning, which only explains why this source was *chosen*, not why the // resulting purchase didn't clear. Falling back to a generic "didn't clear the // relevance floor" message here was actively misleading for a real rejected/failed // purchase attempt (e.g. a duplicate-request guard, or a verification failure). const failedStep = (result?.trace || []).find((t) => t.status === 'REJECTED' || t.status === 'failed'); const verifyStep = (result?.trace || []).find((t) => t.step === 'verify'); const verificationLabel = verifyStep ? verifyStep.status : done ? 'n/a' : '—'; const noPaymentReason = action === 'REUSE' ? 'reused owned paid context.' : failedStep ? (failedStep.detail || `${failedStep.step} did not clear.`) : 'nothing cleared the relevance floor.'; const remaining = apiRemaining !== null ? apiRemaining : Math.max(0, mandate.budget - spent); const budgetPct = Math.min(100, Math.round(((mandate.budget - remaining) / mandate.budget) * 100)); const explorerUrl = receiptChain?.explorerUrl || null; const fieldS = { background: 'rgba(255,255,255,.04)', border: '1px solid rgba(255,255,255,.08)', borderRadius: 9, padding: '9px 12px', color: 'var(--text)', fontFamily: 'var(--font-mono)', fontSize: 13, width: '100%', outline: 'none' }; const labS = { fontSize: 11, color: 'var(--faint)', textTransform: 'uppercase', letterSpacing: '.07em', fontWeight: 700, display: 'block', marginBottom: 5 }; const SUGGESTIONS = [ 'What are the key arguments around AI content licensing?', 'How should music royalties be split by listener plays?', 'What is the best sourdough bread recipe?', ]; return (
{/* ── Page header ──────────────────────────────────────── */}
Research agent
{session && session.name}
Budget ${(mandate.budget || 0).toFixed(2)} · Ceiling ${(mandate.ceiling || 0).toFixed(2)} · Cite {mandate.requireCite ? 'required' : 'optional'}
Remaining
${remaining.toFixed(4)}
{ setEditMandate(true); setMandateDraft(mandate); }}>Edit
{/* ── Budget bar ───────────────────────────────────────── */}
${spent.toFixed(4)} spent${mandate.budget.toFixed(2)} budget
{/* ── Left: ask + results ──────────────────────────── */}
{/* Ask */}