Rename folder attempt

GameServer/Packet.cs

@@ -0,0 +1,103 @@
+using System.Buffers.Binary;
+using Common.Resources.Proto;
+using Newtonsoft.Json;
+using Common.Utils;
+using ProtoBuf;
+using System.Reflection;
+
+namespace PemukulPaku.GameServer
+{
+    public class Packet
+    {
+        public readonly byte[] Raw;
+        public readonly byte[] HeadMagic;
+        public readonly uint UserId;
+        public readonly uint CmdId;
+        public readonly uint BodyLen;
+        public readonly byte[] Body;
+        public readonly byte[] TailMagic;
+        public static readonly Logger c = new("Packet", ConsoleColor.Magenta);
+
+        public Packet(byte[] buf)
+        {
+            Raw = buf;
+            CmdId = BinaryPrimitives.ReadUInt32BigEndian(buf.AsSpan(24));
+            string? PacketName = Enum.GetName(typeof(CmdId), CmdId);
+
+            if (PacketName == null)
+            {
+                c.Error($"CMD ID {CmdId} NOT RECOGNIZED!");
+            }
+
+            HeadMagic = buf.Take(4).ToArray();
+            UserId = BinaryPrimitives.ReadUInt32BigEndian(buf.AsSpan(12));
+            ushort headerLen = BinaryPrimitives.ReadUInt16BigEndian(buf.AsSpan(28));
+            BodyLen = BinaryPrimitives.ReadUInt32BigEndian(buf.AsSpan(30));
+            Body = buf.Skip(34 + headerLen).Take((int)BodyLen).ToArray();
+            TailMagic = buf.Skip(buf.Length - 4).ToArray();
+
+            try
+            {
+                MemoryStream ms = new(Body);
+                object SerializedBody = Serializer.NonGeneric.Deserialize(typeof(Common.Global).Assembly.GetType($"Common.Resources.Proto.{PacketName}"), ms)!;
+                c.Debug(JsonConvert.SerializeObject(SerializedBody));
+            }
+            catch
+            {
+                c.Error($"Failed to deserialized packet with Common.Resources.Proto.{PacketName}");
+            }
+        }
+    }
+
+    public class PacketCmdId : Attribute
+    {
+        public CmdId Id { get; }
+
+        public PacketCmdId(CmdId id)
+        {
+            Id = id;
+        }
+    }
+
+    public interface IPacketHandler
+    {
+        public void Handle(Session session, Packet packet);
+    }
+
+    public static class PacketFactory
+    {
+        public static readonly Dictionary<CmdId, IPacketHandler> Handlers = new();
+        static readonly Logger c = new("Factory", ConsoleColor.Yellow);
+
+        public static void LoadPacketHandlers()
+        {
+            c.Log("Loading Packet Handlers...");
+
+            IEnumerable<Type> classes = from t in Assembly.GetExecutingAssembly().GetTypes()
+                                        select t;
+
+            foreach ((Type t, PacketCmdId attr) in from Type? t in classes.ToList()
+                                                   let attrs = (Attribute[])t.GetCustomAttributes(typeof(PacketCmdId), false)
+                                                   where attrs.Length > 0
+                                                   let attr = (PacketCmdId)attrs[0]
+                                                   where !Handlers.ContainsKey(attr.Id)
+                                                   select (t, attr))
+            {
+                Handlers.Add(attr.Id, (IPacketHandler)Activator.CreateInstance(t)!);
+
+                c.Log($"Loaded PacketHandler {t.Name} for Packet Type {attr.Id}");
+            }
+
+            c.Log("Finished Loading Packet Handlers");
+        }
+    }
+
+    [PacketCmdId(CmdId.PlayerLoginReq)]
+    public class PlayerLoginReqHandler : IPacketHandler
+    {
+        public void Handle(Session session, Packet packet)
+        {
+            throw new NotImplementedException();
+        }
+    }
+}