From f5d08d8d90b86ac01a6df0cbd7d9168da9fe307e Mon Sep 17 00:00:00 2001
From: root <295172551@qq.com>
Date: Sat, 26 Jul 2025 20:44:40 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=BC=BA=20MessageValidationStep=20?=
 =?UTF-8?q?=E5=BC=82=E5=B8=B8=E5=A4=84=E7=90=86=EF=BC=9A1)=20=E5=B0=86=20t?=
 =?UTF-8?q?hrow=20=E6=9B=BF=E6=8D=A2=E4=B8=BA=20PipelineException=202)=20?=
 =?UTF-8?q?=E6=B7=BB=E5=8A=A0=20input.Data=20=E5=AE=89=E5=85=A8=E9=AA=8C?=
 =?UTF-8?q?=E8=AF=81=E5=92=8C=E5=AD=97=E7=AC=A6=E4=B8=B2=E8=BD=AC=E6=8D=A2?=
 =?UTF-8?q?=203)=20=E5=A2=9E=E5=BC=BA=E9=94=99=E8=AF=AF=E6=97=A5=E5=BF=97?=
 =?UTF-8?q?=E8=AE=B0=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Pipeline/Steps/MessageValidationStep.cs    | 18 ++++++++++++++++--
 1 file changed, 16 insertions(+), 2 deletions(-)

diff --git a/src/X1.WebSocket/Pipeline/Steps/MessageValidationStep.cs b/src/X1.WebSocket/Pipeline/Steps/MessageValidationStep.cs
index d9666d6..c7cd782 100644
--- a/src/X1.WebSocket/Pipeline/Steps/MessageValidationStep.cs
+++ b/src/X1.WebSocket/Pipeline/Steps/MessageValidationStep.cs
@@ -28,8 +28,22 @@ public class MessageValidationStep : IPipelineStep<WebSocketMessage, WebSocketMe
         }
         catch (Exception ex)
         {
-            _logger.LogError(ex, "Message validation failed for connection {ConnectionId}", input.ConnectionId);
-            throw;
+            var messageData = "null or empty";
+            if (input.Data != null && input.Data.Length > 0)
+            {
+                try
+                {
+                    messageData = System.Text.Encoding.UTF8.GetString(input.Data);
+                }
+                catch (Exception encodingEx)
+                {
+                    messageData = $"Encoding error: {encodingEx.Message}";
+                }
+            }
+            
+            _logger.LogError(ex, "Message validation failed for connection {ConnectionId}, message data: {MessageData}", 
+                input.ConnectionId, messageData);
+            throw new PipelineException($"Message validation failed: {ex.Message}", ex);
         }
     }