go/internal/pusher/conn.go

@@ -41,15 +41,14 @@ func (c *Conn) ReadPump(ctx context.Context, hub *Hub) {
 				slog.Info("websocket context cancelled", "connId", c.id, "humanId", c.humanID, "error", ctx.Err())
 				return
 			}
-			slog.Info("websocket read error", "connId", c.id, "humanId", c.humanID, "error", err)
+			slog.Warn("websocket read error", "connId", c.id, "humanId", c.humanID, "error", err)
 			return
 		}
 
 		// Respond to keep-alive pings
 		if string(data) == "ping" {
 			if err := c.ws.Write(ctx, websocket.MessageText, []byte("pong")); err != nil {
-				slog.Debug("websocket pong write error", "connId", c.id, "error", err)
-				return
+				slog.Warn("websocket pong write error", "connId", c.id, "error", err)
 			}
 			continue
 		}