feat: multiarch build

Reviewed-on: #26

.dockerignore

@@ -0,0 +1,11 @@
+.git
+.gitignore
+.cursor
+*.md
+node_modules
+README.md
+docs
+test
+openapitools.json
+*.backup
+

Dockerfile

@@ -0,0 +1,41 @@
+# Build stage
+FROM node:20-alpine AS builder
+
+WORKDIR /app
+
+# Copy package files
+COPY package*.json ./
+
+# Install dependencies
+RUN npm ci --only=production
+
+# Runtime stage
+FROM node:20-alpine
+
+# Install wget for health checks
+RUN apk --no-cache add wget
+
+WORKDIR /app
+
+# Copy dependencies from builder
+COPY --from=builder /app/node_modules ./node_modules
+
+# Copy application files
+COPY package*.json ./
+COPY index.js index-standalone.js ./
+COPY public ./public
+COPY src ./src
+
+# Create non-root user (let Alpine assign available GID/UID)
+RUN addgroup spore && \
+    adduser -D -s /bin/sh -G spore spore && \
+    chown -R spore:spore /app
+
+USER spore
+
+# Expose port
+EXPOSE 3000
+
+# Run the application
+CMD ["node", "index.js"]
+

Makefile

@@ -0,0 +1,54 @@
+.PHONY: install build run clean docker-build docker-run docker-push docker-build-multiarch docker-push-multiarch
+
+# Install dependencies
+install:
+	npm install
+
+# Build the application (if needed)
+build: install
+
+# Run the application
+run:
+	node index.js
+
+# Start in development mode
+dev:
+	node index.js
+
+# Clean build artifacts
+clean:
+	rm -rf node_modules
+	rm -f package-lock.json
+
+# Docker variables
+DOCKER_REGISTRY ?= 
+IMAGE_NAME = wirelos/spore-ui
+IMAGE_TAG ?= latest
+FULL_IMAGE_NAME = $(if $(DOCKER_REGISTRY),$(DOCKER_REGISTRY)/$(IMAGE_NAME),$(IMAGE_NAME)):$(IMAGE_TAG)
+
+# Build Docker image
+docker-build:
+	docker build -t $(FULL_IMAGE_NAME) .
+
+# Run Docker container
+docker-run:
+	docker run -p 3000:3000 --rm $(FULL_IMAGE_NAME)
+
+# Push Docker image
+docker-push:
+	docker push $(FULL_IMAGE_NAME)
+
+# Build multiarch Docker image
+docker-build-multiarch:
+	docker buildx build --platform linux/amd64,linux/arm64 \
+		-t $(FULL_IMAGE_NAME) \
+		--push \
+		.
+
+# Push multiarch Docker image (if not pushed during build)
+docker-push-multiarch:
+	docker buildx build --platform linux/amd64,linux/arm64 \
+		-t $(FULL_IMAGE_NAME) \
+		--push \
+		.
+

README.md

@@ -23,6 +23,9 @@ This frontend server works together with the **SPORE Gateway** (spore-gateway) b
 ![UI](./assets/cluster.png)
 ### Topology
 ![UI](./assets/topology.png)
+### Events
+![UI](./assets/events.png)
+![UI](./assets/events-messages.png)
 ### Monitoring
 ![UI](./assets/monitoring.png)
 ### Firmware

docs/Events.md

@@ -0,0 +1,518 @@
+# Events Feature
+
+## Overview
+
+The Events feature provides real-time visualization of WebSocket events streaming through the SPORE cluster. It displays events as an interactive force-directed graph, showing the flow and relationships between different event topics.
+
+![Events View](./assets/events.png)
+
+## Features
+
+### Real-Time Event Visualization
+- **Interactive Graph**: Events are visualized as a force-directed graph using D3.js
+- **Topic Chain Visualization**: Multi-part topics (e.g., `cluster/event/api/neopattern`) are broken down into chains showing hierarchical relationships
+- **Event Counting**: Each event type is tracked with occurrence counts displayed on connections
+- **Animated Transitions**: New events trigger visual animations showing data flow through the graph
+
+### User Interactions
+
+#### Drag to Reposition Nodes
+- **Center Node**: Dragging the center (blue) node moves the entire graph together
+- **Topic Nodes**: Individual topic nodes (green) can be repositioned independently
+- **Fixed Positioning**: Once dragged, nodes maintain their positions to prevent layout disruption
+
+#### Zoom Controls
+- **Mouse Wheel**: Zoom in and out using the mouse wheel
+- **Scale Range**: Zoom level constrained between 0.5x and 5x
+- **Pan**: Click and drag the canvas to pan around the graph
+
+#### Rearrange Layout
+- **Rearrange Button**: Click the button in the top-left corner to reset node positions
+- **Automatic Layout**: Clears fixed positions and lets the force simulation reposition nodes
+
+### Visual Elements
+
+#### Node Types
+- **Center Node** (Blue):
+  - Represents the central event hub
+  - Always visible in the graph
+  - Acts as the root node for all event chains
+  - Larger size (18px radius)
+
+- **Topic Nodes** (Green):
+  - Represent individual topic segments
+  - Examples: `cluster`, `event`, `api`, `neopattern`
+  - Smaller size (14px radius)
+  - Positioned dynamically based on event frequency
+
+#### Link Types
+- **Center Links** (Blue):
+  - Connect the center node to root topic nodes
+  - Thicker lines (2.5px)
+  - Examples: center → `cluster`, center → `event`
+
+- **Topic Links** (Green):
+  - Connect adjacent topics in event chains
+  - Line thickness proportional to event frequency
+  - Examples: `cluster` → `event`, `api` → `neopattern`
+
+#### Hover Interactions
+- **Link Hover**: Links become thicker and more opaque when hovered
+- **Event Frequency**: Line thickness dynamically adjusts based on event occurrence counts
+
+## Architecture
+
+### Component Structure
+
+```12:37:spore-ui/public/scripts/components/EventComponent.js
+// Events Component - Visualizes websocket events as a graph
+class EventComponent extends Component {
+    constructor(container, viewModel, eventBus) {
+        super(container, viewModel, eventBus);
+        
+        this.svg = null;
+        this.simulation = null;
+        this.zoom = null;
+        this.width = 0;
+        this.height = 0;
+        this.isInitialized = false;
+        
+        // Center node data - will be initialized with proper coordinates later
+        this.centerNode = { id: 'center', type: 'center', label: '', x: 0, y: 0 };
+        
+        // Track nodes for D3
+        this.graphNodes = [];
+        this.graphLinks = [];
+        
+        // Track recent events to trigger animations
+        this.lastSeenEvents = new Set();
+    }
+```
+
+### ViewModel
+
+The `EventViewModel` manages the state and WebSocket connections:
+
+```1241:1253:spore-ui/public/scripts/view-models.js
+// Events View Model for websocket event visualization
+class EventViewModel extends ViewModel {
+    constructor() {
+        super();
+        this.setMultiple({
+            events: new Map(), // Map of topic -> { parts: [], count: number, lastSeen: timestamp }
+            isLoading: false,
+            error: null,
+            lastUpdateTime: null
+        });
+        
+        // Set up WebSocket listeners for real-time updates
+        this.setupWebSocketListeners();
+    }
+```
+
+### Event Tracking
+
+Events are tracked with the following metadata:
+- **Topic**: The full event topic path (e.g., `cluster/event/api/neopattern`)
+- **Parts**: Array of topic segments split by `/`
+- **Count**: Total occurrences of this event
+- **First Seen**: ISO timestamp of first occurrence
+- **Last Seen**: ISO timestamp of most recent occurrence
+- **Last Data**: The most recent event payload
+
+### Event Addition Logic
+
+The view model handles nested events specially:
+
+```1283:1329:spore-ui/public/scripts/view-models.js
+    // Add a topic (parsed by "/" separator)
+    addTopic(topic, data = null) {
+        // Get current events as a new Map to ensure change detection
+        const events = new Map(this.get('events'));
+        
+        // Handle nested events from cluster/event
+        let fullTopic = topic;
+        if (topic === 'cluster/event' && data && data.data) {
+            try {
+                const parsedData = typeof data.data === 'string' ? JSON.parse(data.data) : data.data;
+                if (parsedData && parsedData.event) {
+                    // Create nested topic chain: cluster/event/api/neopattern
+                    fullTopic = `${topic}/${parsedData.event}`;
+                }
+            } catch (e) {
+                // If parsing fails, just use the original topic
+            }
+        }
+        
+        const parts = fullTopic.split('/').filter(p => p);
+        
+        if (events.has(fullTopic)) {
+            // Update existing event - create new object to ensure change detection
+            const existing = events.get(fullTopic);
+            events.set(fullTopic, {
+                topic: existing.topic,
+                parts: existing.parts,
+                count: existing.count + 1,
+                firstSeen: existing.firstSeen,
+                lastSeen: new Date().toISOString(),
+                lastData: data
+            });
+        } else {
+            // Create new event entry
+            events.set(fullTopic, {
+                topic: fullTopic,
+                parts: parts,
+                count: 1,
+                firstSeen: new Date().toISOString(),
+                lastSeen: new Date().toISOString(),
+                lastData: data
+            });
+        }
+        
+        // Use set to trigger change notification
+        this.set('events', events);
+        this.set('lastUpdateTime', new Date().toISOString());
+    }
+```
+
+## Graph Construction
+
+### Node Creation
+
+The graph construction process follows two passes:
+
+1. **First Pass - Node Creation**:
+   - Creates nodes for each unique topic segment
+   - Preserves existing node positions if they've been dragged
+   - New nodes are positioned near their parent in the hierarchy
+
+2. **Second Pass - Event Counting**:
+   - Counts occurrences of each topic segment
+   - Updates node counts to reflect event frequency
+
+### Link Construction
+
+Links are created as chains representing complete topic paths:
+
+```283:342:spore-ui/public/scripts/components/EventComponent.js
+        // Build links as chains for each topic
+        // For "cluster/update", create: center -> cluster -> update
+        this.graphLinks = [];
+        const linkSet = new Set(); // Track links to avoid duplicates
+        
+        if (events && events.size > 0) {
+            for (const [topic, data] of events) {
+                const parts = data.parts;
+                
+                if (parts.length === 0) continue;
+                
+                // Connect center to first part
+                const firstPart = parts[0];
+                const centerToFirst = `center-${firstPart}`;
+                if (!linkSet.has(centerToFirst)) {
+                    this.graphLinks.push({
+                        source: 'center',
+                        target: firstPart,
+                        type: 'center-link',
+                        count: data.count,
+                        topic: topic
+                    });
+                    linkSet.add(centerToFirst);
+                } else {
+                    // Update count for existing link
+                    const existingLink = this.graphLinks.find(l => 
+                        `${l.source}-${l.target}` === centerToFirst
+                    );
+                    if (existingLink) {
+                        existingLink.count += data.count;
+                    }
+                }
+                
+                // Connect each part to the next (creating a chain)
+                for (let i = 0; i < parts.length - 1; i++) {
+                    const source = parts[i];
+                    const target = parts[i + 1];
+                    const linkKey = `${source}-${target}`;
+                    
+                    if (!linkSet.has(linkKey)) {
+                        this.graphLinks.push({
+                            source: source,
+                            target: target,
+                            type: 'topic-link',
+                            topic: topic,
+                            count: data.count
+                        });
+                        linkSet.add(linkKey);
+                    } else {
+                        // Update count for existing link
+                        const existingLink = this.graphLinks.find(l => 
+                            `${l.source}-${l.target}` === linkKey
+                        );
+                        if (existingLink) {
+                            existingLink.count += data.count;
+                        }
+                    }
+                }
+            }
+        }
+```
+
+## Force Simulation
+
+The D3.js force simulation provides the physics-based layout:
+
+```103:111:spore-ui/public/scripts/components/EventComponent.js
+        // Initialize simulation
+        this.simulation = d3.forceSimulation()
+            .force('link', d3.forceLink().id(d => d.id).distance(100))
+            .force('charge', d3.forceManyBody().strength(-300))
+            .force('center', d3.forceCenter(this.width / 2, this.height / 2))
+            .force('collision', d3.forceCollide().radius(35))
+            .alphaDecay(0.0228) // Slower decay to allow simulation to run longer
+            .velocityDecay(0.4); // Higher velocity decay for smoother, less jumpy movement
+```
+
+### Force Parameters
+- **Link Force**: Maintains 100px distance between connected nodes
+- **Charge Force**: -300 strength creates repulsion between nodes
+- **Center Force**: Keeps the graph centered in the viewport
+- **Collision Detection**: Prevents nodes from overlapping (35px collision radius)
+- **Decay Rate**: Slow decay (0.0228) keeps the simulation running smoothly
+- **Velocity Decay**: High decay (0.4) prevents excessive movement
+
+## Animation System
+
+### Event Arrival Animation
+
+When a new event arrives, a golden animation dot travels along the event chain:
+
+```725:809:spore-ui/public/scripts/components/EventComponent.js
+    animateEventMessage(topic, data) {
+        const g = this.svg.select('g');
+        if (g.empty()) return;
+        
+        const parts = data.parts || topic.split('/').filter(p => p);
+        if (parts.length === 0) return;
+        
+        // Wait for the next tick to ensure nodes exist
+        setTimeout(() => {
+            // Build the chain: center -> first -> second -> ... -> last
+            const chain = ['center', ...parts];
+            
+            // Animate along each segment of the chain
+            let delay = 0;
+            for (let i = 0; i < chain.length - 1; i++) {
+                const sourceId = chain[i];
+                const targetId = chain[i + 1];
+                
+                const sourceNode = this.graphNodes.find(n => n.id === sourceId);
+                const targetNode = this.graphNodes.find(n => n.id === targetId);
+                
+                if (!sourceNode || !targetNode) continue;
+                
+                setTimeout(() => {
+                    this.animateDotAlongLink(sourceNode, targetNode, g);
+                }, delay);
+                
+                // Add delay between segments (staggered animation)
+                delay += 400; // Duration (300ms) + small gap (100ms)
+            }
+        }, 100);
+    }
+    
+    animateDotAlongLink(sourceNode, targetNode, g) {
+        if (!sourceNode || !targetNode || !g) return;
+        
+        // Calculate positions
+        const dx = targetNode.x - sourceNode.x;
+        const dy = targetNode.y - sourceNode.y;
+        const length = Math.sqrt(dx * dx + dy * dy);
+        
+        if (length === 0) return;
+        
+        // Normalize direction
+        const nx = dx / length;
+        const ny = dy / length;
+        
+        // Calculate node radii
+        const sourceRadius = sourceNode.type === 'center' ? 18 : 14;
+        const targetRadius = targetNode.type === 'center' ? 18 : 14;
+        
+        // Start from edge of source node
+        const startX = sourceNode.x + nx * sourceRadius;
+        const startY = sourceNode.y + ny * sourceRadius;
+        
+        // End at edge of target node
+        const endX = targetNode.x - nx * targetRadius;
+        const endY = targetNode.y - ny * targetRadius;
+        
+        // Create animation dot
+        const animationGroup = g.append('g').attr('class', 'animation-group');
+        
+        const dot = animationGroup.append('circle')
+            .attr('r', 4)
+            .attr('fill', '#FFD700')
+            .attr('stroke', '#fff')
+            .attr('stroke-width', 2)
+            .attr('cx', startX)
+            .attr('cy', startY);
+        
+        // Animate the dot along the path
+        dot.transition()
+            .duration(300)
+            .ease(d3.easeLinear)
+            .attr('cx', endX)
+            .attr('cy', endY)
+            .on('end', function() {
+                // Fade out after reaching destination
+                dot.transition()
+                    .duration(100)
+                    .style('opacity', 0)
+                    .remove();
+                animationGroup.remove();
+            });
+    }
+```
+
+### Animation Characteristics
+- **Golden Dot**: Visual indicator traveling along event chains
+- **Staggered Timing**: Each segment of a multi-part topic animates sequentially
+- **Duration**: 300ms per segment with 100ms delay between segments
+- **Smooth Motion**: Linear easing for consistent speed
+
+## WebSocket Integration
+
+The Events view subscribes to all WebSocket messages through the gateway:
+
+```1256:1280:spore-ui/public/scripts/view-models.js
+    // Set up WebSocket event listeners
+    setupWebSocketListeners() {
+        if (!window.wsClient) {
+            // Retry after a short delay to allow wsClient to initialize
+            setTimeout(() => this.setupWebSocketListeners(), 1000);
+            return;
+        }
+
+        // Listen for all websocket messages
+        window.wsClient.on('message', (data) => {
+            const topic = data.topic || data.type;
+            
+            if (topic) {
+                this.addTopic(topic, data);
+            }
+        });
+
+        // Listen for connection status changes
+        window.wsClient.on('connected', () => {
+            logger.info('EventViewModel: WebSocket connected');
+        });
+
+        window.wsClient.on('disconnected', () => {
+            logger.debug('EventViewModel: WebSocket disconnected');
+        });
+    }
+```
+
+### Event Types Tracked
+
+All WebSocket messages are captured and displayed, including:
+- **cluster/update**: Node discovery and cluster membership changes
+- **cluster/event**: Arbitrary events from cluster members
+- **api/tasks**: Task execution notifications
+- **api/config**: Configuration updates
+- **node/***: Node-specific events
+- Any custom topics sent by SPORE nodes
+
+## Empty State
+
+When no events have been received, the view displays a helpful message:
+
+```604:632:spore-ui/public/scripts/components/EventComponent.js
+    showEmptyState() {
+        if (!this.isInitialized || !this.svg) return;
+        
+        const g = this.svg.select('g');
+        if (g.empty()) return;
+        
+        // Remove any existing message
+        g.selectAll('.empty-state').remove();
+        
+        // Account for the initial zoom transform (scale(1.4) translate(-200, -150))
+        // We need to place the text in the center of the transformed coordinate space
+        const transformX = -200;
+        const transformY = -150;
+        const scale = 1.4;
+        
+        // Calculate centered position in transformed space
+        const x = ((this.width / 2) - transformX) / scale;
+        const y = ((this.height / 2) - transformY) / scale;
+        
+        const emptyMsg = g.append('text')
+            .attr('class', 'empty-state')
+            .attr('x', x)
+            .attr('y', y)
+            .attr('text-anchor', 'middle')
+            .attr('font-size', '18px')
+            .attr('fill', 'var(--text-secondary)')
+            .attr('font-weight', '500')
+            .text('Waiting for websocket events...');
+    }
+```
+
+## Best Practices
+
+### Performance Considerations
+1. **Event Accumulation**: Events accumulate over time; consider clearing the view for long-running sessions
+2. **Many Events**: With hundreds of unique topics, the graph may become cluttered
+3. **Animation**: Rapid event bursts may cause overlapping animations
+
+### Usage Tips
+1. **Rearrange Regularly**: Use the rearrange button to clean up the layout after many events
+2. **Drag Center Node**: Move the entire graph to see different areas of the visualization
+3. **Zoom Out**: Zoom out to see the overall event pattern across the cluster
+4. **Interactive Exploration**: Hover over links to see event frequencies
+
+## Troubleshooting
+
+### No Events Showing
+- **Check WebSocket Connection**: Verify the gateway WebSocket is connected
+- **Check Node Activity**: Ensure SPORE nodes are actively sending events
+- **Browser Console**: Check for any JavaScript errors
+
+### Graph Not Updating
+- **Force Refresh**: Reload the page to reinitialize the WebSocket connection
+- **Check Gateway**: Verify the SPORE Gateway is running and accessible
+
+### Performance Issues
+- **Clear Events**: Reload the page to clear accumulated events
+- **Reduce Events**: Limit the event rate in your SPORE nodes
+- **Browser Settings**: Ensure hardware acceleration is enabled
+
+## Technical Details
+
+### Dependencies
+- **D3.js v7**: Force-directed graph simulation and SVG manipulation
+- **SPORE Gateway**: WebSocket connection to cluster event stream
+- **Component Framework**: Built on the SPORE UI component architecture
+
+### Browser Compatibility
+- **Modern Browsers**: Chrome, Firefox, Safari, Edge (latest versions)
+- **SVG Support**: Requires modern browser with full SVG support
+- **WebSocket Support**: Native WebSocket API required
+
+### View Structure
+
+```254:262:spore-ui/public/index.html
+        <div id="events-view" class="view-content">
+            <div class="view-section" style="height: 100%; display: flex; flex-direction: column;">
+                <div id="events-graph-container" style="flex: 1; min-height: 0;">
+                    <div class="loading">
+                        <div>Waiting for websocket events...</div>
+                    </div>
+                </div>
+            </div>
+        </div>
+```
+
+The Events view provides a unique perspective on cluster activity, making it easy to observe the flow of events through the SPORE system in real-time.
+

docs/README.md

@@ -0,0 +1,78 @@
+# SPORE UI Documentation
+
+This directory contains detailed documentation for the SPORE UI frontend application.
+
+## Documentation Index
+
+### Core Documentation
+
+- **[Framework](./FRAMEWORK_README.md)**: Component-based architecture, View Models, Event Bus, and framework conventions
+- **[Discovery](./DISCOVERY.md)**: Node discovery system and cluster management
+- **[Topology WebSocket Update](./TOPOLOGY_WEBSOCKET_UPDATE.md)**: Real-time topology visualization updates
+- **[Logging](./LOGGING.md)**: Logging system and debugging utilities
+
+### Feature Documentation
+
+- **[Events](./Events.md)**: Real-time WebSocket event visualization with interactive force-directed graph
+- **[Firmware Registry Integration](./FIRMWARE_REGISTRY_INTEGRATION.md)**: Integration with the firmware registry system
+
+## Feature Overview
+
+### Events Feature
+The Events feature provides real-time visualization of WebSocket events streaming through the SPORE cluster. It displays events as an interactive force-directed graph, showing the flow and relationships between different event topics.
+
+**Key Capabilities:**
+- Real-time event tracking and visualization
+- Interactive force-directed graph layout
+- Event counting and frequency visualization
+- Animated event flow visualization
+- Topic hierarchy display
+
+See [Events.md](./Events.md) for complete documentation.
+
+### Framework Architecture
+The SPORE UI uses a component-based architecture with:
+- View Models for state management
+- Components for UI rendering
+- Event Bus for pub/sub communication
+- API Client for backend integration
+
+See [FRAMEWORK_README.md](./FRAMEWORK_README.md) for architecture details.
+
+### Discovery System
+The discovery system enables automatic detection of SPORE nodes on the network, maintaining a real-time view of cluster members.
+
+See [DISCOVERY.md](./DISCOVERY.md) for implementation details.
+
+### Topology Visualization
+The topology view provides an interactive network graph showing relationships between cluster nodes in real-time.
+
+See [TOPOLOGY_WEBSOCKET_UPDATE.md](./TOPOLOGY_WEBSOCKET_UPDATE.md) for detailed documentation.
+
+## Quick Reference
+
+### Most Popular Pages
+1. [Framework Architecture](./FRAMEWORK_README.md) - Start here for understanding the codebase
+2. [Events Feature](./Events.md) - Real-time event visualization
+3. [Firmware Registry Integration](./FIRMWARE_REGISTRY_INTEGRATION.md) - Firmware management
+
+### Developer Resources
+- Component development: See [FRAMEWORK_README.md](./FRAMEWORK_README.md)
+- Debugging: See [LOGGING.md](./LOGGING.md)
+- Testing: See individual component documentation
+
+## Contributing
+
+When adding new features or documentation:
+1. Follow the existing documentation structure
+2. Include code examples and diagrams where helpful
+3. Update this README when adding new documentation files
+4. Maintain consistency with existing documentation style
+
+## Related Documentation
+
+For information about other SPORE components:
+- **SPORE Gateway**: See `spore-gateway/README.md`
+- **SPORE Registry**: See `spore-registry/README.md`
+- **SPORE Embedded**: See `spore/README.md`
+

public/index.html

@@ -41,11 +41,13 @@
                 </a>
                 <a href="/events" class="nav-tab" data-view="events">
                     <svg viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" width="16" height="16" style="margin-right:6px;">
-                        <circle cx="6" cy="6" r="2" fill="currentColor"/>
+                        <circle cx="5" cy="12" r="1.5" fill="currentColor"/>
-                        <circle cx="18" cy="6" r="2" fill="currentColor"/>
+                        <circle cx="18" cy="6" r="1.5" fill="currentColor"/>
-                        <circle cx="12" cy="18" r="2" fill="currentColor"/>
+                        <circle cx="18" cy="12" r="1.5" fill="currentColor"/>
-                        <line x1="6" y1="6" x2="12" y2="18"/>
+                        <circle cx="18" cy="18" r="1.5" fill="currentColor"/>
-                        <line x1="18" y1="6" x2="12" y2="18"/>
+                        <line x1="6.5" y1="12" x2="16.5" y2="6"/>
+                        <line x1="6.5" y1="12" x2="16.5" y2="12"/>
+                        <line x1="6.5" y1="12" x2="16.5" y2="18"/>
                     </svg>
                     Events
                 </a>

public/scripts/components/EventComponent.js

@@ -11,7 +11,7 @@ class EventComponent extends Component {
         this.isInitialized = false;
         
         // Center node data - will be initialized with proper coordinates later
-        this.centerNode = { id: 'center', type: 'center', label: 'Events', x: 0, y: 0 };
+        this.centerNode = { id: 'center', type: 'center', label: '', x: 0, y: 0 };
         
         // Track nodes for D3
         this.graphNodes = [];
@@ -19,6 +19,12 @@ class EventComponent extends Component {
         
         // Track recent events to trigger animations
         this.lastSeenEvents = new Set();
+        
+        // Track rendered message IDs for animation
+        this.renderedMessageIds = new Set();
+        
+        // Track selected node for highlighting
+        this.selectedNodeId = null;
     }
 
     updateDimensions() {
@@ -64,8 +70,19 @@ class EventComponent extends Component {
         // Clear container
         container.innerHTML = '';
         
+        // Create a wrapper div for relative positioning  
+        const wrapper = document.createElement('div');
+        wrapper.style.cssText = 'position: relative; width: 100%; height: 100%; overflow: hidden;';
+        container.appendChild(wrapper);
+        
+        // Store wrapper for button placement
+        this.wrapper = wrapper;
+        
+        // Add rearrange button
+        this.createRearrangeButton(wrapper);
+        
         // Create SVG with D3 - match topology view style
-        this.svg = d3.select(container)
+        this.svg = d3.select(wrapper)
             .append('svg')
             .attr('width', '100%')
             .attr('height', '100%')
@@ -172,25 +189,41 @@ class EventComponent extends Component {
         const centerX = this.width / 2;
         const centerY = this.height / 2;
         
-        const centerNodeWithPos = {
+        // Check if center node already exists in simulation (has been dragged)
-            ...this.centerNode,
+        const existingCenter = existingNodesMap.get('center');
-            x: centerX,
+        let centerNodeWithPos;
-            y: centerY,
+        
-            fx: centerX, // Fix x position
+        if (existingCenter && existingCenter.fx !== undefined && existingCenter.fy !== undefined) {
-            fy: centerY  // Fix y position
+            // Preserve the dragged position
-        };
+            centerNodeWithPos = {
+                ...this.centerNode,
+                x: existingCenter.fx !== null ? existingCenter.fx : existingCenter.x,
+                y: existingCenter.fy !== null ? existingCenter.fy : existingCenter.y,
+                fx: existingCenter.fx,
+                fy: existingCenter.fy
+            };
+        } else {
+            // New center node at center, or if it was never dragged
+            centerNodeWithPos = {
+                ...this.centerNode,
+                x: centerX,
+                y: centerY,
+                fx: null,
+                fy: null
+            };
+        }
         nodesMap.set('center', centerNodeWithPos);
         
         // Only process events if they exist
         if (events && events.size > 0) {
-            // First pass: create all unique topic part nodes
+            // First pass: create all unique topic part nodes with proper hierarchy
             for (const [topic, data] of events) {
                 data.parts.forEach((part, index) => {
                     if (!nodesMap.has(part)) {
                         const existingNode = existingNodesMap.get(part);
                         
                         if (existingNode && existingNode.x && existingNode.y) {
-                            // Preserve existing position, including fixed state for center node
+                            // Preserve existing position
                             nodesMap.set(part, {
                                 id: part,
                                 type: 'topic',
@@ -202,16 +235,36 @@ class EventComponent extends Component {
                                 fy: existingNode.fy
                             });
                         } else {
-                            // Initialize new node with random position
+                            // Determine where to place this new node based on hierarchy
+                            let parentPart;
+                            let refPos;
+                            
+                            if (index === 0) {
+                                // First part connects to center
+                                parentPart = 'center';
+                            } else {
+                                // Subsequent parts connect to previous part in this topic
+                                parentPart = data.parts[index - 1];
+                            }
+                            
+                            // Get parent position (should exist since we process in order)
+                            refPos = nodesMap.get(parentPart);
+                            
+                            // Fallback to center if parent doesn't exist yet
+                            if (!refPos) {
+                                refPos = nodesMap.get('center');
+                            }
+                            
+                            // Initialize new node very close to its parent
                             const angle = Math.random() * Math.PI * 2;
-                            const distance = 150 + Math.random() * 100;
+                            const distance = 60 + Math.random() * 30;
                             nodesMap.set(part, {
                                 id: part,
                                 type: 'topic',
                                 label: part,
                                 count: 0,
-                                x: (this.width / 2) + Math.cos(angle) * distance,
+                                x: refPos.x + Math.cos(angle) * distance,
-                                y: (this.height / 2) + Math.sin(angle) * distance,
+                                y: refPos.y + Math.sin(angle) * distance,
                                 fx: null,
                                 fy: null
                             });
@@ -367,15 +420,25 @@ class EventComponent extends Component {
             .style('opacity', 0)
             .call(this.drag());
         
-        // Add circle
+        // Add circle with click handler for non-center nodes
-        nodesEnter.append('circle')
+        const circlesEnter = nodesEnter.append('circle')
             .attr('r', d => d.type === 'center' ? 18 : 14)
             .attr('fill', d => {
                 if (d.type === 'center') return '#3498db';
                 return '#10b981';
             })
             .attr('stroke', '#fff')
-            .attr('stroke-width', 2.5);
+            .attr('stroke-width', 2.5)
+            .style('cursor', d => d.type === 'center' ? 'default' : 'pointer');
+        
+        // Add outer ring for highlighted nodes
+        nodesEnter.append('circle')
+            .attr('class', 'node-highlight')
+            .attr('r', d => d.type === 'center' ? 22 : 18)
+            .attr('fill', 'none')
+            .attr('stroke', '#FFD700')
+            .attr('stroke-width', 3)
+            .attr('opacity', 0);
         
         // Add text labels
         nodesEnter.append('text')
@@ -386,20 +449,37 @@ class EventComponent extends Component {
             .attr('font-weight', '600')
             .text(d => d.label);
         
+        // Add click handler to open drawer for topic nodes
+        nodesEnter.on('click', (event, d) => {
+            if (d.type !== 'center' && d.id) {
+                this.selectedNodeId = d.id;
+                // Update the graph to show highlight
+                if (this.svg) {
+                    this.updateSimulation();
+                }
+                this.openTopicDrawer(d.id);
+            }
+        });
+        
         // Merge and update all nodes
         const nodesUpdate = nodesEnter.merge(nodes);
         
         // Update node visibility
         nodesUpdate.style('opacity', 1);
         
-        // Update circles
+        // Update circles (excluding highlight ring)
-        nodesUpdate.select('circle')
+        nodesUpdate.select('circle:not(.node-highlight)')
             .attr('r', d => d.type === 'center' ? 18 : 14)
             .attr('fill', d => {
                 if (d.type === 'center') return '#3498db';
                 return '#10b981';
             });
         
+        // Update highlight rings
+        nodesUpdate.select('.node-highlight')
+            .attr('opacity', d => d.id === this.selectedNodeId ? 1 : 0)
+            .classed('highlighted', d => d.id === this.selectedNodeId);
+        
         // Update text labels
         nodesUpdate.select('text')
             .text(d => d.label);
@@ -471,22 +551,59 @@ class EventComponent extends Component {
 
     drag() {
         const simulation = this.simulation;
+        const component = this;
+        
+        let initialCenterX = 0;
+        let initialCenterY = 0;
         
         function dragstarted(event, d) {
             if (!event.active) simulation.alphaTarget(0.3).restart();
             d.fx = d.x;
             d.fy = d.y;
+            
+            // If dragging the center node, store initial position and get all nodes
+            if (d.type === 'center') {
+                initialCenterX = d.x;
+                initialCenterY = d.y;
+            }
         }
         
         function dragged(event, d) {
             d.fx = event.x;
             d.fy = event.y;
+            
+            // If dragging the center node, move all other nodes by the same offset
+            if (d.type === 'center') {
+                const dx = event.x - initialCenterX;
+                const dy = event.y - initialCenterY;
+                
+                // Apply the same offset to all other nodes
+                simulation.nodes().forEach(node => {
+                    if (node.id !== 'center') {
+                        node.fx = node.x + dx;
+                        node.fy = node.y + dy;
+                    }
+                });
+                
+                // Update initial position for next iteration
+                initialCenterX = event.x;
+                initialCenterY = event.y;
+            }
         }
         
         function dragended(event, d) {
             if (!event.active) simulation.alphaTarget(0);
+            // Keep positions fixed after dragging
             d.fx = d.x;
             d.fy = d.y;
+            
+            // If dragging the center node, preserve all node positions
+            if (d.type === 'center') {
+                simulation.nodes().forEach(node => {
+                    node.fx = node.x;
+                    node.fy = node.y;
+                });
+            }
         }
         
         return d3.drag()
@@ -563,6 +680,81 @@ class EventComponent extends Component {
         return false;
     }
     
+    createRearrangeButton(container) {
+        const button = document.createElement('button');
+        button.className = 'topology-rearrange-btn';
+        button.innerHTML = `
+            <svg width="20" height="20" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2">
+                <circle cx="12" cy="5" r="1.5"/>
+                <circle cx="12" cy="12" r="1.5"/>
+                <circle cx="12" cy="19" r="1.5"/>
+                <circle cx="5" cy="12" r="1.5"/>
+                <circle cx="19" cy="12" r="1.5"/>
+                <path d="M12 7v3m0 2v3m-5-3h3m2 0h3"/>
+            </svg>
+            <span>Rearrange</span>
+        `;
+        button.title = 'Rearrange nodes into a clean layout';
+        button.style.cssText = `
+            position: absolute;
+            left: 16px;
+            top: 16px;
+            z-index: 1000;
+            display: flex;
+            align-items: center;
+            gap: 8px;
+            padding: 8px 14px;
+            background: var(--card-background, rgba(30, 30, 30, 0.95));
+            border: 1px solid var(--border-color, rgba(255, 255, 255, 0.1));
+            border-radius: 8px;
+            color: var(--text-primary, #ecf0f1);
+            font-size: 13px;
+            font-weight: 500;
+            cursor: pointer;
+            transition: all 0.2s ease;
+            box-shadow: 0 2px 8px rgba(0, 0, 0, 0.2);
+        `;
+
+        // Add hover effect
+        button.addEventListener('mouseenter', () => {
+            button.style.background = 'var(--card-hover, rgba(40, 40, 40, 0.95))';
+            button.style.borderColor = 'var(--primary-color, #3498db)';
+            button.style.transform = 'translateY(-1px)';
+            button.style.boxShadow = '0 4px 12px rgba(0, 0, 0, 0.3)';
+        });
+
+        button.addEventListener('mouseleave', () => {
+            button.style.background = 'var(--card-background, rgba(30, 30, 30, 0.95))';
+            button.style.borderColor = 'var(--border-color, rgba(255, 255, 255, 0.1))';
+            button.style.transform = 'translateY(0)';
+            button.style.boxShadow = '0 2px 8px rgba(0, 0, 0, 0.2)';
+        });
+
+        // Add click handler
+        button.addEventListener('click', () => {
+            this.rearrangeNodes();
+        });
+
+        container.appendChild(button);
+    }
+    
+    rearrangeNodes() {
+        if (!this.simulation) {
+            return;
+        }
+        
+        // Clear fixed positions for all nodes except center
+        this.graphNodes.forEach(node => {
+            if (node.type !== 'center') {
+                node.fx = null;
+                node.fy = null;
+            }
+        });
+        
+        // Restart simulation with higher energy
+        this.simulation.alpha(1).restart();
+    }
+    
     animateEventMessage(topic, data) {
         const g = this.svg.select('g');
         if (g.empty()) return;
@@ -648,6 +840,289 @@ class EventComponent extends Component {
                 animationGroup.remove();
             });
     }
+    
+    // Get topics that contain this node ID (part)
+    getTopicsForNodeId(nodeId) {
+        const events = this.viewModel.get('events');
+        const topics = [];
+        
+        for (const [topic, data] of events) {
+            if (data.parts && data.parts.includes(nodeId)) {
+                topics.push(topic);
+            }
+        }
+        
+        return topics;
+    }
+    
+    // Open drawer to show messages for a topic node
+    openTopicDrawer(nodeId) {
+        // Find topics that contain this node
+        const topics = this.getTopicsForNodeId(nodeId);
+        
+        if (topics.length === 0) {
+            logger.warn('EventComponent: No topics found for node', nodeId);
+            return;
+        }
+        
+        // Store all matching topics
+        this._selectedNodeId = nodeId;
+        this._selectedTopics = topics;
+        
+        // Set selected topic in view model (first topic for backwards compatibility)
+        this.viewModel.setSelectedTopic(topics[0]);
+        
+        // Update highlight state
+        this.selectedNodeId = nodeId;
+        this.updateSimulation();
+        
+        // Open drawer with all matching topics
+        this.openMessagesDrawer(nodeId, topics);
+    }
+    
+    // Open the messages drawer
+    openMessagesDrawer(nodeId, topics) {
+        if (!window.DrawerComponent) {
+            logger.error('EventComponent: DrawerComponent not available');
+            return;
+        }
+        
+        const drawer = new window.DrawerComponent();
+        
+        const title = topics.length === 1 
+            ? `Live Messages: ${topics[0]}` 
+            : `Live Messages: ${nodeId} (${topics.length} topics)`;
+        
+        drawer.openDrawer(
+            title,
+            (container) => {
+                this.renderMessageList(container, nodeId, topics);
+            },
+            null,
+            () => {
+                // On close callback - cleanup
+                if (this._messageUnsubscribe) {
+                    this._messageUnsubscribe();
+                    this._messageUnsubscribe = null;
+                }
+                this._selectedNodeId = null;
+                this._selectedTopics = null;
+                this.selectedNodeId = null;
+                // Update graph to remove highlight
+                this.updateSimulation();
+                this.viewModel.clearSelectedTopic();
+            },
+            true // Hide terminal button for events drawer
+        );
+    }
+    
+    // Render message list in the drawer
+    renderMessageList(container, nodeId, topics) {
+        // Clear loading state
+        container.innerHTML = '';
+        
+        // Create scrollable container
+        const messagesContainer = document.createElement('div');
+        messagesContainer.className = 'topic-messages-container';
+        
+        // Create header info
+        const header = document.createElement('div');
+        header.className = 'message-list-header';
+        
+        // Build topic display
+        let topicDisplay = '';
+        if (topics.length === 1) {
+            topicDisplay = `<code class="topic-code">${topics[0]}</code>`;
+        } else {
+            topicDisplay = `
+                ${topics.map(t => `<code class="topic-code" style="margin-right: 4px;">${t}</code>`).join('')}
+                <br><small class="topic-multi-indicator">(${topics.length} topics for node: ${nodeId})</small>
+            `;
+        }
+        
+        header.innerHTML = `
+            <div class="message-list-header-title">
+                Topics: ${topicDisplay}
+            </div>
+            <div class="message-list-header-subtitle">
+                Showing live websocket messages for these topics
+            </div>
+        `;
+        messagesContainer.appendChild(header);
+        
+        // Message list
+        const messageList = document.createElement('div');
+        messageList.id = `message-list-${nodeId}`;
+        messageList.className = 'message-list';
+        messagesContainer.appendChild(messageList);
+        
+        container.appendChild(messagesContainer);
+        
+        // Initial render
+        this.updateMessageList(nodeId, topics);
+        
+        // Subscribe to allMessagesCounter changes to update in real-time
+        // Store unsubscribe function for cleanup
+        const updateHandler = () => {
+            this.updateMessageList(nodeId, topics);
+        };
+        
+        // Subscribe to the counter which changes on every new message
+        this._messageUnsubscribe = this.viewModel.subscribe('allMessagesCounter', updateHandler);
+    }
+    
+    // Update the message list display
+    updateMessageList(nodeId, topics) {
+        const messageList = document.getElementById(`message-list-${nodeId}`);
+        if (!messageList) return;
+        
+        // Get messages for all topics
+        const allMessages = [];
+        topics.forEach(topic => {
+            const messages = this.viewModel.getMessagesForTopic(topic);
+            allMessages.push(...messages);
+        });
+        
+        // Sort by timestamp (newest first)
+        allMessages.sort((a, b) => new Date(b.timestamp) - new Date(a.timestamp));
+        
+        // Clear existing content
+        messageList.innerHTML = '';
+        
+        if (allMessages.length === 0) {
+            const emptyMsg = document.createElement('div');
+            emptyMsg.className = 'empty-message-state';
+            emptyMsg.textContent = 'No messages yet. Waiting for websocket events...';
+            messageList.appendChild(emptyMsg);
+            return;
+        }
+        
+        // Show messages (newest at top)
+        allMessages.forEach((msg, index) => {
+            // Check if this is a new message (not previously rendered)
+            const isNewMessage = !this.renderedMessageIds.has(msg.id);
+            
+            const messageDiv = document.createElement('div');
+            messageDiv.className = 'message-item';
+            if (isNewMessage) {
+                // Add animation class for new messages
+                messageDiv.classList.add('message-item-new');
+            }
+            
+            // Timestamp
+            const timestamp = new Date(msg.timestamp);
+            const timeStr = timestamp.toLocaleTimeString();
+            
+            // Get full message data (exclude internal properties)
+            const messageData = this.getDisplayableMessageData(msg);
+            
+            // Format message for display
+            let displayText = '';
+            if (messageData && Object.keys(messageData).length > 0) {
+                try {
+                    displayText = JSON.stringify(messageData, null, 2);
+                } catch (e) {
+                    displayText = String(messageData);
+                }
+            } else {
+                displayText = '(empty message)';
+            }
+            
+            const topicIndicator = topics.length > 1 ? ` - ${msg.topic || 'unknown'}` : '';
+            
+            messageDiv.innerHTML = `
+                <div class="message-item-header">
+                    <div class="message-id">#${allMessages.length - index}${topicIndicator}</div>
+                    <div class="message-timestamp">${timeStr}</div>
+                </div>
+                <pre class="message-content">${this.escapeHtml(displayText)}</pre>
+            `;
+            
+            messageList.appendChild(messageDiv);
+            
+            // Mark as rendered
+            this.renderedMessageIds.add(msg.id);
+        });
+        
+        // Auto-scroll to top (newest messages)
+        messageList.scrollTop = 0;
+    }
+    
+    // Get displayable message data (exclude internal properties)
+    getDisplayableMessageData(msg) {
+        // Clone the message and exclude internal properties
+        const data = { ...msg };
+        delete data.id;
+        delete data.timestamp;
+        delete data.topic;
+        
+        // If the message has a 'data' property, that's usually what we want to show
+        // Otherwise show all properties
+        if (data.data !== undefined) {
+            return this.unescapeJson(data.data);
+        }
+        
+        return this.unescapeJson(data);
+    }
+    
+    // Recursively unescape JSON strings
+    unescapeJson(obj, depth = 0) {
+        // Prevent infinite recursion
+        if (depth > 10) return obj;
+        
+        // If it's a string, try to parse as JSON
+        if (typeof obj === 'string') {
+            try {
+                const parsed = JSON.parse(obj);
+                // If parsing succeeded and it's an object/array, recursively unescape
+                if (typeof parsed === 'object' && parsed !== null) {
+                    return this.unescapeJson(parsed, depth + 1);
+                }
+                return parsed;
+            } catch (e) {
+                // Not a valid JSON string, return as-is
+                return obj;
+            }
+        }
+        
+        // If it's an array, process each element
+        if (Array.isArray(obj)) {
+            return obj.map(item => this.unescapeJson(item, depth + 1));
+        }
+        
+        // If it's an object, process each property
+        if (obj && typeof obj === 'object') {
+            const result = {};
+            for (const key in obj) {
+                if (obj.hasOwnProperty(key)) {
+                    result[key] = this.unescapeJson(obj[key], depth + 1);
+                }
+            }
+            return result;
+        }
+        
+        // Not a string, array, or object - return as-is
+        return obj;
+    }
+    
+    // Escape HTML to prevent XSS
+    escapeHtml(text) {
+        const div = document.createElement('div');
+        div.textContent = text;
+        return div.innerHTML;
+    }
+    
+    // Cleanup method
+    unmount() {
+        // Unsubscribe from messages if subscribed
+        if (this._messageUnsubscribe) {
+            this._messageUnsubscribe();
+            this._messageUnsubscribe = null;
+        }
+        
+        // Call parent unmount
+        super.unmount();
+    }
 }
 
 window.EventComponent = EventComponent;

public/scripts/view-models.js

@@ -1243,6 +1243,9 @@ class EventViewModel extends ViewModel {
         super();
         this.setMultiple({
             events: new Map(), // Map of topic -> { parts: [], count: number, lastSeen: timestamp }
+            allMessages: [], // Array of all messages for live viewing
+            allMessagesCounter: 0, // Counter to trigger updates
+            selectedTopic: null, // Currently selected topic for drawer
             isLoading: false,
             error: null,
             lastUpdateTime: null
@@ -1265,6 +1268,26 @@ class EventViewModel extends ViewModel {
             const topic = data.topic || data.type;
             
             if (topic) {
+                // Store the full message
+                const allMessages = this.get('allMessages') || [];
+                const newMessage = {
+                    ...data,
+                    topic: topic,
+                    timestamp: new Date().toISOString(),
+                    id: `${topic}-${Date.now()}-${Math.random()}`
+                };
+                allMessages.push(newMessage);
+                
+                // Keep only the last 1000 messages to prevent memory issues
+                const maxMessages = 1000;
+                if (allMessages.length > maxMessages) {
+                    allMessages.splice(0, allMessages.length - maxMessages);
+                }
+                
+                // Update messages and trigger change notification
+                this.set('allMessages', allMessages);
+                this.set('allMessagesCounter', this.get('allMessagesCounter') + 1);
+                
                 this.addTopic(topic, data);
             }
         });
@@ -1278,6 +1301,36 @@ class EventViewModel extends ViewModel {
             logger.debug('EventViewModel: WebSocket disconnected');
         });
     }
+    
+    // Get messages for a specific topic
+    getMessagesForTopic(topic) {
+        const allMessages = this.get('allMessages') || [];
+        return allMessages.filter(msg => {
+            // Handle nested events from cluster/event
+            if (msg.topic === 'cluster/event' && msg.data) {
+                try {
+                    const parsedData = typeof msg.data === 'string' ? JSON.parse(msg.data) : msg.data;
+                    if (parsedData && parsedData.event) {
+                        const fullTopic = `${msg.topic}/${parsedData.event}`;
+                        return fullTopic === topic;
+                    }
+                } catch (e) {
+                    // If parsing fails, just use the original topic
+                }
+            }
+            return msg.topic === topic;
+        });
+    }
+    
+    // Set the selected topic for drawer
+    setSelectedTopic(topic) {
+        this.set('selectedTopic', topic);
+    }
+    
+    // Clear selected topic
+    clearSelectedTopic() {
+        this.set('selectedTopic', null);
+    }
 
     // Add a topic (parsed by "/" separator)
     addTopic(topic, data = null) {

public/styles/main.css

@@ -3,6 +3,127 @@
     transform: rotate(-90deg);
     transform-origin: 50% 50%;
 }
+
+/* ========================================
+   MESSAGE LIST STYLES FOR EVENTS DRAWER
+   ======================================== */
+
+.topic-messages-container {
+    height: 100%;
+    overflow-y: auto;
+    padding: 16px;
+}
+
+.message-list-header {
+    margin-bottom: 16px;
+    padding-bottom: 16px;
+    border-bottom: 1px solid var(--border-color, rgba(255, 255, 255, 0.1));
+}
+
+.message-list-header-title {
+    color: var(--text-primary);
+    font-weight: 600;
+    margin-bottom: 8px;
+}
+
+.message-list-header-subtitle {
+    color: var(--text-secondary);
+    font-size: 0.9em;
+}
+
+.topic-code {
+    background: var(--card-background);
+    padding: 2px 6px;
+    border-radius: 4px;
+}
+
+.message-item {
+    margin-bottom: 12px;
+    padding: 12px;
+    background: var(--card-background, rgba(30, 30, 30, 0.5));
+    border-left: 3px solid var(--primary-color, #3498db);
+    border-radius: 4px;
+}
+
+.message-item-header {
+    display: flex;
+    justify-content: space-between;
+    align-items: center;
+    margin-bottom: 8px;
+}
+
+.message-id {
+    color: var(--text-secondary);
+    font-size: 0.85em;
+}
+
+.message-timestamp {
+    color: var(--text-secondary);
+    font-size: 0.85em;
+}
+
+.message-content {
+    margin: 0;
+    white-space: pre-wrap;
+    word-break: break-all;
+    font-family: monospace;
+    font-size: 0.9em;
+    color: var(--text-primary);
+}
+
+.empty-message-state {
+    text-align: center;
+    padding: 32px;
+    color: var(--text-secondary);
+}
+
+.topic-multi-indicator {
+    color: var(--text-secondary);
+}
+
+/* Message animations - only for new messages */
+.message-item-new {
+    animation: messageSlideIn 0.5s cubic-bezier(0.25, 0.46, 0.45, 0.94);
+}
+
+@keyframes messageSlideIn {
+    0% {
+        opacity: 0;
+        transform: translateY(-15px) scale(0.98);
+        max-height: 0;
+        margin-bottom: 0;
+        padding-top: 0;
+        padding-bottom: 0;
+    }
+    50% {
+        opacity: 0.8;
+    }
+    100% {
+        opacity: 1;
+        transform: translateY(0) scale(1);
+        max-height: 1000px;
+        margin-bottom: 12px;
+        padding-top: 12px;
+        padding-bottom: 12px;
+    }
+}
+
+/* Node highlight animation - only for selected nodes */
+.node-highlight.highlighted {
+    animation: nodePulse 2s ease-in-out infinite;
+    filter: drop-shadow(0 0 3px rgba(255, 215, 0, 0.6));
+}
+
+@keyframes nodePulse {
+    0%, 100% {
+        opacity: 1;
+        transform: scale(1);
+    }
+    50% {
+        opacity: 0.6;
+        transform: scale(1.05);
+    }
+}
 * {
     margin: 0;
     padding: 0;