@@ -5981,6 +6031,14 @@ tempest.operators.
spawn(
'scan
if (data.operators) {
this._updateOperatorStatusUI(data.operators);
}
+ window.updateLiveScanStatus?.(data);
+ } catch {}
+ });
+
+ this._eventSource.addEventListener('scan:progress', (e) => {
+ try {
+ const data = JSON.parse(e.data);
+ window.recordLiveScanEvent?.(data);
} catch {}
});
@@ -6909,13 +6967,205 @@ Correlating findings across agents, identifying patterns, producing actionable i
}));
}
+ const LiveScanState = {
+ status: null,
+ events: [],
+ seen: new Set()
+ };
+
+ function liveScanEscape(value) {
+ return String(value ?? '').replace(/[&<>"']/g, ch => ({
+ '&': '&', '<': '<', '>': '>', '"': '"', "'": '''
+ }[ch]));
+ }
+
+ function liveScanTime(ts) {
+ const date = ts ? new Date(ts) : new Date();
+ return date.toLocaleTimeString([], { hour: '2-digit', minute: '2-digit', second: '2-digit' });
+ }
+
+ function liveScanStatusColor(status) {
+ const s = String(status || '').toLowerCase();
+ if (s === 'completed' || s === 'idle') return '#00ff88';
+ if (s === 'failed' || s === 'burned') return '#ff4444';
+ if (s === 'running' || s === 'tasked' || s === 'executing' || s === 'in_progress') return '#00aaff';
+ if (s === 'pending' || s === 'cooldown') return '#ffaa00';
+ return 'var(--text-secondary)';
+ }
+
+ function liveScanKindLabel(kind) {
+ return ({
+ task_started: 'START',
+ thinking: 'THINK',
+ tool_call: 'TOOL',
+ tool_result: 'RESULT',
+ task_completed: 'DONE',
+ task_failed: 'FAIL'
+ })[kind] || String(kind || 'EVENT').toUpperCase();
+ }
+
+ function liveScanMergeEvents(events) {
+ if (!Array.isArray(events)) return;
+ events.forEach(ev => {
+ const id = ev?.id || `${ev?.timestamp || Date.now()}-${ev?.operatorId || ''}-${ev?.kind || ''}-${ev?.detail || ''}`;
+ if (LiveScanState.seen.has(id)) return;
+ LiveScanState.seen.add(id);
+ LiveScanState.events.push({ ...ev, id });
+ });
+ LiveScanState.events.sort((a, b) => (a.timestamp || 0) - (b.timestamp || 0));
+ if (LiveScanState.events.length > 300) {
+ const trimmed = LiveScanState.events.splice(0, LiveScanState.events.length - 300);
+ trimmed.forEach(ev => LiveScanState.seen.delete(ev.id));
+ }
+ }
+
+ window.recordLiveScanEvent = function recordLiveScanEvent(event) {
+ liveScanMergeEvents([event]);
+ renderLiveScanPage();
+ };
+
+ window.updateLiveScanStatus = function updateLiveScanStatus(status) {
+ LiveScanState.status = status || null;
+ liveScanMergeEvents(status?.progress);
+ renderLiveScanPage();
+ };
+
+ window.refreshLiveScanPage = async function refreshLiveScanPage() {
+ const status = await T3MP3ST_API.get('/api/mission/status');
+ window.updateLiveScanStatus(status);
+ };
+
+ window.clearLiveScanFeed = function clearLiveScanFeed() {
+ LiveScanState.events = [];
+ LiveScanState.seen = new Set();
+ renderLiveScanPage();
+ };
+
+ function renderLiveScanPage() {
+ const page = document.getElementById('page-live-scan');
+ if (!page) return;
+
+ const status = LiveScanState.status || {};
+ const active = status.active ?? status.running ?? false;
+ const mission = status.mission || {};
+ const operators = Array.isArray(status.operators?.details) ? status.operators.details : [];
+ const operatorSummary = status.operators?.summary || status.operators || {};
+ const tasks = Array.isArray(status.tasks) ? status.tasks : [];
+ const events = LiveScanState.events.slice().reverse();
+ const currentPhase = mission.currentPhase || status.currentPhase || 'none';
+ const progress = typeof mission.progress === 'number' ? `${Math.round(mission.progress)}%` : '-';
+
+ const summary = document.getElementById('liveScanSummary');
+ if (summary) {
+ const cells = [
+ ['State', status.paused ? 'Paused' : (active ? 'Running' : 'Stopped'), active ? '#00ff88' : '#ffaa00'],
+ ['Phase', currentPhase, '#00aaff'],
+ ['Progress', progress, '#00ff88'],
+ ['Operators', String(operatorSummary.total ?? operators.length ?? 0), '#ffaa00'],
+ ['Tasks', String(tasks.length), '#00aaff'],
+ ['Stall', status.stallReason || '-', status.stallReason ? '#ff4444' : 'var(--text-secondary)']
+ ];
+ summary.innerHTML = cells.map(([label, value, color]) => `
+
+
${liveScanEscape(label)}
+
${liveScanEscape(value)}
+
No operator details available yet.
';
+ } else {
+ opEl.innerHTML = operators.map(op => {
+ const statusColor = liveScanStatusColor(op.status);
+ return `
+
+
+
${liveScanEscape(op.callsign || op.id)}
+
${liveScanEscape(op.archetype || 'operator')}
+
${Number(op.completedTasks || 0)} done ยท ${Number(op.failedTasks || 0)} failed ยท risk ${Number(op.detectionRisk || 0)}
+
+
${liveScanEscape(op.status || 'unknown')}
+
No mission tasks are queued.
';
+ } else {
+ taskEl.innerHTML = tasks.map(task => {
+ const color = liveScanStatusColor(task.status);
+ const output = task.result?.error || task.result?.output || '';
+ return `
+
+
+
${liveScanEscape(task.name || task.id)}
+
${liveScanEscape(task.phase || '-')} ยท ${liveScanEscape(task.operatorType || '-')} ${task.assignedTo ? 'ยท ' + liveScanEscape(task.assignedTo) : ''}
+ ${output ? `
${liveScanEscape(output).slice(0, 260)}
` : ''}
+
+
${liveScanEscape(task.status || 'unknown')}
+
No live reasoning events yet. Start or refresh a scan to populate this stream.
';
+ } else {
+ feed.innerHTML = events.map(ev => {
+ const color = ev.kind === 'task_failed' || ev.success === false ? '#ff6666'
+ : ev.kind === 'tool_call' ? '#ffaa00'
+ : ev.kind === 'tool_result' ? '#00aaff'
+ : ev.kind === 'thinking' ? '#cfd6e6'
+ : '#00ff88';
+ const sourceBadge = ev.source === 'backend_seeded'
+ ? 'backend-seeded'
+ : '';
+ return `
+
+
${liveScanTime(ev.timestamp)}
+
${liveScanEscape(liveScanKindLabel(ev.kind))}
+
${liveScanEscape(ev.callsign || ev.archetype || ev.operatorId || '-')}
+
+
${liveScanEscape(ev.taskName || ev.toolName || '-')}${sourceBadge}
+
${liveScanEscape(ev.detail || '')}
+
+