StreamPeerBuffer

using System;
using System.Text;
using Reckfell;

public static class BinaryMessageExample
{
    private const uint Magic = 0x52464C31;
    private const int HeaderSize = 12;
    private const int MaxPayload = 4096;

    public static bool TryEncode(string message, out byte[] packet)
    {
        packet = Array.Empty<byte>();
        if (message.Length > MaxPayload)
            return false;
        byte[] payload;
        try { payload = new UTF8Encoding(false, true).GetBytes(message); }
        catch (EncoderFallbackException) { return false; }
        if (payload.Length > MaxPayload)
            return false;
        using var writer = new StreamPeerBuffer { BigEndian = true };
        writer.PutU32(Magic);
        writer.PutU16(1);
        writer.PutU16(0);
        writer.PutU32((uint)payload.Length);
        if (writer.PutData(payload) != Error.Ok)
            return false;
        packet = writer.DataArray;
        return true;
    }

    public static bool TryDecode(byte[] packet, out string message)
    {
        message = "";
        if (packet.Length < HeaderSize || packet.Length > HeaderSize + MaxPayload)
            return false;
        using var reader = new StreamPeerBuffer { BigEndian = true, DataArray = packet };
        if (reader.GetU32() != Magic || reader.GetU16() != 1 || reader.GetU16() != 0)
            return false;
        uint length = reader.GetU32();
        if (length > MaxPayload || length != (uint)reader.GetAvailableBytes())
            return false;
        if (length == 0)
            return true;
        using var result = reader.GetData((int)length);
        using Variant status = result[0];
        using Variant data = result[1];
        if (status.AsInt32() != (int)Error.Ok)
            return false;
        try { message = new UTF8Encoding(false, true).GetString(data.AsByteArray()); }
        catch (DecoderFallbackException) { return false; }
        return true;
    }
}