using System;
using System.Text;
using System.Threading.Tasks;
using Newtonsoft.Json;
using UnityEngine.Networking;
using Unity.Services.Core.Internal;
using Unity.Services.Core.Scheduler.Internal;
using NotNull = JetBrains.Annotations.NotNullAttribute;

namespace Unity.Services.Core.Telemetry.Internal
{
    class TelemetrySender
    {
        public string TargetUrl { get; }

        readonly ExponentialBackOffRetryPolicy m_RetryPolicy;

        readonly IActionScheduler m_Scheduler;

        readonly IUnityWebRequestSender m_RequestSender;

        public TelemetrySender(
            [NotNull] string targetUrl, [NotNull] string servicePath,
            [NotNull] IActionScheduler scheduler, [NotNull] ExponentialBackOffRetryPolicy retryPolicy,
            [NotNull] IUnityWebRequestSender requestSender)
        {
            TargetUrl = $"{targetUrl}/{servicePath}";
            m_RetryPolicy = retryPolicy;
            m_Scheduler = scheduler;
            m_RequestSender = requestSender;
        }

        public Task SendAsync<TPayload>(TPayload payload)
            where TPayload : ITelemetryPayload
        {
            var completionSource = new TaskCompletionSource<object>();
            var sendCount = 0;
            byte[] serializedPayload;

            try
            {
                serializedPayload = SerializePayload(payload);
                SendWebRequest();
            }
            catch (Exception e)
            {
                completionSource.TrySetException(e);
            }

            return completionSource.Task;

            void SendWebRequest()
            {
                var request = CreateRequest(serializedPayload);

                sendCount++;
                CoreLogger.LogVerbose($"Attempt #{sendCount.ToString()} to send {typeof(TPayload).Name}.");

                m_RequestSender.SendRequest(request, OnRequestCompleted);
            }

            void OnRequestCompleted(WebRequest webRequest)
            {
                if (webRequest.IsSuccess)
                {
                    CoreLogger.LogVerbose($"{typeof(TPayload).Name} sent successfully");
                    completionSource.SetResult(null);
                }
                else if (m_RetryPolicy.CanRetry(webRequest, sendCount))
                {
                    var delayBeforeSendingSeconds = m_RetryPolicy.GetDelayBeforeSendingSeconds(sendCount);
                    m_Scheduler.ScheduleAction(SendWebRequest, delayBeforeSendingSeconds);
                }
                else
                {
                    var errorMessage = $"Error: {webRequest.ErrorMessage}\nBody: {webRequest.ErrorBody}";
                    completionSource.TrySetException(new Exception(errorMessage));
                    CoreLogger.LogVerbose($"{typeof(TPayload).Name} couldn't be sent after {sendCount.ToString()} tries.\n{errorMessage}");
                }
            }
        }

        internal static byte[] SerializePayload<TPayload>(TPayload payload)
            where TPayload : ITelemetryPayload
        {
            var jsonPayload = JsonConvert.SerializeObject(payload);
            var serializedPayload = Encoding.UTF8.GetBytes(jsonPayload);
            return serializedPayload;
        }

        internal UnityWebRequest CreateRequest(byte[] serializedPayload)
        {
            var request = new UnityWebRequest(TargetUrl, UnityWebRequest.kHttpVerbPOST)
            {
                uploadHandler = new UploadHandlerRaw(serializedPayload)
                {
                    contentType = UnityWebRequestUtils.JsonContentType,
                },
                downloadHandler = new DownloadHandlerBuffer()
            };
            request.SetRequestHeader("Content-Type", UnityWebRequestUtils.JsonContentType);
            return request;
        }
    }
}
