[同步]1. 同步主库到2024年8月8日 91433fc

91433fc - tried to support websocket encoding with mask

Author: AlianBlank

src/GameFrameX.SuperSocket.WebSocket/WebSocketDataPipelineFilter.cs

@@ -7,18 +7,21 @@ namespace GameFrameX.SuperSocket.WebSocket
 {
     public class WebSocketDataPipelineFilter : PackagePartsPipelineFilter<WebSocketPackage>
     {
-        private HttpHeader _httpHeader;
+        private readonly HttpHeader _httpHeader;
+
+        private readonly bool _requireMask = true;
 
         /// <summary>
         /// -1: default value
         /// 0: ready to preserve bytes
         /// N: the bytes we preserved
         /// </summary>
         private long _consumed = -1;
-
-        public WebSocketDataPipelineFilter(HttpHeader httpHeader)
+        
+        public WebSocketDataPipelineFilter(HttpHeader httpHeader, bool requireMask = true)
         {
             _httpHeader = httpHeader;
+            _requireMask = requireMask;
         }
 
         protected override WebSocketPackage CreatePackage()
@@ -72,6 +75,11 @@ protected override void OnPartReaderSwitched(IPackagePartReader<WebSocketPackage
         {
             if (currentPartReader is FixPartReader)
             {
+                if (_requireMask && !CurrentPackage.HasMask)
+                {
+                    throw new ProtocolException("Mask is required for this websocket package.");
+                }
+
                 // not final fragment or is the last fragment of multiple fragments message
                 // _consumed = 0 means we are ready to preserve the bytes
                 if (!CurrentPackage.FIN || CurrentPackage.Head != null)