Serializer.cs

using System;
using System.Collections.Generic;
using System.IO;
using System.Text;
 
namespace Waher.Networking.Cluster.Serialization
{
    public class Serializer : IDisposable
    {
        private MemoryStream ms;
 
        public Serializer()
        {
            this.ms = new MemoryStream();
        }
 
        public void Dispose()
        {
            this.ms?.Dispose();
            this.ms = null;
        }
 
        public byte[] ToArray()
        {
            return this.ms.ToArray();
        }
 
        public void WriteBoolean(bool Value)
        {
            this.ms.WriteByte(Value ? (byte)1 : (byte)0);
        }
 
        public void WriteByte(byte Value)
        {
            this.ms.WriteByte(Value);
        }
 
        public void WriteVarUInt64(ulong Value)
        {
            byte b;
 
            do
            {
                b = (byte)(Value & 0x7f);
                Value >>= 7;
                if (Value != 0)
                    b |= 0x80;
 
                this.ms.WriteByte(b);
            }
            while (Value != 0);
        }
 
        public void WriteBinary(byte[] Value)
        {
            if (Value is null)
                this.ms.WriteByte(0);
            else
            {
                this.WriteVarUInt64((ulong)Value.Length + 1);
                this.ms.Write(Value, 0, Value.Length);
            }
        }
 
        public void WriteRaw(byte[] Binary)
        {
            this.ms.Write(Binary, 0, Binary.Length);
        }
 
        public void WriteRaw(byte[] Binary, int Offset, int Count)
        {
            this.ms.Write(Binary, Offset, Count);
        }
 
        public void WriteString(string Value)
        {
            if (Value is null)
                this.ms.WriteByte(0);
            else if (string.IsNullOrEmpty(Value))
                this.ms.WriteByte(1);
            else
            {
                byte[] Bin = Encoding.UTF8.GetBytes(Value);
 
                this.WriteVarUInt64((ulong)Bin.Length + 1);
                this.ms.Write(Bin, 0, Bin.Length);
            }
        }
 
        public void WriteInt8(sbyte Value)
        {
            this.ms.WriteByte((byte)Value);
        }
 
        public void WriteInt16(short Value)
        {
            this.ms.WriteByte((byte)Value);
            Value >>= 8;
            this.ms.WriteByte((byte)Value);
        }
 
        public void WriteInt32(int Value)
        {
            byte[] Bin = new byte[4];
            int i;
 
            for (i = 0; i < 4; i++)
            {
                Bin[i] = (byte)Value;
                Value >>= 8;
            }
 
            this.ms.Write(Bin, 0, 4);
        }
 
        public void WriteInt64(long Value)
        {
            byte[] Bin = new byte[8];
            int i;
 
            for (i = 0; i < 8; i++)
            {
                Bin[i] = (byte)Value;
                Value >>= 8;
            }
 
            this.ms.Write(Bin, 0, 8);
        }
 
        public void WriteUInt8(byte Value)
        {
            this.ms.WriteByte(Value);
        }
 
        public void WriteUInt16(ushort Value)
        {
            this.ms.WriteByte((byte)Value);
            Value >>= 8;
            this.ms.WriteByte((byte)Value);
        }
 
        public void WriteUInt32(uint Value)
        {
            byte[] Bin = new byte[4];
            int i;
 
            for (i = 0; i < 4; i++)
            {
                Bin[i] = (byte)Value;
                Value >>= 8;
            }
 
            this.ms.Write(Bin, 0, 4);
        }
 
        public void WriteUInt64(ulong Value)
        {
            byte[] Bin = new byte[8];
            int i;
 
            for (i = 0; i < 8; i++)
            {
                Bin[i] = (byte)Value;
                Value >>= 8;
            }
 
            this.ms.Write(Bin, 0, 8);
        }
 
        public void WriteSingle(float Value)
        {
            byte[] Bin = BitConverter.GetBytes(Value);
            this.ms.Write(Bin, 0, Bin.Length);
        }
 
        public void WriteDouble(double Value)
        {
            byte[] Bin = BitConverter.GetBytes(Value);
            this.ms.Write(Bin, 0, Bin.Length);
        }
 
        public void WriteDecimal(decimal Value)
        {
            int[] A = decimal.GetBits(Value);
            int i;
 
            for (i = 0; i < 4; i++)
                this.WriteInt32(A[i]);
        }
 
        public void WriteCharacter(char Value)
        {
            this.WriteUInt16(Value);
        }
 
        public void WriteDateTime(DateTime Value)
        {
            this.WriteInt64(Value.Ticks);
            this.ms.WriteByte((byte)Value.Kind);
        }
 
        public void WriteTimeSpan(TimeSpan Value)
        {
            this.WriteInt64(Value.Ticks);
        }
 
        public void WriteDateTimeOffset(DateTimeOffset Value)
        {
            this.WriteDateTime(Value.DateTime);
            this.WriteTimeSpan(Value.Offset);
        }
 
        public void WriteGuid(Guid Value)
        {
            byte[] Bin = Value.ToByteArray();
            this.ms.Write(Bin, 0, Bin.Length);
        }
    }
}