97 lines
3.6 KiB
C#
97 lines
3.6 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Text;
|
|
using Lidgren.Network;
|
|
namespace RageCoop.Core
|
|
{
|
|
internal partial class Packets
|
|
{
|
|
|
|
internal class CustomEvent : Packet
|
|
{
|
|
public CustomEvent(Func<byte,BitReader,object> onResolve = null)
|
|
{
|
|
_resolve= onResolve;
|
|
}
|
|
private Func<byte, BitReader, object> _resolve { get; set; }
|
|
public int Hash { get; set; }
|
|
public List<object> Args { get; set; }
|
|
|
|
public override void Pack(NetOutgoingMessage message)
|
|
{
|
|
Args= Args ?? new List<object>(0);
|
|
message.Write((byte)PacketType.CustomEvent);
|
|
|
|
List<byte> result = new List<byte>();
|
|
result.AddInt(Hash);
|
|
result.AddInt(Args.Count);
|
|
(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);
|
|
}
|
|
|
|
message.Write(result.Count);
|
|
message.Write(result.ToArray());
|
|
}
|
|
|
|
public override void Unpack(byte[] array)
|
|
{
|
|
BitReader reader = new BitReader(array);
|
|
|
|
Hash = reader.ReadInt();
|
|
var len=reader.ReadInt();
|
|
Args=new List<object>(len);
|
|
for (int i = 0; i < len; i++)
|
|
{
|
|
byte type = reader.ReadByte();
|
|
switch (type)
|
|
{
|
|
case 0x01:
|
|
Args.Add(reader.ReadByte()); break;
|
|
case 0x02:
|
|
Args.Add(reader.ReadShort()); break;
|
|
case 0x03:
|
|
Args.Add(reader.ReadUShort()); break;
|
|
case 0x04:
|
|
Args.Add(reader.ReadInt()); break;
|
|
case 0x05:
|
|
Args.Add(reader.ReadUInt()); break;
|
|
case 0x06:
|
|
Args.Add(reader.ReadLong()); break;
|
|
case 0x07:
|
|
Args.Add(reader.ReadULong()); break;
|
|
case 0x08:
|
|
Args.Add(reader.ReadFloat()); break;
|
|
case 0x09:
|
|
Args.Add(reader.ReadBool()); break;
|
|
case 0x10:
|
|
Args.Add(reader.ReadString()); break;
|
|
case 0x11:
|
|
Args.Add(reader.ReadVector3()); break;
|
|
case 0x12:
|
|
Args.Add(reader.ReadQuaternion()); break;
|
|
case 0x13:
|
|
Args.Add((GTA.Model)reader.ReadInt()); break;
|
|
default:
|
|
if (_resolve==null)
|
|
{
|
|
throw new InvalidOperationException($"Unexpected type:{type}\r\n{array.Dump()}");
|
|
}
|
|
else
|
|
{
|
|
Args.Add(_resolve(type, reader)); break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|