Deserializer.cs

using System;
using System.IO;
using System.Text;
using Waher.Runtime.IO;
 
namespace Waher.Networking.Cluster.Serialization
{
    public class Deserializer : IDisposable
    {
        private MemoryStream ms;
 
        public Deserializer(byte[] Data)
        {
            this.ms = new MemoryStream(Data);
        }
 
        public void Dispose()
        {
            this.ms?.Dispose();
            this.ms = null;
        }
 
        public bool ReadBoolean()
        {
            return this.ms.ReadByte() != 0;
        }
 
        public byte ReadByte()
        {
            return (byte)this.ms.ReadByte();
        }
 
        public ulong ReadVarUInt64()
        {
            ulong Value = 0;
            int Offset = 0;
            byte b;
 
            do
            {
                b = (byte)this.ms.ReadByte();
                Value |= ((ulong)(b & 0x7f)) << Offset;
                Offset += 7;
            }
            while ((b & 0x80) != 0);
 
            return Value;
        }
 
        public byte[] ReadBinary()
        {
            ulong Len = this.ReadVarUInt64();
 
            if (Len == 0)
                return null;
 
            Len--;
            if (Len > int.MaxValue)
                throw new Exception("Invalid binary serialization.");
 
            int c = (int)Len;
            byte[] Bin = new byte[c];
            this.ms.ReadAll(Bin, 0, c);
 
            return Bin;
        }
 
        public string ReadString()
        {
            ulong Len = this.ReadVarUInt64();
 
            switch (Len)
            {
                case 0:
                    return null;
 
                case 1:
                    return string.Empty;
 
                default:
                    Len--;
                    if (Len > int.MaxValue)
                        throw new Exception("Invalid string serialization.");
 
                    int c = (int)Len;
                    byte[] Bin = new byte[c];
                    this.ms.ReadAll(Bin, 0, c);
                    return Encoding.UTF8.GetString(Bin);
            }
        }
 
        public sbyte ReadInt8()
        {
            return (sbyte)this.ms.ReadByte();
        }
 
        public short ReadInt16()
        {
            short Value = (short)this.ms.ReadByte();
            Value |= (short)(this.ms.ReadByte() << 8);
 
            return Value;
        }
 
        public int ReadInt32()
        {
            int Value = this.ReadUInt16();
            Value |= this.ReadInt16() << 16;
 
            return Value;
        }
 
        public long ReadInt64()
        {
            long Value = this.ReadUInt32();
            Value |= ((long)this.ReadInt32()) << 32;
 
            return Value;
        }
 
        public byte ReadUInt8()
        {
            return (byte)this.ms.ReadByte();
        }
 
        public ushort ReadUInt16()
        {
            ushort Value = (ushort)this.ms.ReadByte();
            Value |= (ushort)(this.ms.ReadByte() << 8);
 
            return Value;
        }
 
        public uint ReadUInt32()
        {
            uint Value = this.ReadUInt16();
            Value |= (uint)(this.ReadUInt16() << 16);
 
            return Value;
        }
 
        public ulong ReadUInt64()
        {
            ulong Value = this.ReadUInt32();
            Value |= ((ulong)this.ReadUInt32()) << 32;
 
            return Value;
        }
 
        public float ReadSingle()
        {
            byte[] Bin = new byte[4];
            this.ms.ReadAll(Bin, 0, 4);
            return BitConverter.ToSingle(Bin, 0);
        }
 
        public double ReadDouble()
        {
            byte[] Bin = new byte[8];
            this.ms.ReadAll(Bin, 0, 8);
            return BitConverter.ToDouble(Bin, 0);
        }
 
        public decimal ReadDecimal()
        {
            int[] A = new int[4];
            int i;
 
            for (i = 0; i < 4; i++)
                A[i] = this.ReadInt32();
 
            return new decimal(A);
        }
 
        public char ReadCharacter()
        {
            return (char)this.ReadUInt16();
        }
 
        public DateTime ReadDateTime()
        {
            long Ticks = this.ReadInt64();
            DateTimeKind Kind = (DateTimeKind)this.ms.ReadByte();
 
            return new DateTime(Ticks, Kind);
        }
 
        public TimeSpan ReadTimeSpan()
        {
            long Ticks = this.ReadInt64();
            return new TimeSpan(Ticks);
        }
 
        public DateTimeOffset ReadDateTimeOffset()
        {
            DateTime TP = this.ReadDateTime();
            TimeSpan Offset = this.ReadTimeSpan();
 
            return new DateTimeOffset(TP, Offset);
        }
 
        public Guid ReadGuid()
        {
            byte[] Bin = new byte[16];
            this.ms.ReadAll(Bin, 0, 16);
            return new Guid(Bin);
        }
    }
}