/*
 * Copyright 2016 Game Server Services, Inc. or its affiliates. All Rights
 * Reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License").
 * You may not use this file except in compliance with the License.
 * A copy of the License is located at
 *
 *  http://www.apache.org/licenses/LICENSE-2.0
 *
 * or in the "license" file accompanying this file. This file is distributed
 * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
 * express or implied. See the License for the specific language governing
 * permissions and limitations under the License.
 */

#pragma warning disable CS0618 // Obsolete with a message

using System;
using System.Collections.Generic;
using System.Text;
using System.Linq;
using Gs2.Core;
using Gs2.Core.Model;
using Gs2.Core.Net;
using Gs2.Util.LitJson;

#if UNITY_2017_1_OR_NEWER
using System.Collections;
using UnityEngine.Events;
using UnityEngine.Networking;
    #if GS2_ENABLE_UNITASK
using Cysharp.Threading.Tasks;
    #endif
#else
using System.Threading.Tasks;
using System.Threading;
#endif

namespace Gs2.Gs2Deploy
{
	public class Gs2DeployWebSocketClient : AbstractGs2Client
	{

		public static string Endpoint = "deploy";

        protected Gs2WebSocketSession Gs2WebSocketSession => (Gs2WebSocketSession) Gs2Session;

		public Gs2DeployWebSocketClient(Gs2WebSocketSession Gs2WebSocketSession) : base(Gs2WebSocketSession)
		{

		}


        public class PreCreateStackTask : Gs2WebSocketSessionTask<Request.PreCreateStackRequest, Result.PreCreateStackResult>
        {
	        public PreCreateStackTask(IGs2Session session, Request.PreCreateStackRequest request) : base(session, request)
	        {
	        }

            protected override IGs2SessionRequest CreateRequest(Request.PreCreateStackRequest request)
            {
                var stringBuilder = new StringBuilder();
                var jsonWriter = new JsonWriter(stringBuilder);

                jsonWriter.WriteObjectStart();

                if (request.ContextStack != null)
                {
                    jsonWriter.WritePropertyName("contextStack");
                    jsonWriter.Write(request.ContextStack.ToString());
                }
                if (request.DryRun)
                {
                    jsonWriter.WritePropertyName("xGs2DryRun");
                    jsonWriter.Write("true");
                }

                AddHeader(
                    Session.Credential,
                    "deploy",
                    "stack",
                    "preCreateStack",
                    jsonWriter
                );

                jsonWriter.WriteObjectEnd();

                return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
            }
        }

#if UNITY_2017_1_OR_NEWER
		public IEnumerator PreCreateStack(
                Request.PreCreateStackRequest request,
                UnityAction<AsyncResult<Result.PreCreateStackResult>> callback
        )
		{
			var task = new PreCreateStackTask(
			    Gs2WebSocketSession,
			    request
            );
            yield return task;
            callback.Invoke(new AsyncResult<Result.PreCreateStackResult>(task.Result, task.Error));
        }

		public IFuture<Result.PreCreateStackResult> PreCreateStackFuture(
                Request.PreCreateStackRequest request
        )
		{
			return new PreCreateStackTask(
			    Gs2WebSocketSession,
			    request
			);
        }

    #if GS2_ENABLE_UNITASK
		public async UniTask<Result.PreCreateStackResult> PreCreateStackAsync(
            Request.PreCreateStackRequest request
        )
		{
		    var task = new PreCreateStackTask(
		        Gs2WebSocketSession,
		        request
            );
			return await task.Invoke();
        }
    #else
		public PreCreateStackTask PreCreateStackAsync(
                Request.PreCreateStackRequest request
        )
		{
			return new PreCreateStackTask(
                Gs2WebSocketSession,
			    request
            );
        }
    #endif
#else
		public async Task<Result.PreCreateStackResult> PreCreateStackAsync(
            Request.PreCreateStackRequest request
        )
		{
		    var task = new PreCreateStackTask(
		        Gs2WebSocketSession,
		        request
            );
			return await task.Invoke();
        }
#endif


        public class PreValidateTask : Gs2WebSocketSessionTask<Request.PreValidateRequest, Result.PreValidateResult>
        {
	        public PreValidateTask(IGs2Session session, Request.PreValidateRequest request) : base(session, request)
	        {
	        }

            protected override IGs2SessionRequest CreateRequest(Request.PreValidateRequest request)
            {
                var stringBuilder = new StringBuilder();
                var jsonWriter = new JsonWriter(stringBuilder);

                jsonWriter.WriteObjectStart();

                if (request.ContextStack != null)
                {
                    jsonWriter.WritePropertyName("contextStack");
                    jsonWriter.Write(request.ContextStack.ToString());
                }
                if (request.DryRun)
                {
                    jsonWriter.WritePropertyName("xGs2DryRun");
                    jsonWriter.Write("true");
                }

                AddHeader(
                    Session.Credential,
                    "deploy",
                    "stack",
                    "preValidate",
                    jsonWriter
                );

                jsonWriter.WriteObjectEnd();

                return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
            }
        }

#if UNITY_2017_1_OR_NEWER
		public IEnumerator PreValidate(
                Request.PreValidateRequest request,
                UnityAction<AsyncResult<Result.PreValidateResult>> callback
        )
		{
			var task = new PreValidateTask(
			    Gs2WebSocketSession,
			    request
            );
            yield return task;
            callback.Invoke(new AsyncResult<Result.PreValidateResult>(task.Result, task.Error));
        }

		public IFuture<Result.PreValidateResult> PreValidateFuture(
                Request.PreValidateRequest request
        )
		{
			return new PreValidateTask(
			    Gs2WebSocketSession,
			    request
			);
        }

    #if GS2_ENABLE_UNITASK
		public async UniTask<Result.PreValidateResult> PreValidateAsync(
            Request.PreValidateRequest request
        )
		{
		    var task = new PreValidateTask(
		        Gs2WebSocketSession,
		        request
            );
			return await task.Invoke();
        }
    #else
		public PreValidateTask PreValidateAsync(
                Request.PreValidateRequest request
        )
		{
			return new PreValidateTask(
                Gs2WebSocketSession,
			    request
            );
        }
    #endif
#else
		public async Task<Result.PreValidateResult> PreValidateAsync(
            Request.PreValidateRequest request
        )
		{
		    var task = new PreValidateTask(
		        Gs2WebSocketSession,
		        request
            );
			return await task.Invoke();
        }
#endif


        public class ValidateTask : Gs2WebSocketSessionTask<Request.ValidateRequest, Result.ValidateResult>
        {
	        public ValidateTask(IGs2Session session, Request.ValidateRequest request) : base(session, request)
	        {
	        }

            protected override IGs2SessionRequest CreateRequest(Request.ValidateRequest request)
            {
                var stringBuilder = new StringBuilder();
                var jsonWriter = new JsonWriter(stringBuilder);

                jsonWriter.WriteObjectStart();

                if (request.Mode != null)
                {
                    jsonWriter.WritePropertyName("mode");
                    jsonWriter.Write(request.Mode.ToString());
                }
                if (request.Template != null)
                {
                    jsonWriter.WritePropertyName("template");
                    jsonWriter.Write(request.Template.ToString());
                }
                if (request.UploadToken != null)
                {
                    jsonWriter.WritePropertyName("uploadToken");
                    jsonWriter.Write(request.UploadToken.ToString());
                }
                if (request.ContextStack != null)
                {
                    jsonWriter.WritePropertyName("contextStack");
                    jsonWriter.Write(request.ContextStack.ToString());
                }
                if (request.DryRun)
                {
                    jsonWriter.WritePropertyName("xGs2DryRun");
                    jsonWriter.Write("true");
                }

                AddHeader(
                    Session.Credential,
                    "deploy",
                    "stack",
                    "validate",
                    jsonWriter
                );

                jsonWriter.WriteObjectEnd();

                return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
            }
        }

#if UNITY_2017_1_OR_NEWER
		public IEnumerator Validate(
                Request.ValidateRequest request,
                UnityAction<AsyncResult<Result.ValidateResult>> callback
        )
		{
			var task = new ValidateTask(
			    Gs2WebSocketSession,
			    request
            );
            yield return task;
            callback.Invoke(new AsyncResult<Result.ValidateResult>(task.Result, task.Error));
        }

		public IFuture<Result.ValidateResult> ValidateFuture(
                Request.ValidateRequest request
        )
		{
			return new ValidateTask(
			    Gs2WebSocketSession,
			    request
			);
        }

    #if GS2_ENABLE_UNITASK
		public async UniTask<Result.ValidateResult> ValidateAsync(
            Request.ValidateRequest request
        )
		{
		    var task = new ValidateTask(
		        Gs2WebSocketSession,
		        request
            );
			return await task.Invoke();
        }
    #else
		public ValidateTask ValidateAsync(
                Request.ValidateRequest request
        )
		{
			return new ValidateTask(
                Gs2WebSocketSession,
			    request
            );
        }
    #endif
#else
		public async Task<Result.ValidateResult> ValidateAsync(
            Request.ValidateRequest request
        )
		{
		    var task = new ValidateTask(
		        Gs2WebSocketSession,
		        request
            );
			return await task.Invoke();
        }
#endif


        public class PreUpdateStackTask : Gs2WebSocketSessionTask<Request.PreUpdateStackRequest, Result.PreUpdateStackResult>
        {
	        public PreUpdateStackTask(IGs2Session session, Request.PreUpdateStackRequest request) : base(session, request)
	        {
	        }

            protected override IGs2SessionRequest CreateRequest(Request.PreUpdateStackRequest request)
            {
                var stringBuilder = new StringBuilder();
                var jsonWriter = new JsonWriter(stringBuilder);

                jsonWriter.WriteObjectStart();

                if (request.StackName != null)
                {
                    jsonWriter.WritePropertyName("stackName");
                    jsonWriter.Write(request.StackName.ToString());
                }
                if (request.ContextStack != null)
                {
                    jsonWriter.WritePropertyName("contextStack");
                    jsonWriter.Write(request.ContextStack.ToString());
                }
                if (request.DryRun)
                {
                    jsonWriter.WritePropertyName("xGs2DryRun");
                    jsonWriter.Write("true");
                }

                AddHeader(
                    Session.Credential,
                    "deploy",
                    "stack",
                    "preUpdateStack",
                    jsonWriter
                );

                jsonWriter.WriteObjectEnd();

                return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
            }
        }

#if UNITY_2017_1_OR_NEWER
		public IEnumerator PreUpdateStack(
                Request.PreUpdateStackRequest request,
                UnityAction<AsyncResult<Result.PreUpdateStackResult>> callback
        )
		{
			var task = new PreUpdateStackTask(
			    Gs2WebSocketSession,
			    request
            );
            yield return task;
            callback.Invoke(new AsyncResult<Result.PreUpdateStackResult>(task.Result, task.Error));
        }

		public IFuture<Result.PreUpdateStackResult> PreUpdateStackFuture(
                Request.PreUpdateStackRequest request
        )
		{
			return new PreUpdateStackTask(
			    Gs2WebSocketSession,
			    request
			);
        }

    #if GS2_ENABLE_UNITASK
		public async UniTask<Result.PreUpdateStackResult> PreUpdateStackAsync(
            Request.PreUpdateStackRequest request
        )
		{
		    var task = new PreUpdateStackTask(
		        Gs2WebSocketSession,
		        request
            );
			return await task.Invoke();
        }
    #else
		public PreUpdateStackTask PreUpdateStackAsync(
                Request.PreUpdateStackRequest request
        )
		{
			return new PreUpdateStackTask(
                Gs2WebSocketSession,
			    request
            );
        }
    #endif
#else
		public async Task<Result.PreUpdateStackResult> PreUpdateStackAsync(
            Request.PreUpdateStackRequest request
        )
		{
		    var task = new PreUpdateStackTask(
		        Gs2WebSocketSession,
		        request
            );
			return await task.Invoke();
        }
#endif


        public class PreChangeSetTask : Gs2WebSocketSessionTask<Request.PreChangeSetRequest, Result.PreChangeSetResult>
        {
	        public PreChangeSetTask(IGs2Session session, Request.PreChangeSetRequest request) : base(session, request)
	        {
	        }

            protected override IGs2SessionRequest CreateRequest(Request.PreChangeSetRequest request)
            {
                var stringBuilder = new StringBuilder();
                var jsonWriter = new JsonWriter(stringBuilder);

                jsonWriter.WriteObjectStart();

                if (request.StackName != null)
                {
                    jsonWriter.WritePropertyName("stackName");
                    jsonWriter.Write(request.StackName.ToString());
                }
                if (request.ContextStack != null)
                {
                    jsonWriter.WritePropertyName("contextStack");
                    jsonWriter.Write(request.ContextStack.ToString());
                }
                if (request.DryRun)
                {
                    jsonWriter.WritePropertyName("xGs2DryRun");
                    jsonWriter.Write("true");
                }

                AddHeader(
                    Session.Credential,
                    "deploy",
                    "stack",
                    "preChangeSet",
                    jsonWriter
                );

                jsonWriter.WriteObjectEnd();

                return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
            }
        }

#if UNITY_2017_1_OR_NEWER
		public IEnumerator PreChangeSet(
                Request.PreChangeSetRequest request,
                UnityAction<AsyncResult<Result.PreChangeSetResult>> callback
        )
		{
			var task = new PreChangeSetTask(
			    Gs2WebSocketSession,
			    request
            );
            yield return task;
            callback.Invoke(new AsyncResult<Result.PreChangeSetResult>(task.Result, task.Error));
        }

		public IFuture<Result.PreChangeSetResult> PreChangeSetFuture(
                Request.PreChangeSetRequest request
        )
		{
			return new PreChangeSetTask(
			    Gs2WebSocketSession,
			    request
			);
        }

    #if GS2_ENABLE_UNITASK
		public async UniTask<Result.PreChangeSetResult> PreChangeSetAsync(
            Request.PreChangeSetRequest request
        )
		{
		    var task = new PreChangeSetTask(
		        Gs2WebSocketSession,
		        request
            );
			return await task.Invoke();
        }
    #else
		public PreChangeSetTask PreChangeSetAsync(
                Request.PreChangeSetRequest request
        )
		{
			return new PreChangeSetTask(
                Gs2WebSocketSession,
			    request
            );
        }
    #endif
#else
		public async Task<Result.PreChangeSetResult> PreChangeSetAsync(
            Request.PreChangeSetRequest request
        )
		{
		    var task = new PreChangeSetTask(
		        Gs2WebSocketSession,
		        request
            );
			return await task.Invoke();
        }
#endif
	}
}