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

namespace Tango.Transport
{
    /// <summary>
    /// Represents a base transport message.
    /// </summary>
    internal abstract class TransportMessageBase : ExtendedObject
    {
        /// <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>
        /// 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);

        /// <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;
        }
    }
}