Fix tracking websocket connections (#26943)

server/channels/app/platform/web_conn.go

@@ -417,8 +417,15 @@ func (wc *WebConn) Pump() {
 
 func (wc *WebConn) readPump() {
 	defer func() {
+		if metrics := wc.Platform.metricsIFace; metrics != nil {
+			metrics.DecrementHTTPWebSockets(wc.originClient)
+		}
 		wc.WebSocket.Close()
 	}()
+	if metrics := wc.Platform.metricsIFace; metrics != nil {
+		metrics.IncrementHTTPWebSockets(wc.originClient)
+	}
+
 	wc.WebSocket.SetReadLimit(model.SocketMaxMessageSizeKb)
 	wc.WebSocket.SetReadDeadline(time.Now().Add(pongWaitTime))
 	wc.WebSocket.SetPongHandler(func(string) error {

server/channels/app/platform/web_hub.go

@@ -423,9 +423,6 @@ func (h *Hub) Start() {
 
 				connIndex.Add(webConn)
 				atomic.StoreInt64(&h.connectionCount, int64(connIndex.AllActive()))
-				if metrics := h.platform.metricsIFace; metrics != nil {
-					metrics.IncrementHTTPWebSockets(webConn.originClient)
-				}
 
 				if webConn.IsAuthenticated() && webConn.reuseCount == 0 {
 					// The hello message should only be sent when the reuseCount is 0.
@@ -440,9 +437,6 @@ func (h *Hub) Start() {
 				webConn.active.Store(false)
 
 				atomic.StoreInt64(&h.connectionCount, int64(connIndex.AllActive()))
-				if metrics := h.platform.metricsIFace; metrics != nil {
-					metrics.DecrementHTTPWebSockets(webConn.originClient)
-				}
 
 				if webConn.UserId == "" {
 					continue