no idea what happened

Author: GuilhermeStrice

Infinity.WebSockets/WebSocketClientConnection.cs

@@ -24,7 +24,7 @@ public class WebSocketClientConnection : WebSocketConnection
         protected override NetworkStream Stream => stream!;
         protected override bool MaskOutgoingFrames => true;
 
-        protected override bool ValidateIncomingMask() => false;
+        protected override bool ValidateIncomingMask(bool masked) => !masked;
         public override int MaxPayloadSize { get; set; } = Configuration.MaxBufferSize;
 
         public WebSocketClientConnection(ILogger? _logger = null) { logger = _logger; }

Infinity.WebSockets/WebSocketConnection.cs

@@ -23,6 +23,8 @@ public abstract class WebSocketConnection : NetworkConnection
         protected abstract bool MaskOutgoingFrames { get; }
         public abstract int MaxPayloadSize { get; set; }
 
+        protected abstract bool ValidateIncomingMask(bool masked);
+
         public override async Task<SendErrors> Send(MessageWriter writer)
         {
             if (state != ConnectionState.Connected || Stream == null || closeSent)
@@ -130,8 +132,6 @@ private async Task SendPing()
             }
         }
 
-        protected abstract bool ValidateIncomingMask();
-
         protected async Task ReceiveLoop()
         {
             if (Stream == null) return;
@@ -168,7 +168,7 @@ protected async Task ReceiveLoop()
 
 
                     // Validate masking
-                    if (!ValidateIncomingMask())
+                    if (!ValidateIncomingMask(masked))
                     {
                         var cw = MessageWriter.Get();
                         cw.Write((byte)(1002 >> 8));

Infinity.WebSockets/WebSocketServerConnection.cs

@@ -13,7 +13,7 @@ public class WebSocketServerConnection : WebSocketConnection
         protected override NetworkStream Stream => stream;
         protected override bool MaskOutgoingFrames => false;
 
-        protected override bool ValidateIncomingMask() => true;
+        protected override bool ValidateIncomingMask(bool masked) => masked;
         public override int MaxPayloadSize { get; set; } = 64 * 1024 * 1024; // default 64MB
 
         // additional handshake metadata exposed for consumers