Prevent concurrent writes to a websocket connection

Author: zkokelj

tools/walletextension/userconn/user_conn.go

@@ -6,6 +6,7 @@ import (
 	"net/http"
 	"net/url"
 	"strings"
+	"sync"
 
 	"github.com/ten-protocol/go-ten/go/common/log"
 
@@ -39,6 +40,7 @@ type userConnWS struct {
 	isClosed bool
 	logger   gethlog.Logger
 	req      *http.Request
+	mu       sync.Mutex
 }
 
 func NewUserConnHTTP(resp http.ResponseWriter, req *http.Request, logger gethlog.Logger) UserConn {
@@ -106,6 +108,9 @@ func (w *userConnWS) ReadRequest() ([]byte, error) {
 }
 
 func (w *userConnWS) WriteResponse(msg []byte) error {
+	w.mu.Lock()
+	defer w.mu.Unlock()
+
 	err := w.conn.WriteMessage(websocket.TextMessage, msg)
 	if err != nil {
 		if websocket.IsCloseError(err) || strings.Contains(string(msg), "EOF") {