Revert "Improve event pipeline and dashboard UX"

This reverts commit 383ceca.

Author: Peter-SL5

otel-collector.yaml

@@ -4,6 +4,11 @@ receivers:
       grpc:
         endpoint: 0.0.0.0:4317
 
+processors:
+  batch:
+    timeout: 1s
+    send_batch_size: 50
+
 exporters:
   otlphttp/dashboard:
     endpoint: http://dashboard:3000
@@ -15,6 +20,7 @@ service:
   pipelines:
     traces:
       receivers: [otlp]
+      processors: [batch]
       exporters: [otlphttp/dashboard]
 
   telemetry:

public/index.html

@@ -649,15 +649,13 @@
 
     switch (eventType) {
       case 'agent.created':
-        return (attrs['user.id'] || '') + ' → ' + (attrs['agent.id'] || '');
+        return 'Agent ' + (attrs['agent.id'] || '') + ' provisioned';
       case 'agent.terminated':
         return 'Agent ' + (attrs['agent.id'] || '') + ' terminated';
       case 'request.allowed':
         return (attrs['http.host'] || '') + ' -- allowed';
       case 'request.denied':
         return (attrs['http.host'] || '') + ' -- denied' + (attrs['denial.reason'] ? ': ' + attrs['denial.reason'] : '');
-      case 'agent.prompted':
-        return (attrs['user.id'] || 'user') + ' → ' + (attrs['agent.id'] || 'agent');
       default:
         if (attrs['agent.id']) return eventType + ' for ' + attrs['agent.id'];
         return eventType;
@@ -713,11 +711,12 @@
       if (userId) Topology.removeUserNode(userId);
     }
 
-    // agent.prompted: user→platform then platform→agent sequentially
-    if (eventType === 'agent.prompted') {
+    // User actions — light up the user→platform edge.
+    if (eventType === 'agent.requested' || eventType === 'prompt.sent' || eventType === 'permission.change_requested' || eventType === 'termination.requested') {
       const userId = attrs['user.id'] || '';
-      if (userId) Topology.highlightEdge(userId, Topology.EDGE_HIGHLIGHT_MS);
-      if (agentId) setTimeout(() => Topology.highlightEdge('platform-' + agentId, Topology.EDGE_HIGHLIGHT_MS), 400);
+      if (userId) {
+        Topology.highlightEdge(userId, Topology.EDGE_HIGHLIGHT_MS);
+      }
     }
 
     // Agent lifecycle. Light up the platform→agent edge: the platform is
@@ -732,6 +731,11 @@
       Topology.removeAgentRuntimeNode(agentId);
     }
 
+    // Prompt delivered: platform exec'd into the agent via the supervisor.
+    if (eventType === 'agent.prompted') {
+      if (agentId) Topology.highlightEdge('platform-' + agentId, Topology.EDGE_HIGHLIGHT_MS);
+    }
+
     // Gateway decisions
     if (eventType === 'auth.allowed' || eventType === 'request.allowed' || eventType === 'request.denied' || eventType === 'permission.checked') {
       const decision = {

server.js

@@ -228,27 +228,46 @@ const server = http.createServer(async (req, res) => {
       }
     }
 
-    // POST /api/reset - trigger full demo reset via host-side reset server
+    // POST /api/reset - proxy to demo-admin reset endpoint
     if (pathName === '/api/reset' && method === 'POST') {
-      const resetServerUrl = process.env.RESET_SERVER_URL || 'http://host.docker.internal:8765/reset';
-      try {
-        await new Promise((resolve, reject) => {
-          const resetReq = http.request(resetServerUrl, { method: 'POST' }, (resetRes) => {
-            resetRes.resume();
-            if (resetRes.statusCode === 200) resolve();
-            else reject(new Error(`reset server returned ${resetRes.statusCode}`));
+      const adminHost = process.env.ADMIN_HOST || 'demo-admin';
+      const adminPort = process.env.ADMIN_PORT || '8080';
+      return new Promise((resolve) => {
+        let responded = false;
+        const proxyReq = http.request({
+          hostname: adminHost,
+          port: parseInt(adminPort),
+          path: '/api/reset',
+          method: 'POST',
+          headers: { 'Content-Type': 'application/json' },
+          timeout: 30000,
+        }, (proxyRes) => {
+          let body = '';
+          proxyRes.on('data', chunk => { body += chunk; });
+          proxyRes.on('end', () => {
+            if (responded) return;
+            responded = true;
+            events = [];
+            res.writeHead(proxyRes.statusCode, { 'Content-Type': 'application/json' });
+            res.end(body);
+            resolve();
           });
-          resetReq.on('error', reject);
-          resetReq.setTimeout(180000, () => { resetReq.destroy(); reject(new Error('reset timed out')); });
-          resetReq.end();
         });
-      } catch (err) {
-        return sendJson(res, 502, { error: `reset failed: ${err.message}` });
-      }
-      events = [];
-      const resetEvent = { source: 'dashboard', event_type: 'demo.reset', timestamp: new Date().toISOString(), attributes: {}, received_at: new Date().toISOString() };
-      broadcastEvent(resetEvent);
-      return sendJson(res, 200, {});
+        proxyReq.on('error', (err) => {
+          if (responded) return;
+          responded = true;
+          sendJson(res, 502, { error: 'Failed to reach demo-admin: ' + err.message });
+          resolve();
+        });
+        proxyReq.on('timeout', () => {
+          proxyReq.destroy();
+          if (responded) return;
+          responded = true;
+          sendJson(res, 504, { error: 'demo-admin request timed out' });
+          resolve();
+        });
+        proxyReq.end();
+      });
     }
 
     // Serve static files for everything else
@@ -264,9 +283,8 @@ const wss = new WebSocketServer({ server, path: '/ws' });
 wss.on('connection', (ws) => {
   wsClients.add(ws);
 
-  // Send event history on connect, sorted chronologically
-  const sortedEvents = [...events].sort((a, b) => (a.timestamp < b.timestamp ? -1 : a.timestamp > b.timestamp ? 1 : 0));
-  ws.send(JSON.stringify({ type: 'history', events: sortedEvents }));
+  // Send event history on connect
+  ws.send(JSON.stringify({ type: 'history', events }));
 
   ws.on('close', () => {
     wsClients.delete(ws);

translate.js

@@ -53,7 +53,7 @@ function translateOtlpLogs(otlp) {
       }
     }
   }
-  return out.sort((a, b) => (a.timestamp < b.timestamp ? -1 : a.timestamp > b.timestamp ? 1 : 0));
+  return out;
 }
 
 // ─── Jaeger trace export → flat events ─────────────────────────────────────
@@ -198,7 +198,7 @@ function translateOtlpTraces(payload) {
       }
     }
   }
-  return out.sort((a, b) => (a.timestamp < b.timestamp ? -1 : a.timestamp > b.timestamp ? 1 : 0));
+  return out;
 }
 
 module.exports = { translateOtlpLogs, translateJaegerTraces, translateOtlpTraces };