Add /api/events endpoint and host-triggered reset

Author: Peter-SL5

server.js

@@ -228,46 +228,27 @@ const server = http.createServer(async (req, res) => {
       }
     }
 
-    // POST /api/reset - proxy to demo-admin reset endpoint
+    // POST /api/reset - trigger full demo reset via host-side reset server
     if (pathName === '/api/reset' && method === 'POST') {
-      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();
+      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}`));
           });
+          resetReq.on('error', reject);
+          resetReq.setTimeout(180000, () => { resetReq.destroy(); reject(new Error('reset timed out')); });
+          resetReq.end();
         });
-        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();
-      });
+      } 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, {});
     }
 
     // Serve static files for everything else
@@ -283,8 +264,9 @@ const wss = new WebSocketServer({ server, path: '/ws' });
 wss.on('connection', (ws) => {
   wsClients.add(ws);
 
-  // Send event history on connect
-  ws.send(JSON.stringify({ type: 'history', events }));
+  // 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 }));
 
   ws.on('close', () => {
     wsClients.delete(ws);