Method writePump

server/handlers/websocket.go:167–197

writePump writes messages to the WebSocket connection

(wsConn *WebSocketConnection)

// writePump writes messages to the WebSocket connection
func (h *WebSocketHandler) writePump(wsConn *WebSocketConnection) {
	ticker := time.NewTicker(54 * time.Second)
	defer func() {
		ticker.Stop()
		_ = wsConn.Conn.Close()
	}()

	for {
		select {
		case message, ok := <-wsConn.Send:
			_ = wsConn.Conn.SetWriteDeadline(time.Now().Add(10 * time.Second))
			if !ok {
				_ = wsConn.Conn.WriteMessage(websocket.CloseMessage, []byte{})
				return
			}

			if err := wsConn.Conn.WriteMessage(websocket.TextMessage, message); err != nil {
				return
			}

		case <-ticker.C:
			_ = wsConn.Conn.SetWriteDeadline(time.Now().Add(10 * time.Second))
			if err := wsConn.Conn.WriteMessage(websocket.PingMessage, nil); err != nil {
				return
			}

		case <-wsConn.ctx.Done():
			return
		}
	}
}

// handleMessage handles different message types
func (h *WebSocketHandler) handleMessage(wsConn *WebSocketConnection, msg *WebSocketMessage) {