using System;
using System.Collections.Generic;
using System.Linq;
using System.Reactive.Subjects;
using System.Text;
using System.Threading.Tasks;
using Tango.Core;
using Tango.PMR;
using Tango.PMR.Common;
using Tango.PMR.Integration;

namespace Tango.Transport
{
    /// <summary>
    /// Represents a base transport message.
    /// </summary>
    internal abstract class TransportMessageBase : ExtendedObject
    {
        public bool AtLeastOneResponseReceived { get; set; }

        public String TransportComponentName { get; set; }

        public QueuePriority Priority { get; set; }

        public TransportThreadingMode ThreadingMode { get; set; }

        /// <summary>
        /// Gets or sets a value indicating whether this instance is multi response.
        /// </summary>
        public bool IsContinuous { get; set; }

        /// <summary>
        /// Gets or sets the message token.
        /// </summary>
        public String Token { get; set; }

        /// <summary>
        /// Gets or sets the message direction.
        /// </summary>
        public TransportMessageDirection Direction { get; set; }

        /// <summary>
        /// Gets or sets method to serial the message to byte array.
        /// </summary>
        public Func<byte[]> Serialize { get; set; }

        /// <summary>
        /// Gets or sets the activate timeout callback.
        /// </summary>
        public Action ActivateTimeout { get; set; }

        /// <summary>
        /// Gets or sets the message.
        /// </summary>
        public Object Message { get; set; }

        /// <summary>
        /// Gets or sets a value indicating whether log the message before sending.
        /// </summary>
        public bool ShouldLog { get; set; }

        public bool Immidiate { get; set; }

        /// <summary>
        /// Notifies the message observer of the new result.
        /// </summary>
        /// <param name="result">The result.</param>
        public abstract void SetResult(object result, bool completed);

        /// <summary>
        /// Notifies the message observer of an exception.
        /// </summary>
        /// <param name="ex">The ex.</param>
        public abstract void SetException(Exception ex);

        public abstract String GetActualMessageTypeName();

        public abstract Object GetActualMessage();

        /// <summary>
        /// Initializes a new instance of the <see cref="TransportMessageBase"/> class.
        /// </summary>
        /// <param name="token">The token.</param>
        /// <param name="message">The message.</param>
        /// <param name="direction">The direction.</param>
        /// <param name="toBytes">To bytes.</param>
        public TransportMessageBase(String token, object message, TransportMessageDirection direction, Func<byte[]> toBytes)
        {
            Token = token;
            Message = message;
            Direction = direction;
            Serialize = toBytes;
        }

        public static String GetActualMessageTypeName(Object obj)
        {
            String name = String.Empty;

            if (obj is ITangoMessage)
            {
                var message = obj.GetType().GetProperty("Message").GetValue(obj);

                if (message.GetType() == typeof(GenericRequest))
                {
                    try
                    {
                        name = (message as GenericRequest).GetTypeName();
                    }
                    catch
                    {
                        name = message.GetType().Name;
                    }
                }
                else if (message.GetType() == typeof(GenericResponse))
                {
                    try
                    {
                        name = (message as GenericResponse).GetTypeName();
                    }
                    catch
                    {
                        name = message.GetType().Name;
                    }
                }
                else
                {
                    name = message.GetType().Name;
                }
            }
            else if (obj is MessageContainer)
            {
                name = (obj as MessageContainer).Type.ToString();
            }
            else
            {
                name = obj.GetType().Name;
            }

            return name;
        }
    }
}