using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using EleWise.ELMA.ComponentModel;
using EleWise.ELMA.Services;
using RabbitMQ.Client.Events;
using Yambr.ELMA.MessageQueueRMQ.ExtensionPoints;

namespace Yambr.ELMA.MessageQueueRMQ.Components
{
    [Component(Order = 0)]
    public class GetModelFromMessageHandler : IModelMessageHandler
    {
        public string GetModelFromMessage(string jsonObject, BasicDeliverEventArgs eventArgs)
        {
            if (eventArgs == null) return null; //throw new ArgumentNullException(nameof(eventArgs));
            var settings = Locator.GetServiceNotNull<MessageQueueRMQSettingsModule>().Settings;

            if (eventArgs.BasicProperties.Headers == null || !eventArgs.BasicProperties.Headers.ContainsKey(settings.ModelHeaderKey))
                return null;

            var header = eventArgs.BasicProperties.Headers[settings.ModelHeaderKey] as byte[];
            if (header == null || header.Length == 0)
                return null;

            return Encoding.UTF8.GetString(header);
        }
    }
}