PR, Palworld Support (Tested on Minecraft and PalWorld)

src/CoreRCON/Constants.cs

@@ -12,11 +12,12 @@ internal class Constants
         /// Minimum size of a rcon packet
         /// </summary>
         internal const int MIN_PACKET_SIZE = 14;
-
+
+
         /// <summary>
         /// The size of the header of an RCON packet.
         /// </summary>
-        internal const int PACKET_HEADER_SIZE = 8;
+        internal const int PACKET_HEADER_SIZE = 12;
 
         /// <summary>
         /// The size of the header of an RCON packet.
@@ -28,5 +29,6 @@ internal class Constants
         /// Used to finde the end of a multi packet response.
         /// </summary>
         internal const string MULTI_PACKET_END_RESPONSE = "\0\u0001\0\0";
+
     }
 }

src/CoreRCON/Exceptions.cs

@@ -19,4 +19,19 @@ public AuthenticationException(string message, Exception innerException) : base(
         {
         }
     }
+
+    public class AuthenticationFailedException : AuthenticationException
+    {
+        public AuthenticationFailedException()
+        {
+        }
+
+        public AuthenticationFailedException(string message) : base(message)
+        {
+        }
+
+        public AuthenticationFailedException(string message, Exception innerException) : base(message, innerException)
+        {
+        }
+    }
 }

src/CoreRCON/Extensions.cs

@@ -134,18 +134,16 @@ public static async Task<T> TimeoutAfter<T>(this Task<T> task, TimeSpan? timeout
             {
                 var delayTask = Task.Delay(timeout.Value, cts.Token);
 
-                var resultTask = await Task.WhenAny(task, delayTask);
+                var resultTask = await Task.WhenAny(task, delayTask).ConfigureAwait(false);
                 if (resultTask == delayTask)
                 {
                     // Operation cancelled
                     throw new TimeoutException();
                 }
-                else
-                {
-                    cts.Cancel();
-                }
 
-                return await task;
+                cts.Cancel();
+
+                return await task.ConfigureAwait(false);
             }
         }
 

src/CoreRCON/PacketFormats/RCONPacket.cs

@@ -69,14 +69,16 @@ internal static RCONPacket FromBytes(byte[] buffer)
         internal byte[] ToBytes()
         {
             int bodyLength = Encoding.UTF8.GetByteCount(Body);
-            int size = Constants.PACKET_HEADER_SIZE + Constants.PACKET_PADDING_SIZE + bodyLength;
+            //
+            int packetSize = Constants.PACKET_HEADER_SIZE + Constants.PACKET_PADDING_SIZE + bodyLength;
 
-            byte[] packetBytes = new byte[size+4];
+            byte[] packetBytes = new byte[packetSize];
             Span<byte> packetSpan = packetBytes;
 
             // Write packet size
             // Packet size parameter does not include the size of the size parameter itself
-            BinaryPrimitives.WriteInt32LittleEndian(packetSpan, size);
+            var normalizedPacketSize = packetSize - 4;
+            BinaryPrimitives.WriteInt32LittleEndian(packetSpan, normalizedPacketSize); 
             packetSpan = packetSpan.Slice(4);
 
             // Write ID
@@ -87,7 +89,7 @@ internal byte[] ToBytes()
             BinaryPrimitives.WriteInt32LittleEndian(packetSpan, (int)Type);
 
             // Write body
-            Encoding.UTF8.GetBytes(Body, 0, Body.Length, packetBytes, 12);
+            Encoding.UTF8.GetBytes(Body, 0, Body.Length, packetBytes, Constants.PACKET_HEADER_SIZE);
 
             packetBytes[packetBytes.Length - 2] = 0; // Null terminator for the body
             packetBytes[packetBytes.Length - 1] = 0; // Null terminator for the package