Method readPump

server/handlers/websocket.go:122–164

readPump reads messages from the WebSocket connection

(wsConn *WebSocketConnection)

// readPump reads messages from the WebSocket connection
func (h *WebSocketHandler) readPump(wsConn *WebSocketConnection) {
	defer func() {
		h.closeConnection(wsConn)
	}()

	_ = wsConn.Conn.SetReadDeadline(time.Now().Add(60 * time.Second))
	wsConn.Conn.SetPongHandler(func(string) error {
		_ = wsConn.Conn.SetReadDeadline(time.Now().Add(60 * time.Second))
		return nil
	})

	for {
		_, message, err := wsConn.Conn.ReadMessage()
		if err != nil {
			logging.Info(wsConn.ctx, "websocket.read.closed", map[string]any{
				"connection_id": wsConn.ID,
				"error":         err.Error(),
			})
			if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
				logging.Error(wsConn.ctx, "websocket.read.error", map[string]any{
					"connection_id": wsConn.ID,
					"error":         err.Error(),
				})
			}
			break
		}

		logging.Info(wsConn.ctx, "websocket.message.received", map[string]any{
			"connection_id": wsConn.ID,
			"message":       string(message),
		})

		// Parse message
		var msg WebSocketMessage
		if err := json.Unmarshal(message, &msg); err != nil {
			h.sendError(wsConn, "invalid_message", "Failed to parse message")
			continue
		}

		// Handle message based on type
		h.handleMessage(wsConn, &msg)
	}
}

// writePump writes messages to the WebSocket connection
func (h *WebSocketHandler) writePump(wsConn *WebSocketConnection) {