Method handleWebSocket

internal/dashboard/api.go:143–181

handleWebSocket handles WebSocket connections for real-time updates

(w http.ResponseWriter, r *http.Request)

// handleWebSocket handles WebSocket connections for real-time updates
func (ds *DashboardServer) handleWebSocket(w http.ResponseWriter, r *http.Request) {
	conn, err := ds.upgrader.Upgrade(w, r, nil)
	if err != nil {
		shared.LogErrorf("Failed to upgrade WebSocket connection: %v", err)
		return
	}
	
	ds.clientsMu.Lock()
	ds.clients[conn] = true
	ds.clientsMu.Unlock()
	
	shared.LogInfof("New WebSocket client connected, total clients: %d", len(ds.clients))
	
	// Handle client disconnection
	defer func() {
		ds.clientsMu.Lock()
		delete(ds.clients, conn)
		ds.clientsMu.Unlock()
		conn.Close()
		shared.LogInfof("WebSocket client disconnected, remaining clients: %d", len(ds.clients))
	}()
	
	// Send initial dashboard data
	data := ds.collector.CollectDashboardData()
	if jsonData, err := json.Marshal(data); err == nil {
		conn.WriteMessage(websocket.TextMessage, jsonData)
	}
	
	// Keep connection alive and handle pings
	for {
		_, _, err := conn.ReadMessage()
		if err != nil {
			if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
				shared.LogErrorf("WebSocket error: %v", err)
			}
			break
		}
	}
}

// startBroadcaster starts the background broadcaster for WebSocket updates
func (ds *DashboardServer) startBroadcaster() {