added EOFPacket

Author: kerryjiang

src/SuperSocket.MySQL/MySQLConnection.cs

@@ -5,6 +5,7 @@
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
 using SuperSocket.Client;
 using SuperSocket.MySQL.Packets;
 using SuperSocket.ProtoBase;
@@ -23,8 +24,8 @@ public class MySQLConnection : EasyClient<MySQLPacket>
 
         public bool IsAuthenticated { get; private set; }
 
-        public MySQLConnection(string host, int port, string userName, string password)
-            : base(new MySQLPacketFilter(MySQLPacketDecoder.ClientInstance))
+        public MySQLConnection(string host, int port, string userName, string password, ILogger logger = null)
+            : base(new MySQLPacketFilter(MySQLPacketDecoder.ClientInstance), logger)
         {
             _host = host ?? throw new ArgumentNullException(nameof(host));
             _port = port > 0 ? port : DefaultPort;
@@ -87,6 +88,8 @@ public async Task ConnectAsync(CancellationToken cancellationToken = default)
                         ? errorPacket.ErrorMessage
                         : "Authentication failed";
                     throw new InvalidOperationException($"MySQL authentication failed: {errorMsg} (Error {errorPacket.ErrorCode})");
+                case EOFPacket eofPacket:
+                    throw new InvalidOperationException($"MySQL authentication failed.");
                 default:
                     throw new InvalidOperationException($"Unexpected packet received during authentication: {authResult?.GetType().Name ?? "null"}");
             }
@@ -160,7 +163,8 @@ public async Task DisconnectAsync()
         {
             try
             {
-                await CloseAsync();
+                if (Connection != null)
+                    await CloseAsync();
             }
             finally
             {

src/SuperSocket.MySQL/MySQLPacketFactory.cs

@@ -15,7 +15,8 @@ static MySQLPacketFactory()
             ClientInstance = new MySQLPacketFactory()
                 .RegisterPacketType<HandshakePacket>(-1)
                 .RegisterPacketType<OKPacket>(0x00)
-                .RegisterPacketType<ErrorPacket>(0xFF);
+                .RegisterPacketType<ErrorPacket>(0xFF)
+                .RegisterPacketType<EOFPacket>(0xFE);
         }
 
         private readonly Dictionary<int, Func<MySQLPacket>> _packetCreators = new();

src/SuperSocket.MySQL/Packets/EOFPacket.cs

@@ -0,0 +1,39 @@
+using System;
+using System.Buffers;
+using SuperSocket.ProtoBase;
+
+namespace SuperSocket.MySQL.Packets
+{
+    public class EOFPacket : MySQLPacket, IPacketWithHeaderByte
+    {
+        public byte Header { get; set; } = 0xFE;
+        public ushort WarningCount { get; set; }
+        public ushort StatusFlags { get; set; }
+
+        protected internal override void Decode(ref SequenceReader<byte> reader, object context)
+        {
+            if (reader.TryReadLittleEndian(out ushort warningCount))
+            {
+                WarningCount = warningCount;
+            }
+            else
+            {
+                throw new InvalidOperationException("Failed to read WarningCount from EOFPacket.");
+            }
+
+            if (reader.TryReadLittleEndian(out ushort statusFlags))
+            {
+                StatusFlags = statusFlags;
+            }
+            else
+            {
+                throw new InvalidOperationException("Failed to read StatusFlags from EOFPacket.");
+            }
+        }
+
+        protected internal override int Encode(IBufferWriter<byte> writer)
+        {
+            throw new NotImplementedException();
+        }
+    }
+}