using Mogafa.Common;
using Mogafa.Common.HttpClients;
using Mogafa.Common.Ioc;
using Mogafa.Unity.Common.Networks;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace DidabuCloud.Unity.Core.NetWorking
{
    public class HttpUtility : MogafaBase
    {
        private static IHttpClient httpClient;
        private static IHttpClient defaultHttpClient = new UnityWebRequestHttpClient("", new List<IHttpRequestHandler>(), new HttpRequestOptions());
        private static List<IHttpRequestHandler> httpRequestHandlers = new List<IHttpRequestHandler>();

        protected static IHttpClient HttpClient
        {
            get
            {
                if (httpClient != null)
                {
                    return httpClient;
                }
                if (!IocContainer.TryResolve<IHttpClient>(out httpClient))
                {
                    return defaultHttpClient;
                }
                foreach (IHttpRequestHandler handler in httpRequestHandlers)
                {
                    httpClient.AddHttpRequestHandler(handler);
                }
                return httpClient;
            }
        }
        public static void SetHeaders(Dictionary<string, string> headers)
        {

        }
        public static void AddHttpRequestHandler(IHttpRequestHandler httpRequestHandler)
        {
            if (httpRequestHandler == null)
            {
                return;
            }
            if (httpRequestHandlers.FirstOrDefault(h => h.Name == httpRequestHandler.Name) != null)
            {
                return;
            }
            httpRequestHandlers.Add(httpRequestHandler);
            HttpClient.AddHttpRequestHandler(httpRequestHandler);
        }
        private static DidabuHttpResponse<T> GetResponse<T>(HttpOriginalResponse<DidabuHttpResponse<T>> originalResponse)
            where T : new()
        {
            if (originalResponse.StatusCode == HttpStatusCodes.OK)
            {
                originalResponse.Body.Code = HttpStatusCodes.OK;
                return originalResponse.Body;
            }
            if (originalResponse.Body == null)
            {
                originalResponse.Body = new DidabuHttpResponse<T>();
            }
            originalResponse.Body.Code = originalResponse.StatusCode;
            originalResponse.Body.IsSuccessful = false;
            originalResponse.Body.Message = originalResponse.StatusMessage;
            return originalResponse.Body;
        }
        public async static Task<DidabuHttpResponse<T>> Get<T>(string url, Dictionary<string, string> headers = null)
            where T : new()
        {
            var finalHeaders = headers;
            if (finalHeaders == null)
            {
                finalHeaders = new Dictionary<string, string>();
            }
            var originalResponse = new HttpOriginalResponse<DidabuHttpResponse<T>>()
            {
                StatusCode = -1
            };
            try
            {
                originalResponse = await HttpClient.Get<DidabuHttpResponse<T>>(url, finalHeaders);
            }
            catch (Exception ex)
            {
                originalResponse.StatusMessage = ex.Message;
            }
            return GetResponse<T>(originalResponse);
        }
        public async static Task<DidabuHttpResponse<T>> Delete<T>(string url, Dictionary<string, string> headers = null)
            where T : new()
        {
            var finalHeaders = headers;
            if (finalHeaders == null)
            {
                finalHeaders = new Dictionary<string, string>();
            }
            var originalResponse = new HttpOriginalResponse<DidabuHttpResponse<T>>()
            {
                StatusCode = -1
            };
            try
            {
                originalResponse = await HttpClient.Delete<DidabuHttpResponse<T>>(url, finalHeaders);
            }
            catch (Exception ex)
            {
                originalResponse.StatusMessage = ex.Message;
            }
            return GetResponse<T>(originalResponse);
        }
        //public async static Task<DidabuHttpResponse<T>> Put<T>(string url, Dictionary<string, string> headers = null)
        //{
        //    var finalHeaders = headers;
        //    if (finalHeaders == null)
        //    {
        //        finalHeaders = new Dictionary<string, string>();
        //    }
        //    var originalResponse = await HttpClient.<DidabuHttpResponse<T>>(url, finalHeaders);
        //    return GetResponse<T>(originalResponse);
        //}

        public async static Task<DidabuHttpResponse<T>> Post<T>(string url, string data, Dictionary<string, string> headers = null)
            where T : new()
        {
            var finalHeaders = headers;
            if (finalHeaders == null)
            {
                finalHeaders = new Dictionary<string, string>();
            }
            var originalResponse = new HttpOriginalResponse<DidabuHttpResponse<T>>()
            {
                StatusCode = -1
            };
            try
            {
                originalResponse = await HttpClient.Post<DidabuHttpResponse<T>>(url, data, finalHeaders);
            }
            catch (Exception ex)
            {
                originalResponse.StatusMessage = ex.Message;
            }
            return GetResponse<T>(originalResponse);
        }
    }
}