using System;
using ServiceStack.Messaging;
using ServiceStack.ServiceHost;

namespace ServiceStack.ServiceInterface
{
	/// <summary>
	/// Useful base functionality for IAsyncServices by serializing the request
	/// into the message queue configured by the AppHost if one is configured. 
	/// 
	/// This allows the request to persist for longer than the request duration 
	/// and can defer the execution of the async request under optimal execution.
	/// 
	/// If one is not configured it will Execute the request immediately as per normal.
	/// </summary>
	/// <typeparam name="TRequest"></typeparam>
	public abstract class AsyncServiceBase<TRequest> 
		: ServiceBase<TRequest>, IAsyncService<TRequest>
	{
		/// <summary>
		/// Injected by the ServiceStack IOC with the registered dependency in the Funq IOC container.
		/// </summary>
		public IMessageFactory MessageFactory { get; set; }

		/// <summary>
		/// Persists the request into the registered message queue if configured, 
		/// otherwise calls Execute() to handle the request immediately.
		/// </summary>
		/// <param name="request"></param>
		public virtual object ExecuteAsync(TRequest request)
		{
			if (MessageFactory == null)
			{
				return Execute(request);
			}

			//Capture and persist this async request on this Services 'In Queue' 
			//for execution after this request has been completed
			using (var producer = MessageFactory.CreateMessageProducer())
			{
				producer.Publish(request);
			}

			return CreateResponseDto(request);
		}

		/// <summary>
		/// The Deferred execution of ExecuteAsync(request)'s. 
		/// This request is typically invoked from a messaging queue service host.
		/// </summary>
		/// <param name="request"></param>
		public virtual object ExecuteAsync(IMessage<TRequest> request)
		{
			return Run(request.GetBody());
		}

	}


}