46 lines
1.5 KiB
C#
46 lines
1.5 KiB
C#
using System.Buffers;
|
|
using System.Buffers.Binary;
|
|
using MemoryPack;
|
|
|
|
namespace Phantom.Utils.Rpc.Message;
|
|
|
|
static class MessageSerializer {
|
|
private static readonly MemoryPackSerializerOptions SerializerOptions = MemoryPackSerializerOptions.Utf8;
|
|
|
|
public static byte[] Serialize<T>(T message) {
|
|
return MemoryPackSerializer.Serialize(message, SerializerOptions);
|
|
}
|
|
|
|
public static void Serialize<T>(IBufferWriter<byte> destination, T message) {
|
|
MemoryPackSerializer.Serialize(typeof(T), destination, message, SerializerOptions);
|
|
}
|
|
|
|
public static T Deserialize<T>(ReadOnlyMemory<byte> memory) {
|
|
return MemoryPackSerializer.Deserialize<T>(memory.Span) ?? throw new NullReferenceException();
|
|
}
|
|
|
|
public static void WriteCode(IBufferWriter<byte> destination, ushort value) {
|
|
Span<byte> buffer = stackalloc byte[2];
|
|
BinaryPrimitives.WriteUInt16LittleEndian(buffer, value);
|
|
destination.Write(buffer);
|
|
}
|
|
|
|
public static ushort ReadCode(ref ReadOnlyMemory<byte> memory) {
|
|
ushort value = BinaryPrimitives.ReadUInt16LittleEndian(memory.Span);
|
|
memory = memory[2..];
|
|
return value;
|
|
}
|
|
|
|
public static void WriteSequenceId(IBufferWriter<byte> destination, uint sequenceId) {
|
|
Span<byte> buffer = stackalloc byte[4];
|
|
BinaryPrimitives.WriteUInt32LittleEndian(buffer, sequenceId);
|
|
destination.Write(buffer);
|
|
}
|
|
|
|
public static uint ReadSequenceId(ref ReadOnlyMemory<byte> memory) {
|
|
uint value = BinaryPrimitives.ReadUInt32LittleEndian(memory.Span);
|
|
memory = memory[4..];
|
|
return value;
|
|
}
|
|
}
|