using DeviceCenter.model;
using Newtonsoft.Json;
using RestSharp;
using RSG;
using System;
using System.Collections.Generic;
using System.Net;

namespace DeviceCenter.utils
{
    class http
    {
        private static readonly object _lock = new object();
        private static RestClient _Client;

        public static RestClient getClient()
        {
            if (null == _Client)
            {
                lock (_lock)
                {
                    if (null == _Client)
                    {
                        Config config = Config.getInstance();
                        _Client = new RestClient(config.url);
                    }
                }
            }
            return _Client;
        }

        public static Promise<T> post<T>(string url, Dictionary<string, string> data = null)
        {
            return new Promise<T>(async (resolve, reject) =>
            {
                Config config = Config.getInstance();
                RestClient client = getClient();
                client.BaseUrl = new Uri(config.url);
                var req = new RestRequest(url);
                if (!string.IsNullOrEmpty(config.token))
                {
                    req.AddHeader("Authorization", "Bearer " + config.token);
                }
                if (data != null)
                {
                    foreach (KeyValuePair<string, string> entry in data)
                    {
                        req.AddParameter(entry.Key, entry.Value);
                    }
                }
                try
                {
                    var res = await getClient().ExecutePostAsync(req);
                    if (res.StatusCode == HttpStatusCode.OK)
                    {
                        if (typeof(T) == typeof(string))
                        {
                            resolve((T)Convert.ChangeType(res.Content, typeof(T)));
                        }
                        else
                        {
                            resolve(JsonConvert.DeserializeObject<T>(res.Content));
                        }
                    }
                    else
                    {
                        var resData = JsonConvert.DeserializeObject<Dictionary<string, string>>(res.Content);
                        reject(new Exception(resData["error"]));
                    }
                }
                catch (Exception e)
                {
                    reject(e);
                }
            });
        }

        public static Promise<T> postJson<T>(string url, object body)
        {
            return new Promise<T>(async (resolve, reject) =>
            {
                Config config = Config.getInstance();
                RestClient client = getClient();
                client.BaseUrl = new Uri(config.url);
                var req = new RestRequest(url);
                req.RequestFormat = DataFormat.Json;
                if (!string.IsNullOrEmpty(config.token))
                {
                    req.AddHeader("Authorization", "Bearer " + config.token);
                }
                if (body != null)
                {
                    req.AddBody(body);
                }
                try
                {
                    var res = await getClient().ExecutePostAsync(req);
                    if (res.StatusCode == HttpStatusCode.OK)
                    {
                        if (typeof(T) == typeof(string))
                        {
                            resolve((T)Convert.ChangeType(res.Content, typeof(T)));
                        }
                        else
                        {
                            resolve(JsonConvert.DeserializeObject<T>(res.Content));
                        }
                    }
                    else
                    {
                        var resData = JsonConvert.DeserializeObject<Dictionary<string, string>>(res.Content);
                        reject(new Exception(resData["error"]));
                    }
                }
                catch (Exception e)
                {
                    reject(e);
                }
            });
        }

        public static Promise<T> upload<T>(string url, string filePath)
        {
            return new Promise<T>(async (resolve, reject) =>
            {
                Config config = Config.getInstance();
                RestClient client = getClient();
                client.BaseUrl = new Uri(config.url);
                var req = new RestRequest(url);
                if (!string.IsNullOrEmpty(config.token))
                {
                    req.AddHeader("Authorization", "Bearer " + config.token);
                }
                req.AddFile("file", filePath);
                req.AlwaysMultipartFormData = true;
                req.AddHeader("Content-Type", "multipart/form-data");
                try
                {
                    var res = await getClient().ExecutePostAsync(req);
                    if (res.StatusCode == HttpStatusCode.OK)
                    {
                        if (typeof(T) == typeof(string))
                        {
                            resolve((T)Convert.ChangeType(res.Content, typeof(T)));
                        }
                        else
                        {
                            resolve(JsonConvert.DeserializeObject<T>(res.Content));
                        }
                    }
                    else
                    {
                        var resData = JsonConvert.DeserializeObject<Dictionary<string, string>>(res.Content);
                        reject(new Exception(resData["error"]));
                    }
                }
                catch (Exception e)
                {
                    reject(e);
                }
            });
        }

        public static Promise<T> get<T>(string url, Dictionary<string, string> data = null)
        {
            return new Promise<T>(async (resolve, reject) =>
            {
                Config config = Config.getInstance();
                RestClient client = getClient();
                client.BaseUrl = new Uri(config.url);
                var req = new RestRequest(url);
                if (!string.IsNullOrEmpty(config.token))
                {
                    req.AddHeader("Authorization", "Bearer " + config.token);
                }
                if (data != null)
                {
                    foreach (KeyValuePair<string, string> entry in data)
                    {
                        if (entry.Key == "query")
                        {
                            req.AddQueryParameter(entry.Key, entry.Value, false);
                        }
                        else
                        {
                            req.AddQueryParameter(entry.Key, entry.Value, true);
                        }
                    }
                }
                try
                {
                    var res = await getClient().ExecuteGetAsync(req);
                    if (res.StatusCode == HttpStatusCode.OK)
                    {
                        if (typeof(T) == typeof(string))
                        {
                            resolve((T)Convert.ChangeType(res.Content, typeof(T)));
                        }
                        else
                        {
                            resolve(JsonConvert.DeserializeObject<T>(res.Content));
                        }
                    }
                    else
                    {
                        var resData = JsonConvert.DeserializeObject<Dictionary<string, string>>(res.Content);
                        reject(new Exception(resData["error"]));
                    }
                }
                catch (Exception e)
                {
                    reject(e);
                }
            });
        }
    }
}