RAGECOOP-V/RageCoop.Core/Packets/CustomEvent.cs

using System;
using System.Collections.Generic;
using System.Text;
using Lidgren.Network;
namespace RageCoop.Core
{
    internal partial class Packets
    {

        internal class CustomEvent : Packet
        {
            public override PacketType Type  => (_queued ? PacketType.CustomEventQueued : PacketType.CustomEvent);
            public CustomEvent(Func<byte,BitReader,object> onResolve = null,bool queued=false)
            {
                _resolve= onResolve;
                _queued= queued;
            }
            private bool _queued;
            private Func<byte, BitReader, object> _resolve { get; set; }
            public int Hash { get; set; }
            public object[] Args { get; set; }

            public override byte[] Serialize()
            {
                Args= Args ?? new object[] { };

                List<byte> result = new List<byte>();
                result.AddInt(Hash);
                result.AddInt(Args.Length);
                (byte, byte[]) tup;
                foreach (var arg in Args)
                {
                    tup=CoreUtils.GetBytesFromObject(arg);
                    if (tup.Item1==0||tup.Item2==null)
                    {
                        throw new ArgumentException($"Object of type {arg.GetType()} is not supported");
                    }
                    result.Add(tup.Item1);
                    result.AddRange(tup.Item2);
                }
                return result.ToArray();
            }

            public override void Deserialize(byte[] array)
            {
                BitReader reader = new BitReader(array);

                Hash = reader.ReadInt32();
                var len=reader.ReadInt32();
                Args=new object[len];
                for (int i = 0; i < len; i++)
                {
                    byte type = reader.ReadByte();
                    switch (type)
                    {
                        case 0x01:
                            Args[i]=reader.ReadByte(); break;
                        case 0x02:
                            Args[i]=reader.ReadInt32(); break;
                        case 0x03:
                            Args[i]=reader.ReadUInt16(); break;
                        case 0x04:
                            Args[i]=reader.ReadInt32(); break;
                        case 0x05:
                            Args[i]=reader.ReadUInt32(); break;
                        case 0x06:
                            Args[i]=reader.ReadInt64(); break;
                        case 0x07:
                            Args[i]=reader.ReadUInt64(); break;
                        case 0x08:
                            Args[i]=reader.ReadSingle(); break;
                        case 0x09:
                            Args[i]=reader.ReadBoolean(); break;
                        case 0x10:
                            Args[i]=reader.ReadString(); break;
                        case 0x11: 
                            Args[i]=reader.ReadVector3(); break;
                        case 0x12:
                            Args[i]=reader.ReadQuaternion(); break;
                        case 0x13:
                            Args[i]=(GTA.Model)reader.ReadInt32(); break;
                        case 0x14:
                            Args[i]=reader.ReadVector2(); break;
                        default:
                            if (_resolve==null)
                            {
                                throw new InvalidOperationException($"Unexpected type:{type}\r\n{array.Dump()}");
                            }
                            else
                            {
                                Args[i]=_resolve(type, reader); break;
                            }
                    }
                }
            }
        }
    }
}