using System;
using System.Collections.Generic;
using System.IO;
using System.Runtime.Serialization;
using System.Runtime.Serialization.Json;
using System.Text;
using System.Threading.Tasks;
using MassTransit;
using MassTransit.Turnout;
using Messages;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

namespace Consumers
{
  public class OtherIssuerAddConsumer : IConsumer<JObject>
    {
        public Task Consume(ConsumeContext<JObject> context)
        {
            Console.WriteLine(context);
            var ser = new DataContractJsonSerializer(typeof(KnownCommandType),
                new DataContractJsonSerializerSettings
                {
                    SerializeReadOnlyTypes = true,
                    MaxItemsInObjectGraph = 256,
                    DateTimeFormat = new DateTimeFormat("yyyy-MM-dd'T'HH:mm:ss.FFFFFFFZ")
                });

            var msg = (JObject)JsonConvert.DeserializeObject(context.Message.ToString());

            JToken messageToken;
            JObject message;

            var hasContent = msg.TryGetValue("Content", StringComparison.CurrentCultureIgnoreCase, out messageToken);

            if (hasContent)
            {
                var target = ser.ReadObject(
                    new MemoryStream(Encoding.UTF8.GetBytes(JObject.Parse(messageToken.ToString()).ToString())));
            }

            return Task.CompletedTask;
        }
    }
}