using Newtonsoft.Json;
using SpotifyAPI.Local.Models;
using System;
using System.Collections.Generic;
using System.Net;
using System.Text;
using System.Threading.Tasks;

namespace SpotifyAPI.Local
{
    internal class RemoteHandler
    {
        public String OauthKey { get; private set; }
        public String CfidKey { get; private set; }

        public const String Host = "SpotifyAPI.spotilocal.com";

        internal Boolean Init()
        {
            OauthKey = GetOAuthKey();
            CfidKey = GetCfid();
            return !String.IsNullOrEmpty(CfidKey);
        }

        internal async void SendPauseRequest()
        {
            await QueryAsync("remote/pause.json?pause=true", true, true, -1);
        }

        internal async void SendPlayRequest()
        {
            await QueryAsync("remote/pause.json?pause=false", true, true, -1);
        }

        internal async void SendPlayRequest(String url, String context = "")
        {
            // TODO: instead of having an empty context, one way to fix the bug with the playback time beyond the length of a song would be to provide a 1-song context, and it would be fixed.
            await QueryAsync($"remote/play.json?uri={url}&context={context}", true, true, -1);
        }

        internal async void SendQueueRequest(String url)
        {
            await QueryAsync("remote/play.json?uri=" + url + "?action=queue", true, true, -1);
        }

        internal StatusResponse GetNewStatus()
        {
            String response = Query("remote/status.json", true, true, -1);
            if (String.IsNullOrEmpty(response))
            {
                return null;
            }
            response = response.Replace("\\n", "");
            byte[] bytes = Encoding.Default.GetBytes(response);
            response = Encoding.UTF8.GetString(bytes);
            List<StatusResponse> raw = JsonConvert.DeserializeObject<List<StatusResponse>>(response);
            return raw[0];
        }

        internal String GetOAuthKey()
        {
            String raw;
            using (WebClient wc = new WebClient())
            {
                raw = wc.DownloadString("http://open.spotify.com/token");
            }
            Dictionary<String, object> dic = JsonConvert.DeserializeObject<Dictionary<String, object>>(raw);
            return dic == null ? "" : (String)dic["t"];
        }

        internal string GetCfid()
        {
            string response = Query("simplecsrf/token.json", false, false, -1);
            response = response.Replace(@"\", "");
            List<Cfid> cfidList = (List<Cfid>)JsonConvert.DeserializeObject(response, typeof(List<Cfid>));
            if (cfidList == null)
                return "";
            if (cfidList.Count != 1)
                throw new Exception("CFID could not be loaded");
            return cfidList[0].Error == null ? cfidList[0].Token : "";
        }

        internal string Query(string request, bool oauth, bool cfid, int wait)
        {
            string parameters = "?&ref=&cors=&_=" + GetTimestamp();
            if (request.Contains("?"))
            {
                parameters = parameters.Substring(1);
            }

            if (oauth)
            {
                parameters += "&oauth=" + OauthKey;
            }
            if (cfid)
            {
                parameters += "&csrf=" + CfidKey;
            }

            if (wait != -1)
            {
                parameters += "&returnafter=" + wait;
                parameters += "&returnon=login%2Clogout%2Cplay%2Cpause%2Cerror%2Cap";
            }

            string address = "http://" + Host + ":4380/" + request + parameters;
            string response = "";
            try
            {
                using (var wc = new ExtendedWebClient())
                {
                    if (SpotifyLocalAPI.IsSpotifyRunning())
                        response = "[ " + wc.DownloadString(address) + " ]";
                }
            }
            catch
            {
                return String.Empty;
            }

            return response;
        }

        internal async Task<string> QueryAsync(string request, bool oauth, bool cfid, int wait)
        {
            string parameters = "?&ref=&cors=&_=" + GetTimestamp();
            if (request.Contains("?"))
            {
                parameters = parameters.Substring(1);
            }

            if (oauth)
            {
                parameters += "&oauth=" + OauthKey;
            }
            if (cfid)
            {
                parameters += "&csrf=" + CfidKey;
            }

            if (wait != -1)
            {
                parameters += "&returnafter=" + wait;
                parameters += "&returnon=login%2Clogout%2Cplay%2Cpause%2Cerror%2Cap";
            }

            string address = "http://" + Host + ":4380/" + request + parameters;
            string response = "";
            try
            {
                using (var wc = new ExtendedWebClient())
                {
                    if (SpotifyLocalAPI.IsSpotifyRunning())
                        response = "[ " + await wc.DownloadStringTaskAsync(new Uri(address)) + " ]";
                }
            }
            catch
            {
                return String.Empty;
            }

            return response;
        }

        internal int GetTimestamp()
        {
            return Convert.ToInt32((DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0)).TotalSeconds);
        }
    }
}