merge(fix): connection error with wsrx

🐛 fix connection error with wsrx
ElaBosak233 · Jun 6, 2024 · 86e955b · 86e955b
2 parents e832647 + 2493708
commit 86e955b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/extension/proxy/ws.go b/internal/extension/proxy/ws.go
@@ -95,7 +95,7 @@ func (w *WSProxy) handle(conn *websocket.Conn) {
 			zap.L().Debug("TCP connection read error.", zap.Error(err))
 			return
 		}
-		if err := conn.WriteMessage(websocket.TextMessage, buf[:n]); err != nil {
+		if err := conn.WriteMessage(websocket.BinaryMessage, buf[:n]); err != nil {
 			zap.L().Debug("WebSocket write error.", zap.Error(err))
 			return
 		}
@@ -175,7 +175,7 @@ func (w *WSProxy) handleInTrafficCapture(conn *websocket.Conn) {
 			zap.L().Debug("TCP connection read error.", zap.Error(_err))
 			return
 		}
-		_err = conn.WriteMessage(websocket.TextMessage, buf[:n])
+		_err = conn.WriteMessage(websocket.BinaryMessage, buf[:n])
 		if _err != nil {
 			zap.L().Debug("WebSocket write error.", zap.Error(_err))
 			return