/* global React */ const { useState: useStateA, useEffect: useEffectA, useMemo: useMemoA, useRef: useRefA, useCallback: useCallbackA } = React; const DD = window.NEXUS_DATA; const UU = window.NEXUS_UTIL; async function fetchJson(url, options = {}) { const controller = new AbortController(); const timer = setTimeout(() => controller.abort(), options.timeoutMs || 3500); try { const res = await fetch(url, { ...options, signal: controller.signal }); if (!res.ok) throw new Error(`${res.status} ${res.statusText}`); return await res.json(); } finally { clearTimeout(timer); } } function confidenceToNumber(confidence) { if (typeof confidence === "number") return confidence; return confidence === "high" ? 0.88 : confidence === "medium" ? 0.68 : 0.48; } function mapLiveSignal(lastSignal) { if (!lastSignal) return null; const action = String(lastSignal.action || "hold").toUpperCase(); const positions = Object.values(lastSignal.suggestedPositions || {}); const positionDelta = positions.length ? positions.reduce((sum, p) => sum + (p.direction === "long" ? p.weight : p.direction === "short" ? -p.weight : 0), 0) / positions.length : 0; return { decision: ["BUY", "SELL", "HOLD"].includes(action) ? action : "HOLD", confidence: confidenceToNumber(lastSignal.confidence), risk: String(lastSignal.riskLevel || "moderate"), rationale: lastSignal.reasoning || "Live strategy signal returned by the Quant Agent.", generatedAt: lastSignal.timestamp ? Date.parse(lastSignal.timestamp) : Date.now(), positionDelta, }; } function mapCallbacksToJobs(callbacks, fallbackWorker) { return callbacks.map((callback) => { const settlement = callback.settlement || {}; const symbols = Object.keys(callback.result?.scores || {}); return { jobId: callback.jobId, status: settlement.status === "settled" ? "Disbursed" : "Proof Submitted", amountLamports: settlement.paymentAmountLamports || 500_000, worker: fallbackWorker, buyer: DD.QUANT_PUBKEY, proofHash: callback.proofHash, initSig: null, proofSig: null, disburseSig: settlement.disburseTxSignature || null, createdAt: callback.completedAt || Date.now(), completedAt: callback.completedAt || Date.now(), inferenceMs: callback.result?.inferenceMs || null, model: callback.result?.modelVersion || "finbert", backend: callback.result?.inferenceBackend || "unknown", asset: symbols.join("/") || "ALL", }; }); } function mapHealth(health) { if (!health?.ok) return null; const isHfApi = health.inferenceBackend === "hf_api"; const isNpu = health.npuAvailable; return { status: "online", backend: health.inferenceBackend, model: "finbert-1.0", npu: { // Give the drift animation a realistic baseline — 0 looks broken on non-NPU temp_c: health.npuTempC ?? health.cpuTempC ?? (isNpu ? 52 : isHfApi ? 44 : 38), util: isNpu ? 0.72 : isHfApi ? 0.31 : 0.04, mem_mb: Math.max(0, 8192 - (health.memoryFreeMb || 0)), mem_total_mb: 8192, }, uptime_s: health.uptimeSeconds || 0, inference_p50_ms: 0, inference_p99_ms: 0, loaded: true, }; } function emptyLiveSignal() { return { decision: "HOLD", confidence: 0, risk: "waiting", rationale: "No live strategy signal yet. Trigger an analysis cycle to generate one from the Quant Agent.", generatedAt: Date.now(), positionDelta: 0, }; } // ============================================================ // Top navigation // ============================================================ function TopNav({ route, setRoute, healthOnline }) { const tabs = [ { id: "/", label: "Dashboard", icon: }, { id: "/agents", label: "Agents", icon: }, { id: "/escrow", label: "Escrow", icon: }, ]; return (
{/* Logo */}
NEXUS·402 DEVNET
{/* Tabs */} {/* Mobile menu */}
{/* RPC status */}
api.devnet.solana.com
{/* Wallet badges */}
); } function DataSourceBanner({ source, liveError }) { const live = source === "live"; return (
{live ? "LIVE AGENT DATA" : "DEMO FALLBACK DATA"} {live ? "Polling Quant and Analyst services." : "Start the local agents or set ?quant= and ?analyst= endpoints."} {!live && liveError && ( {liveError} )}
); } function WalletBadge({ label, color, pubkey }) { return (
{label} {UU.truncatePubkey(pubkey, 4, 4)}
); } // ============================================================ // Footer // ============================================================ function Footer() { return (
} /> 402 } />
v0.1.4-devnet commit 9a3c4f1 build {Date.now() % 100000}
); } function PoweredBy({ label, logo }) { return (
powered by {logo} {label}
); } // ============================================================ // Polling sim & cycle simulator // ============================================================ function useNexusSim() { const [jobs, setJobs] = useStateA(DD.SEED_JOBS); const [sentiment, setSentiment] = useStateA(DD.SEED_SENTIMENT); const [signal, setSignal] = useStateA(DD.SEED_SIGNAL); const [health, setHealth] = useStateA(DD.SEED_HEALTH); const [dataSource, setDataSource] = useStateA("demo"); const [liveError, setLiveError] = useStateA(""); const [cycleState, setCycleState] = useStateA({ running: false, activePhase: -1, completedThrough: -1, progress: 0, artifacts: null, }); // Subtle live drift on health every 2s (polling sim) useEffectA(() => { const t = setInterval(() => { setHealth(h => ({ ...h, npu: { ...h.npu, temp_c: Math.max(38, Math.min(72, h.npu.temp_c + (Math.random() - 0.5) * 0.8)), util: Math.max(0.05, Math.min(0.95, h.npu.util + (Math.random() - 0.5) * 0.06)), mem_mb: Math.max(2400, Math.min(7200, h.npu.mem_mb + Math.round((Math.random() - 0.5) * 80))), }, uptime_s: h.uptime_s + 2, inference_p50_ms: Math.max(140, Math.min(260, h.inference_p50_ms + Math.round((Math.random()-0.5)*6))), })); }, 2000); return () => clearInterval(t); }, []); useEffectA(() => { let cancelled = false; const pollLive = async () => { try { const [quantHealth, analystHealth, strategy] = await Promise.all([ fetchJson(`${DD.NEXUS_CONFIG.quantEndpoint}/api/v1/health`), fetchJson(`${DD.NEXUS_CONFIG.analystEndpoint}/api/v1/health`), fetchJson(`${DD.NEXUS_CONFIG.quantEndpoint}/api/v1/strategy/status`), ]); if (cancelled) return; const liveHealth = mapHealth(analystHealth); const liveSignal = mapLiveSignal(strategy.lastSignal); const liveJobs = mapCallbacksToJobs(strategy.callbacks || [], analystHealth.pubkey || DD.ANALYST_PUBKEY); const latestCallback = (strategy.callbacks || [])[0]; setDataSource("live"); setLiveError(""); if (liveHealth) setHealth(h => ({ ...h, ...liveHealth, inference_p50_ms: latestCallback?.result?.inferenceMs || h.inference_p50_ms })); setSignal(liveSignal || emptyLiveSignal()); if (latestCallback?.result?.scores && Object.keys(latestCallback.result.scores).length > 0) { const raw = latestCallback.result.scores; setSentiment(prev => { const next = { ...prev }; for (const [sym, sc] of Object.entries(raw)) { // Skip zero-confidence results — inference failed, keep last good data if (!sc.confidence || !sc.score) continue; next[sym] = { label: sc.label, score: sc.score, confidence: sc.confidence, samples: (prev[sym]?.samples ?? 0) + 1 }; } return next; }); } setJobs(liveJobs); } catch (err) { if (cancelled) return; setDataSource("demo"); setLiveError(String(err.message || err)); } }; pollLive(); const t = setInterval(pollLive, 5000); return () => { cancelled = true; clearInterval(t); }; }, []); // Re-render every 30s so timeAgo updates useEffectA(() => { const t = setInterval(() => setJobs(js => [...js]), 30000); return () => clearInterval(t); }, []); // Trigger cycle simulator const triggerCycle = useCallbackA(async () => { if (cycleState.running) return; // In live mode fire the real trigger in background — animation runs regardless if (dataSource === "live") { fetchJson(`${DD.NEXUS_CONFIG.quantEndpoint}/api/v1/strategy/trigger`, { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify({ symbols: ["BTC", "ETH", "SOL"], lookbackHours: 24 }), timeoutMs: 5000, }).catch(err => setLiveError(String(err.message || err))); } const asset = dataSource === "live" ? "BTC/ETH/SOL" : ["BTC", "ETH", "SOL"][Math.floor(Math.random()*3)]; const seed = Math.random(); const initSig = UU.genTxSig(seed + 0.1); const escrowSig = initSig; // same tx initialises the escrow const proofHash = UU.genHash(seed + 0.2); const proofSig = UU.genTxSig(seed + 0.3); const disburseSig = UU.genTxSig(seed + 0.4); const jobId = UU.genHash(seed + 0.05); const newJob = { jobId, status: "Initialized", amountLamports: 25_000_000, worker: DD.ANALYST_PUBKEY, buyer: DD.QUANT_PUBKEY, proofHash: null, initSig, proofSig: null, disburseSig: null, createdAt: Date.now(), completedAt: null, inferenceMs: null, model: "qwen2.5-7b-instruct", backend: "hailo8_npu", asset, }; setJobs(js => [newJob, ...js]); const artifacts = { asset }; setCycleState({ running: true, activePhase: 0, completedThrough: -1, progress: 0, artifacts }); // Phase timeline (ms after start) — inference held longer to reflect real HF API latency const TL = [ { at: 250, phase: 0, complete: -1, progress: 5 }, // request { at: 700, phase: 1, complete: 0, progress: 14 }, // 402 invoice { at: 1300, phase: 2, complete: 1, progress: 26, artifacts: { ...artifacts, escrowSig } }, // escrow lock { at: 1600, phase: 2, complete: 2, progress: 32, statusUpdate: { status: "Escrow Locked" } }, { at: 2100, phase: 3, complete: 2, progress: 44 }, // inference — holds ~9s { at: 11000, phase: 4, complete: 3, progress: 70, artifacts: { ...artifacts, escrowSig, proofHash } }, // proof { at: 11400, phase: 4, complete: 4, progress: 78, statusUpdate: { status: "Proof Submitted", proofHash, proofSig, inferenceMs: 14000 + Math.round(Math.random()*3000) } }, { at: 12500, phase: 5, complete: 4, progress: 90 }, // disburse { at: 13800, phase: 5, complete: 5, progress: 100, artifacts: { ...artifacts, escrowSig, proofHash, disburseSig }, statusUpdate: { status: "Disbursed", disburseSig, completedAt: Date.now() + 13800 } }, { at: 15500, finish: true }, ]; const start = Date.now(); const timers = []; TL.forEach(step => { const t = setTimeout(() => { if (step.finish) { // After short pause, idle and update sentiment + signal setCycleState({ running: false, activePhase: -1, completedThrough: -1, progress: 0, artifacts: null }); // gentle sentiment refresh setSentiment(s => ({ BTC: jitter(s.BTC), ETH: jitter(s.ETH), SOL: jitter(s.SOL), })); setSignal(prev => { const decisions = ["BUY", "SELL", "HOLD"]; const d = decisions[Math.floor(Math.random()*3)]; return { decision: d, confidence: 0.6 + Math.random() * 0.35, risk: ["balanced", "aggressive", "conservative"][Math.floor(Math.random()*3)], rationale: `${asset} signal regenerated after cycle ${UU.truncatePubkey(jobId, 6, 4)}. ${d === "BUY" ? "Momentum surfacing across cross-asset basket." : d === "SELL" ? "Volume divergence + overbought RSI on SOL pair." : "Mixed indicators — holding net exposure."}`, generatedAt: Date.now(), positionDelta: (Math.random() - 0.5) * 0.8, }; }); return; } setCycleState(prev => ({ ...prev, activePhase: step.phase, completedThrough: step.complete, progress: step.progress, artifacts: step.artifacts || prev.artifacts, })); if (step.statusUpdate) { setJobs(js => js.map(j => j.jobId === jobId ? { ...j, ...step.statusUpdate } : j)); } }, step.at); timers.push(t); }); }, [cycleState.running, dataSource]); return { jobs, sentiment, signal, health, cycleState, triggerCycle, dataSource, liveError }; } function jitter(s) { const score = Math.max(0.05, Math.min(0.95, s.score + (Math.random() - 0.5) * 0.04)); const label = score > 0.6 ? "positive" : score < 0.4 ? "negative" : "neutral"; return { label, score, confidence: Math.max(0.4, Math.min(0.99, s.confidence + (Math.random()-0.5)*0.03)), samples: s.samples + Math.floor(Math.random() * 12), }; } // ============================================================ // App // ============================================================ function App() { const [route, setRoute] = useStateA(() => { const h = window.location.hash.replace(/^#/, ""); if (["/", "/agents", "/escrow"].includes(h)) return h; return "/"; }); useEffectA(() => { const onHash = () => { const h = window.location.hash.replace(/^#/, "") || "/"; if (["/", "/agents", "/escrow"].includes(h)) setRoute(h); }; window.addEventListener("hashchange", onHash); return () => window.removeEventListener("hashchange", onHash); }, []); const sim = useNexusSim(); const screenLabel = route === "/" ? "01 Dashboard" : route === "/agents" ? "02 Agents" : "03 Escrow"; return (
{route === "/" && ( )} {route === "/agents" && } {route === "/escrow" && }
); } // Mount const root = ReactDOM.createRoot(document.getElementById("root")); root.render();