diff --git a/server/socket.go b/server/socket.go index cf4861722..69f2309cf 100644 --- a/server/socket.go +++ b/server/socket.go @@ -2,7 +2,6 @@ package server import ( "context" - "errors" "net/http" "strings" "sync" @@ -65,17 +64,8 @@ func (h *SocketHub) ServeWebsocket(w http.ResponseWriter, r *http.Request) { } defer conn.Close(websocket.StatusInternalError, "") - err = h.subscribe(r.Context(), conn) - - if errors.Is(err, context.Canceled) { - return - } - if cs := websocket.CloseStatus(err); cs == websocket.StatusNormalClosure || cs == websocket.StatusGoingAway { - return - } - if err != nil { - log.ERROR.Println(err) - return + if err := h.subscribe(r.Context(), conn); err != nil { + log.TRACE.Println("web socket upgrade:", err) } }