ObjectInfo.cs

using System;
using System.Collections.Generic;
using Waher.Networking.Cluster.Serialization.Properties;
using Waher.Runtime.Inventory;
 
namespace Waher.Networking.Cluster.Serialization
{
    internal class ObjectInfo
    {
        private Dictionary<string, PropertyReference> sorted = null;
        public PropertyReference[] Properties;
        public Type Type;
 
        public void Serialize(Serializer Output, object Object)
        {
            if (Object is null)
                Output.WriteByte(0);
            else
            {
                Type T = Object.GetType();
                ObjectInfo Info = this;
 
                if (T == this.Type)
                    Output.WriteString(string.Empty);
                else
                {
                    Output.WriteString(T.FullName);
 
                    IProperty P = ClusterEndpoint.GetProperty(T);
                    if (P is ObjectProperty _)
                        Info = ClusterEndpoint.GetObjectInfo(T);
                    else
                    {
                        P.Serialize(Output, Object);
                        return;
                    }
                }
 
                foreach (PropertyReference Property in Info.Properties)
                {
                    Output.WriteString(Property.Name);
                    object Value = Property.Info.GetValue(Object);
                    Property.Property.Serialize(Output, Value);
                }
 
                Output.WriteByte(0);
            }
        }
 
        public object Deserialize(Deserializer Input, Type ExpectedType)
        {
            string TypeName = Input.ReadString();
            ObjectInfo Info;
 
            if (TypeName is null)
                return null;
            else if (string.IsNullOrEmpty(TypeName))
                Info = this;
            else
            {
                Type T = Types.GetType(TypeName);
                if (T is null)
                    throw new KeyNotFoundException("Type name not recognized: " + TypeName);
 
                IProperty P = ClusterEndpoint.GetProperty(T);
                if (P is ObjectProperty _)
                    Info = ClusterEndpoint.GetObjectInfo(T);
                else
                    return P.Deserialize(Input, T);
            }
 
            if (Info.sorted is null)
            {
                Dictionary<string, PropertyReference> Sorted = new Dictionary<string, PropertyReference>();
 
                foreach (PropertyReference P in Info.Properties)
                    Sorted[P.Name] = P;
 
                Info.sorted = Sorted;
            }
 
            object Result = Activator.CreateInstance(Info.Type);
            string PropertyName = Input.ReadString();
 
            while (!string.IsNullOrEmpty(PropertyName))
            {
                if (!Info.sorted.TryGetValue(PropertyName, out PropertyReference P))
                    throw new KeyNotFoundException("Property Name not found: " + Info.Type.FullName + "." + PropertyName);
 
                P.Info.SetValue(Result, P.Property.Deserialize(Input, P.Property.PropertyType));
 
                PropertyName = Input.ReadString();
            }
 
            return Result;
        }
 
    }
}