using System;
using MessagePack;

namespace Christie_net.datagear.dg {
public class MessagePackDataGear<T> : DataGear<T> {
    private int dataSize;
    private byte[] messagePack;
    private readonly object syncObject = new object();

    public MessagePackDataGear(T data) : base(data) {
        GetMessagePack();
    }

    public MessagePackDataGear(Type clazz) : base(clazz) { }

    public MessagePackDataGear(byte[] messagePack, Type clazz) : base(clazz) {
        this.messagePack = messagePack;
    }

    public byte[] GetMessagePack() {
        if (messagePack != null)
            return messagePack;
        try {
            // Debug
            Console.WriteLine("data:" + data.GetType());
            messagePack = MessagePackSerializer.Serialize(data);
           
            SetDataSize(messagePack.Length);
        } catch (Exception e) {
            Console.WriteLine("\n" + e.ToString());
        }

        return messagePack;
    }

    public override T GetData() {
        lock (syncObject) {
            if (data == null)
                try {
                    var dataObj = MessagePackSerializer.Deserialize<T>(messagePack);
                    ///var dataCast = Convert.ChangeType(dataObj, clazz);
                    SetData(dataObj);
                } catch (Exception e) {
                    Console.WriteLine(e.StackTrace);
                } 

            return base.GetData();
        }
    }

    public void SetDataSize(int dataSize) {
        this.dataSize = dataSize;
    }
}
}