Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
pip-gs2 / io.gs2.csharp.sdk js
Repository URL to install this package:
|
Version:
2025.8.5 ▾
|
/*
* 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
#if UNITY_2017_1_OR_NEWER
using UnityEngine.Events;
using UnityEngine.Networking;
#if GS2_ENABLE_UNITASK
using Cysharp.Threading.Tasks;
#endif
#else
using System.Web;
using System.Net.Http;
using System.Threading.Tasks;
#endif
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.Linq;
using Gs2.Core;
using Gs2.Core.Model;
using Gs2.Core.Net;
using Gs2.Gs2Deploy.Request;
using Gs2.Gs2Deploy.Result;
using Gs2.Util.LitJson;
namespace Gs2.Gs2Deploy
{
public class Gs2DeployRestClient : AbstractGs2Client
{
#if UNITY_2017_1_OR_NEWER
private readonly CertificateHandler _certificateHandler;
#endif
public static string Endpoint = "deploy";
protected Gs2RestSession Gs2RestSession => (Gs2RestSession) Gs2Session;
public Gs2DeployRestClient(Gs2RestSession Gs2RestSession) : base(Gs2RestSession)
{
}
#if UNITY_2017_1_OR_NEWER
public Gs2DeployRestClient(Gs2RestSession gs2RestSession, CertificateHandler certificateHandler) : base(gs2RestSession)
{
_certificateHandler = certificateHandler;
}
#endif
public class DescribeStacksTask : Gs2RestSessionTask<DescribeStacksRequest, DescribeStacksResult>
{
public DescribeStacksTask(IGs2Session session, RestSessionRequestFactory factory, DescribeStacksRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DescribeStacksRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack";
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DescribeStacks(
Request.DescribeStacksRequest request,
UnityAction<AsyncResult<Result.DescribeStacksResult>> callback
)
{
var task = new DescribeStacksTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DescribeStacksResult>(task.Result, task.Error));
}
public IFuture<Result.DescribeStacksResult> DescribeStacksFuture(
Request.DescribeStacksRequest request
)
{
return new DescribeStacksTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DescribeStacksResult> DescribeStacksAsync(
Request.DescribeStacksRequest request
)
{
AsyncResult<Result.DescribeStacksResult> result = null;
await DescribeStacks(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DescribeStacksTask DescribeStacksAsync(
Request.DescribeStacksRequest request
)
{
return new DescribeStacksTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DescribeStacksResult> DescribeStacksAsync(
Request.DescribeStacksRequest request
)
{
var task = new DescribeStacksTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class PreCreateStackTask : Gs2RestSessionTask<PreCreateStackRequest, PreCreateStackResult>
{
public PreCreateStackTask(IGs2Session session, RestSessionRequestFactory factory, PreCreateStackRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(PreCreateStackRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/pre";
var sessionRequest = Factory.Post(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
jsonWriter.WriteObjectEnd();
var body = stringBuilder.ToString();
if (!string.IsNullOrEmpty(body))
{
sessionRequest.Body = body;
}
sessionRequest.AddHeader("Content-Type", "application/json");
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator PreCreateStack(
Request.PreCreateStackRequest request,
UnityAction<AsyncResult<Result.PreCreateStackResult>> callback
)
{
var task = new PreCreateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
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(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.PreCreateStackResult> PreCreateStackAsync(
Request.PreCreateStackRequest request
)
{
AsyncResult<Result.PreCreateStackResult> result = null;
await PreCreateStack(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public PreCreateStackTask PreCreateStackAsync(
Request.PreCreateStackRequest request
)
{
return new PreCreateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.PreCreateStackResult> PreCreateStackAsync(
Request.PreCreateStackRequest request
)
{
var task = new PreCreateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class CreateStackTask : Gs2RestSessionTask<CreateStackRequest, CreateStackResult>
{
public CreateStackTask(IGs2Session session, RestSessionRequestFactory factory, CreateStackRequest request) : base(session, factory, request)
{
}
public override IEnumerator Action() {
if (Request.Template != null) {
var preTask = new PreCreateStackTask(
Session,
Factory,
new PreCreateStackRequest()
.WithContextStack(Request.ContextStack)
);
yield return preTask;
if (preTask.Error != null) {
OnError(preTask.Error);
yield break;
}
#if UNITY_2017_1_OR_NEWER
using var request = UnityEngine.Networking.UnityWebRequest.Put(preTask.Result.UploadUrl, Request.Template);
request.SetRequestHeader("Content-Type", "application/json");
yield return request.SendWebRequest();
request.Dispose();
#endif
Request.Mode = "preUpload";
Request.UploadToken = preTask.Result.UploadToken;
Request.Template = null;
}
yield return base.Action();
}
protected override IGs2SessionRequest CreateRequest(CreateStackRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack";
var sessionRequest = Factory.Post(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.Name != null)
{
jsonWriter.WritePropertyName("name");
jsonWriter.Write(request.Name);
}
if (request.Description != null)
{
jsonWriter.WritePropertyName("description");
jsonWriter.Write(request.Description);
}
if (request.Mode != null)
{
jsonWriter.WritePropertyName("mode");
jsonWriter.Write(request.Mode);
}
if (request.Template != null)
{
jsonWriter.WritePropertyName("template");
jsonWriter.Write(request.Template);
}
if (request.UploadToken != null)
{
jsonWriter.WritePropertyName("uploadToken");
jsonWriter.Write(request.UploadToken);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
jsonWriter.WriteObjectEnd();
var body = stringBuilder.ToString();
if (!string.IsNullOrEmpty(body))
{
sessionRequest.Body = body;
}
sessionRequest.AddHeader("Content-Type", "application/json");
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CreateStack(
Request.CreateStackRequest request,
UnityAction<AsyncResult<Result.CreateStackResult>> callback
)
{
var task = new CreateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CreateStackResult>(task.Result, task.Error));
}
public IFuture<Result.CreateStackResult> CreateStackFuture(
Request.CreateStackRequest request
)
{
return new CreateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CreateStackResult> CreateStackAsync(
Request.CreateStackRequest request
)
{
AsyncResult<Result.CreateStackResult> result = null;
await CreateStack(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public CreateStackTask CreateStackAsync(
Request.CreateStackRequest request
)
{
return new CreateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.CreateStackResult> CreateStackAsync(
Request.CreateStackRequest request
)
{
if (request.Template != null) {
var res = await PreCreateStackAsync(
new PreCreateStackRequest()
.WithContextStack(request.ContextStack)
);
var req = new HttpRequestMessage(
System.Net.Http.HttpMethod.Put,
res.UploadUrl
);
req.Content = new ByteArrayContent(System.Text.Encoding.UTF8.GetBytes(request.Template));
req.Content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");
await new HttpClient().SendAsync(req);
request.Mode = "preUpload";
request.UploadToken = res.UploadToken;
request.Template = null;
}
var task = new CreateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class CreateStackFromGitHubTask : Gs2RestSessionTask<CreateStackFromGitHubRequest, CreateStackFromGitHubResult>
{
public CreateStackFromGitHubTask(IGs2Session session, RestSessionRequestFactory factory, CreateStackFromGitHubRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(CreateStackFromGitHubRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/from_git_hub";
var sessionRequest = Factory.Post(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.Name != null)
{
jsonWriter.WritePropertyName("name");
jsonWriter.Write(request.Name);
}
if (request.Description != null)
{
jsonWriter.WritePropertyName("description");
jsonWriter.Write(request.Description);
}
if (request.CheckoutSetting != null)
{
jsonWriter.WritePropertyName("checkoutSetting");
request.CheckoutSetting.WriteJson(jsonWriter);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
jsonWriter.WriteObjectEnd();
var body = stringBuilder.ToString();
if (!string.IsNullOrEmpty(body))
{
sessionRequest.Body = body;
}
sessionRequest.AddHeader("Content-Type", "application/json");
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CreateStackFromGitHub(
Request.CreateStackFromGitHubRequest request,
UnityAction<AsyncResult<Result.CreateStackFromGitHubResult>> callback
)
{
var task = new CreateStackFromGitHubTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CreateStackFromGitHubResult>(task.Result, task.Error));
}
public IFuture<Result.CreateStackFromGitHubResult> CreateStackFromGitHubFuture(
Request.CreateStackFromGitHubRequest request
)
{
return new CreateStackFromGitHubTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CreateStackFromGitHubResult> CreateStackFromGitHubAsync(
Request.CreateStackFromGitHubRequest request
)
{
AsyncResult<Result.CreateStackFromGitHubResult> result = null;
await CreateStackFromGitHub(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public CreateStackFromGitHubTask CreateStackFromGitHubAsync(
Request.CreateStackFromGitHubRequest request
)
{
return new CreateStackFromGitHubTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.CreateStackFromGitHubResult> CreateStackFromGitHubAsync(
Request.CreateStackFromGitHubRequest request
)
{
var task = new CreateStackFromGitHubTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class PreValidateTask : Gs2RestSessionTask<PreValidateRequest, PreValidateResult>
{
public PreValidateTask(IGs2Session session, RestSessionRequestFactory factory, PreValidateRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(PreValidateRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/validate/pre";
var sessionRequest = Factory.Post(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
jsonWriter.WriteObjectEnd();
var body = stringBuilder.ToString();
if (!string.IsNullOrEmpty(body))
{
sessionRequest.Body = body;
}
sessionRequest.AddHeader("Content-Type", "application/json");
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator PreValidate(
Request.PreValidateRequest request,
UnityAction<AsyncResult<Result.PreValidateResult>> callback
)
{
var task = new PreValidateTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
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(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.PreValidateResult> PreValidateAsync(
Request.PreValidateRequest request
)
{
AsyncResult<Result.PreValidateResult> result = null;
await PreValidate(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public PreValidateTask PreValidateAsync(
Request.PreValidateRequest request
)
{
return new PreValidateTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.PreValidateResult> PreValidateAsync(
Request.PreValidateRequest request
)
{
var task = new PreValidateTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class ValidateTask : Gs2RestSessionTask<ValidateRequest, ValidateResult>
{
public ValidateTask(IGs2Session session, RestSessionRequestFactory factory, ValidateRequest request) : base(session, factory, request)
{
}
public override IEnumerator Action() {
if (Request.Template != null) {
var preTask = new PreValidateTask(
Session,
Factory,
new PreValidateRequest()
.WithContextStack(Request.ContextStack)
);
yield return preTask;
if (preTask.Error != null) {
OnError(preTask.Error);
yield break;
}
#if UNITY_2017_1_OR_NEWER
using var request = UnityEngine.Networking.UnityWebRequest.Put(preTask.Result.UploadUrl, Request.Template);
request.SetRequestHeader("Content-Type", "application/json");
yield return request.SendWebRequest();
request.Dispose();
#endif
Request.Mode = "preUpload";
Request.UploadToken = preTask.Result.UploadToken;
Request.Template = null;
}
yield return base.Action();
}
protected override IGs2SessionRequest CreateRequest(ValidateRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/validate";
var sessionRequest = Factory.Post(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.Mode != null)
{
jsonWriter.WritePropertyName("mode");
jsonWriter.Write(request.Mode);
}
if (request.Template != null)
{
jsonWriter.WritePropertyName("template");
jsonWriter.Write(request.Template);
}
if (request.UploadToken != null)
{
jsonWriter.WritePropertyName("uploadToken");
jsonWriter.Write(request.UploadToken);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
jsonWriter.WriteObjectEnd();
var body = stringBuilder.ToString();
if (!string.IsNullOrEmpty(body))
{
sessionRequest.Body = body;
}
sessionRequest.AddHeader("Content-Type", "application/json");
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator Validate(
Request.ValidateRequest request,
UnityAction<AsyncResult<Result.ValidateResult>> callback
)
{
var task = new ValidateTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
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(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.ValidateResult> ValidateAsync(
Request.ValidateRequest request
)
{
AsyncResult<Result.ValidateResult> result = null;
await Validate(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public ValidateTask ValidateAsync(
Request.ValidateRequest request
)
{
return new ValidateTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.ValidateResult> ValidateAsync(
Request.ValidateRequest request
)
{
if (request.Template != null) {
var res = await PreValidateAsync(
new PreValidateRequest()
.WithContextStack(request.ContextStack)
);
var req = new HttpRequestMessage(
System.Net.Http.HttpMethod.Put,
res.UploadUrl
);
req.Content = new ByteArrayContent(System.Text.Encoding.UTF8.GetBytes(request.Template));
req.Content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");
await new HttpClient().SendAsync(req);
request.Mode = "preUpload";
request.UploadToken = res.UploadToken;
request.Template = null;
}
var task = new ValidateTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class GetStackStatusTask : Gs2RestSessionTask<GetStackStatusRequest, GetStackStatusResult>
{
public GetStackStatusTask(IGs2Session session, RestSessionRequestFactory factory, GetStackStatusRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(GetStackStatusRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/status";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetStackStatus(
Request.GetStackStatusRequest request,
UnityAction<AsyncResult<Result.GetStackStatusResult>> callback
)
{
var task = new GetStackStatusTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetStackStatusResult>(task.Result, task.Error));
}
public IFuture<Result.GetStackStatusResult> GetStackStatusFuture(
Request.GetStackStatusRequest request
)
{
return new GetStackStatusTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetStackStatusResult> GetStackStatusAsync(
Request.GetStackStatusRequest request
)
{
AsyncResult<Result.GetStackStatusResult> result = null;
await GetStackStatus(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public GetStackStatusTask GetStackStatusAsync(
Request.GetStackStatusRequest request
)
{
return new GetStackStatusTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.GetStackStatusResult> GetStackStatusAsync(
Request.GetStackStatusRequest request
)
{
var task = new GetStackStatusTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class GetStackTask : Gs2RestSessionTask<GetStackRequest, GetStackResult>
{
public GetStackTask(IGs2Session session, RestSessionRequestFactory factory, GetStackRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(GetStackRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetStack(
Request.GetStackRequest request,
UnityAction<AsyncResult<Result.GetStackResult>> callback
)
{
var task = new GetStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetStackResult>(task.Result, task.Error));
}
public IFuture<Result.GetStackResult> GetStackFuture(
Request.GetStackRequest request
)
{
return new GetStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetStackResult> GetStackAsync(
Request.GetStackRequest request
)
{
AsyncResult<Result.GetStackResult> result = null;
await GetStack(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public GetStackTask GetStackAsync(
Request.GetStackRequest request
)
{
return new GetStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.GetStackResult> GetStackAsync(
Request.GetStackRequest request
)
{
var task = new GetStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class PreUpdateStackTask : Gs2RestSessionTask<PreUpdateStackRequest, PreUpdateStackResult>
{
public PreUpdateStackTask(IGs2Session session, RestSessionRequestFactory factory, PreUpdateStackRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(PreUpdateStackRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/pre";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Put(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
jsonWriter.WriteObjectEnd();
var body = stringBuilder.ToString();
if (!string.IsNullOrEmpty(body))
{
sessionRequest.Body = body;
}
sessionRequest.AddHeader("Content-Type", "application/json");
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator PreUpdateStack(
Request.PreUpdateStackRequest request,
UnityAction<AsyncResult<Result.PreUpdateStackResult>> callback
)
{
var task = new PreUpdateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
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(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.PreUpdateStackResult> PreUpdateStackAsync(
Request.PreUpdateStackRequest request
)
{
AsyncResult<Result.PreUpdateStackResult> result = null;
await PreUpdateStack(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public PreUpdateStackTask PreUpdateStackAsync(
Request.PreUpdateStackRequest request
)
{
return new PreUpdateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.PreUpdateStackResult> PreUpdateStackAsync(
Request.PreUpdateStackRequest request
)
{
var task = new PreUpdateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class UpdateStackTask : Gs2RestSessionTask<UpdateStackRequest, UpdateStackResult>
{
public UpdateStackTask(IGs2Session session, RestSessionRequestFactory factory, UpdateStackRequest request) : base(session, factory, request)
{
}
public override IEnumerator Action() {
if (Request.Template != null) {
var preTask = new PreUpdateStackTask(
Session,
Factory,
new PreUpdateStackRequest()
.WithContextStack(Request.ContextStack)
.WithStackName(Request.StackName)
);
yield return preTask;
if (preTask.Error != null) {
OnError(preTask.Error);
yield break;
}
#if UNITY_2017_1_OR_NEWER
using var request = UnityEngine.Networking.UnityWebRequest.Put(preTask.Result.UploadUrl, Request.Template);
request.SetRequestHeader("Content-Type", "application/json");
yield return request.SendWebRequest();
request.Dispose();
#endif
Request.Mode = "preUpload";
Request.UploadToken = preTask.Result.UploadToken;
Request.Template = null;
}
yield return base.Action();
}
protected override IGs2SessionRequest CreateRequest(UpdateStackRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Put(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.Description != null)
{
jsonWriter.WritePropertyName("description");
jsonWriter.Write(request.Description);
}
if (request.Mode != null)
{
jsonWriter.WritePropertyName("mode");
jsonWriter.Write(request.Mode);
}
if (request.Template != null)
{
jsonWriter.WritePropertyName("template");
jsonWriter.Write(request.Template);
}
if (request.UploadToken != null)
{
jsonWriter.WritePropertyName("uploadToken");
jsonWriter.Write(request.UploadToken);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
jsonWriter.WriteObjectEnd();
var body = stringBuilder.ToString();
if (!string.IsNullOrEmpty(body))
{
sessionRequest.Body = body;
}
sessionRequest.AddHeader("Content-Type", "application/json");
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator UpdateStack(
Request.UpdateStackRequest request,
UnityAction<AsyncResult<Result.UpdateStackResult>> callback
)
{
var task = new UpdateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.UpdateStackResult>(task.Result, task.Error));
}
public IFuture<Result.UpdateStackResult> UpdateStackFuture(
Request.UpdateStackRequest request
)
{
return new UpdateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UpdateStackResult> UpdateStackAsync(
Request.UpdateStackRequest request
)
{
AsyncResult<Result.UpdateStackResult> result = null;
await UpdateStack(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public UpdateStackTask UpdateStackAsync(
Request.UpdateStackRequest request
)
{
return new UpdateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.UpdateStackResult> UpdateStackAsync(
Request.UpdateStackRequest request
)
{
if (request.Template != null) {
var res = await PreUpdateStackAsync(
new PreUpdateStackRequest()
.WithContextStack(request.ContextStack)
.WithStackName(request.StackName)
);
var req = new HttpRequestMessage(
System.Net.Http.HttpMethod.Put,
res.UploadUrl
);
req.Content = new ByteArrayContent(System.Text.Encoding.UTF8.GetBytes(request.Template));
req.Content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");
await new HttpClient().SendAsync(req);
request.Mode = "preUpload";
request.UploadToken = res.UploadToken;
request.Template = null;
}
var task = new UpdateStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class PreChangeSetTask : Gs2RestSessionTask<PreChangeSetRequest, PreChangeSetResult>
{
public PreChangeSetTask(IGs2Session session, RestSessionRequestFactory factory, PreChangeSetRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(PreChangeSetRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/pre";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Post(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
jsonWriter.WriteObjectEnd();
var body = stringBuilder.ToString();
if (!string.IsNullOrEmpty(body))
{
sessionRequest.Body = body;
}
sessionRequest.AddHeader("Content-Type", "application/json");
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator PreChangeSet(
Request.PreChangeSetRequest request,
UnityAction<AsyncResult<Result.PreChangeSetResult>> callback
)
{
var task = new PreChangeSetTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
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(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.PreChangeSetResult> PreChangeSetAsync(
Request.PreChangeSetRequest request
)
{
AsyncResult<Result.PreChangeSetResult> result = null;
await PreChangeSet(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public PreChangeSetTask PreChangeSetAsync(
Request.PreChangeSetRequest request
)
{
return new PreChangeSetTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.PreChangeSetResult> PreChangeSetAsync(
Request.PreChangeSetRequest request
)
{
var task = new PreChangeSetTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class ChangeSetTask : Gs2RestSessionTask<ChangeSetRequest, ChangeSetResult>
{
public ChangeSetTask(IGs2Session session, RestSessionRequestFactory factory, ChangeSetRequest request) : base(session, factory, request)
{
}
public override IEnumerator Action() {
if (Request.Template != null) {
var preTask = new PreChangeSetTask(
Session,
Factory,
new PreChangeSetRequest()
.WithContextStack(Request.ContextStack)
.WithStackName(Request.StackName)
);
yield return preTask;
if (preTask.Error != null) {
OnError(preTask.Error);
yield break;
}
#if UNITY_2017_1_OR_NEWER
using var request = UnityEngine.Networking.UnityWebRequest.Put(preTask.Result.UploadUrl, Request.Template);
request.SetRequestHeader("Content-Type", "application/json");
yield return request.SendWebRequest();
request.Dispose();
#endif
Request.Mode = "preUpload";
Request.UploadToken = preTask.Result.UploadToken;
Request.Template = null;
}
yield return base.Action();
}
protected override IGs2SessionRequest CreateRequest(ChangeSetRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Post(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.Mode != null)
{
jsonWriter.WritePropertyName("mode");
jsonWriter.Write(request.Mode);
}
if (request.Template != null)
{
jsonWriter.WritePropertyName("template");
jsonWriter.Write(request.Template);
}
if (request.UploadToken != null)
{
jsonWriter.WritePropertyName("uploadToken");
jsonWriter.Write(request.UploadToken);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
jsonWriter.WriteObjectEnd();
var body = stringBuilder.ToString();
if (!string.IsNullOrEmpty(body))
{
sessionRequest.Body = body;
}
sessionRequest.AddHeader("Content-Type", "application/json");
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator ChangeSet(
Request.ChangeSetRequest request,
UnityAction<AsyncResult<Result.ChangeSetResult>> callback
)
{
var task = new ChangeSetTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.ChangeSetResult>(task.Result, task.Error));
}
public IFuture<Result.ChangeSetResult> ChangeSetFuture(
Request.ChangeSetRequest request
)
{
return new ChangeSetTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.ChangeSetResult> ChangeSetAsync(
Request.ChangeSetRequest request
)
{
AsyncResult<Result.ChangeSetResult> result = null;
await ChangeSet(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public ChangeSetTask ChangeSetAsync(
Request.ChangeSetRequest request
)
{
return new ChangeSetTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.ChangeSetResult> ChangeSetAsync(
Request.ChangeSetRequest request
)
{
if (request.Template != null) {
var res = await PreChangeSetAsync(
new PreChangeSetRequest()
.WithContextStack(request.ContextStack)
.WithStackName(request.StackName)
);
var req = new HttpRequestMessage(
System.Net.Http.HttpMethod.Put,
res.UploadUrl
);
req.Content = new ByteArrayContent(System.Text.Encoding.UTF8.GetBytes(request.Template));
req.Content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");
await new HttpClient().SendAsync(req);
request.Mode = "preUpload";
request.UploadToken = res.UploadToken;
request.Template = null;
}
var task = new ChangeSetTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class UpdateStackFromGitHubTask : Gs2RestSessionTask<UpdateStackFromGitHubRequest, UpdateStackFromGitHubResult>
{
public UpdateStackFromGitHubTask(IGs2Session session, RestSessionRequestFactory factory, UpdateStackFromGitHubRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(UpdateStackFromGitHubRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/from_git_hub";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Put(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.Description != null)
{
jsonWriter.WritePropertyName("description");
jsonWriter.Write(request.Description);
}
if (request.CheckoutSetting != null)
{
jsonWriter.WritePropertyName("checkoutSetting");
request.CheckoutSetting.WriteJson(jsonWriter);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
jsonWriter.WriteObjectEnd();
var body = stringBuilder.ToString();
if (!string.IsNullOrEmpty(body))
{
sessionRequest.Body = body;
}
sessionRequest.AddHeader("Content-Type", "application/json");
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator UpdateStackFromGitHub(
Request.UpdateStackFromGitHubRequest request,
UnityAction<AsyncResult<Result.UpdateStackFromGitHubResult>> callback
)
{
var task = new UpdateStackFromGitHubTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.UpdateStackFromGitHubResult>(task.Result, task.Error));
}
public IFuture<Result.UpdateStackFromGitHubResult> UpdateStackFromGitHubFuture(
Request.UpdateStackFromGitHubRequest request
)
{
return new UpdateStackFromGitHubTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UpdateStackFromGitHubResult> UpdateStackFromGitHubAsync(
Request.UpdateStackFromGitHubRequest request
)
{
AsyncResult<Result.UpdateStackFromGitHubResult> result = null;
await UpdateStackFromGitHub(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public UpdateStackFromGitHubTask UpdateStackFromGitHubAsync(
Request.UpdateStackFromGitHubRequest request
)
{
return new UpdateStackFromGitHubTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.UpdateStackFromGitHubResult> UpdateStackFromGitHubAsync(
Request.UpdateStackFromGitHubRequest request
)
{
var task = new UpdateStackFromGitHubTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class DeleteStackTask : Gs2RestSessionTask<DeleteStackRequest, DeleteStackResult>
{
public DeleteStackTask(IGs2Session session, RestSessionRequestFactory factory, DeleteStackRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DeleteStackRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Delete(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteStack(
Request.DeleteStackRequest request,
UnityAction<AsyncResult<Result.DeleteStackResult>> callback
)
{
var task = new DeleteStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteStackResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteStackResult> DeleteStackFuture(
Request.DeleteStackRequest request
)
{
return new DeleteStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteStackResult> DeleteStackAsync(
Request.DeleteStackRequest request
)
{
AsyncResult<Result.DeleteStackResult> result = null;
await DeleteStack(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DeleteStackTask DeleteStackAsync(
Request.DeleteStackRequest request
)
{
return new DeleteStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DeleteStackResult> DeleteStackAsync(
Request.DeleteStackRequest request
)
{
var task = new DeleteStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class ForceDeleteStackTask : Gs2RestSessionTask<ForceDeleteStackRequest, ForceDeleteStackResult>
{
public ForceDeleteStackTask(IGs2Session session, RestSessionRequestFactory factory, ForceDeleteStackRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(ForceDeleteStackRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/force";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Delete(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator ForceDeleteStack(
Request.ForceDeleteStackRequest request,
UnityAction<AsyncResult<Result.ForceDeleteStackResult>> callback
)
{
var task = new ForceDeleteStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.ForceDeleteStackResult>(task.Result, task.Error));
}
public IFuture<Result.ForceDeleteStackResult> ForceDeleteStackFuture(
Request.ForceDeleteStackRequest request
)
{
return new ForceDeleteStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.ForceDeleteStackResult> ForceDeleteStackAsync(
Request.ForceDeleteStackRequest request
)
{
AsyncResult<Result.ForceDeleteStackResult> result = null;
await ForceDeleteStack(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public ForceDeleteStackTask ForceDeleteStackAsync(
Request.ForceDeleteStackRequest request
)
{
return new ForceDeleteStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.ForceDeleteStackResult> ForceDeleteStackAsync(
Request.ForceDeleteStackRequest request
)
{
var task = new ForceDeleteStackTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class DeleteStackResourcesTask : Gs2RestSessionTask<DeleteStackResourcesRequest, DeleteStackResourcesResult>
{
public DeleteStackResourcesTask(IGs2Session session, RestSessionRequestFactory factory, DeleteStackResourcesRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DeleteStackResourcesRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/resources";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Delete(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteStackResources(
Request.DeleteStackResourcesRequest request,
UnityAction<AsyncResult<Result.DeleteStackResourcesResult>> callback
)
{
var task = new DeleteStackResourcesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteStackResourcesResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteStackResourcesResult> DeleteStackResourcesFuture(
Request.DeleteStackResourcesRequest request
)
{
return new DeleteStackResourcesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteStackResourcesResult> DeleteStackResourcesAsync(
Request.DeleteStackResourcesRequest request
)
{
AsyncResult<Result.DeleteStackResourcesResult> result = null;
await DeleteStackResources(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DeleteStackResourcesTask DeleteStackResourcesAsync(
Request.DeleteStackResourcesRequest request
)
{
return new DeleteStackResourcesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DeleteStackResourcesResult> DeleteStackResourcesAsync(
Request.DeleteStackResourcesRequest request
)
{
var task = new DeleteStackResourcesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class DeleteStackEntityTask : Gs2RestSessionTask<DeleteStackEntityRequest, DeleteStackEntityResult>
{
public DeleteStackEntityTask(IGs2Session session, RestSessionRequestFactory factory, DeleteStackEntityRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DeleteStackEntityRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/entity";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Delete(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteStackEntity(
Request.DeleteStackEntityRequest request,
UnityAction<AsyncResult<Result.DeleteStackEntityResult>> callback
)
{
var task = new DeleteStackEntityTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteStackEntityResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteStackEntityResult> DeleteStackEntityFuture(
Request.DeleteStackEntityRequest request
)
{
return new DeleteStackEntityTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteStackEntityResult> DeleteStackEntityAsync(
Request.DeleteStackEntityRequest request
)
{
AsyncResult<Result.DeleteStackEntityResult> result = null;
await DeleteStackEntity(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DeleteStackEntityTask DeleteStackEntityAsync(
Request.DeleteStackEntityRequest request
)
{
return new DeleteStackEntityTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DeleteStackEntityResult> DeleteStackEntityAsync(
Request.DeleteStackEntityRequest request
)
{
var task = new DeleteStackEntityTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class GetServiceVersionTask : Gs2RestSessionTask<GetServiceVersionRequest, GetServiceVersionResult>
{
public GetServiceVersionTask(IGs2Session session, RestSessionRequestFactory factory, GetServiceVersionRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(GetServiceVersionRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/system/version";
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetServiceVersion(
Request.GetServiceVersionRequest request,
UnityAction<AsyncResult<Result.GetServiceVersionResult>> callback
)
{
var task = new GetServiceVersionTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetServiceVersionResult>(task.Result, task.Error));
}
public IFuture<Result.GetServiceVersionResult> GetServiceVersionFuture(
Request.GetServiceVersionRequest request
)
{
return new GetServiceVersionTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetServiceVersionResult> GetServiceVersionAsync(
Request.GetServiceVersionRequest request
)
{
AsyncResult<Result.GetServiceVersionResult> result = null;
await GetServiceVersion(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public GetServiceVersionTask GetServiceVersionAsync(
Request.GetServiceVersionRequest request
)
{
return new GetServiceVersionTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.GetServiceVersionResult> GetServiceVersionAsync(
Request.GetServiceVersionRequest request
)
{
var task = new GetServiceVersionTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class DescribeResourcesTask : Gs2RestSessionTask<DescribeResourcesRequest, DescribeResourcesResult>
{
public DescribeResourcesTask(IGs2Session session, RestSessionRequestFactory factory, DescribeResourcesRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DescribeResourcesRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/resource";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DescribeResources(
Request.DescribeResourcesRequest request,
UnityAction<AsyncResult<Result.DescribeResourcesResult>> callback
)
{
var task = new DescribeResourcesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DescribeResourcesResult>(task.Result, task.Error));
}
public IFuture<Result.DescribeResourcesResult> DescribeResourcesFuture(
Request.DescribeResourcesRequest request
)
{
return new DescribeResourcesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DescribeResourcesResult> DescribeResourcesAsync(
Request.DescribeResourcesRequest request
)
{
AsyncResult<Result.DescribeResourcesResult> result = null;
await DescribeResources(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DescribeResourcesTask DescribeResourcesAsync(
Request.DescribeResourcesRequest request
)
{
return new DescribeResourcesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DescribeResourcesResult> DescribeResourcesAsync(
Request.DescribeResourcesRequest request
)
{
var task = new DescribeResourcesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class GetResourceTask : Gs2RestSessionTask<GetResourceRequest, GetResourceResult>
{
public GetResourceTask(IGs2Session session, RestSessionRequestFactory factory, GetResourceRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(GetResourceRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/resource/{resourceName}";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
url = url.Replace("{resourceName}", !string.IsNullOrEmpty(request.ResourceName) ? request.ResourceName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetResource(
Request.GetResourceRequest request,
UnityAction<AsyncResult<Result.GetResourceResult>> callback
)
{
var task = new GetResourceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetResourceResult>(task.Result, task.Error));
}
public IFuture<Result.GetResourceResult> GetResourceFuture(
Request.GetResourceRequest request
)
{
return new GetResourceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetResourceResult> GetResourceAsync(
Request.GetResourceRequest request
)
{
AsyncResult<Result.GetResourceResult> result = null;
await GetResource(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public GetResourceTask GetResourceAsync(
Request.GetResourceRequest request
)
{
return new GetResourceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.GetResourceResult> GetResourceAsync(
Request.GetResourceRequest request
)
{
var task = new GetResourceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class DescribeEventsTask : Gs2RestSessionTask<DescribeEventsRequest, DescribeEventsResult>
{
public DescribeEventsTask(IGs2Session session, RestSessionRequestFactory factory, DescribeEventsRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DescribeEventsRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/event";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DescribeEvents(
Request.DescribeEventsRequest request,
UnityAction<AsyncResult<Result.DescribeEventsResult>> callback
)
{
var task = new DescribeEventsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DescribeEventsResult>(task.Result, task.Error));
}
public IFuture<Result.DescribeEventsResult> DescribeEventsFuture(
Request.DescribeEventsRequest request
)
{
return new DescribeEventsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DescribeEventsResult> DescribeEventsAsync(
Request.DescribeEventsRequest request
)
{
AsyncResult<Result.DescribeEventsResult> result = null;
await DescribeEvents(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DescribeEventsTask DescribeEventsAsync(
Request.DescribeEventsRequest request
)
{
return new DescribeEventsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DescribeEventsResult> DescribeEventsAsync(
Request.DescribeEventsRequest request
)
{
var task = new DescribeEventsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class GetEventTask : Gs2RestSessionTask<GetEventRequest, GetEventResult>
{
public GetEventTask(IGs2Session session, RestSessionRequestFactory factory, GetEventRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(GetEventRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/event/{eventName}";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
url = url.Replace("{eventName}", !string.IsNullOrEmpty(request.EventName) ? request.EventName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetEvent(
Request.GetEventRequest request,
UnityAction<AsyncResult<Result.GetEventResult>> callback
)
{
var task = new GetEventTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetEventResult>(task.Result, task.Error));
}
public IFuture<Result.GetEventResult> GetEventFuture(
Request.GetEventRequest request
)
{
return new GetEventTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetEventResult> GetEventAsync(
Request.GetEventRequest request
)
{
AsyncResult<Result.GetEventResult> result = null;
await GetEvent(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public GetEventTask GetEventAsync(
Request.GetEventRequest request
)
{
return new GetEventTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.GetEventResult> GetEventAsync(
Request.GetEventRequest request
)
{
var task = new GetEventTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class DescribeOutputsTask : Gs2RestSessionTask<DescribeOutputsRequest, DescribeOutputsResult>
{
public DescribeOutputsTask(IGs2Session session, RestSessionRequestFactory factory, DescribeOutputsRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DescribeOutputsRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/output";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DescribeOutputs(
Request.DescribeOutputsRequest request,
UnityAction<AsyncResult<Result.DescribeOutputsResult>> callback
)
{
var task = new DescribeOutputsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DescribeOutputsResult>(task.Result, task.Error));
}
public IFuture<Result.DescribeOutputsResult> DescribeOutputsFuture(
Request.DescribeOutputsRequest request
)
{
return new DescribeOutputsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DescribeOutputsResult> DescribeOutputsAsync(
Request.DescribeOutputsRequest request
)
{
AsyncResult<Result.DescribeOutputsResult> result = null;
await DescribeOutputs(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DescribeOutputsTask DescribeOutputsAsync(
Request.DescribeOutputsRequest request
)
{
return new DescribeOutputsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DescribeOutputsResult> DescribeOutputsAsync(
Request.DescribeOutputsRequest request
)
{
var task = new DescribeOutputsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class GetOutputTask : Gs2RestSessionTask<GetOutputRequest, GetOutputResult>
{
public GetOutputTask(IGs2Session session, RestSessionRequestFactory factory, GetOutputRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(GetOutputRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "deploy")
.Replace("{region}", Session.Region.DisplayName())
+ "/stack/{stackName}/output/{outputName}";
url = url.Replace("{stackName}", !string.IsNullOrEmpty(request.StackName) ? request.StackName.ToString() : "null");
url = url.Replace("{outputName}", !string.IsNullOrEmpty(request.OutputName) ? request.OutputName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetOutput(
Request.GetOutputRequest request,
UnityAction<AsyncResult<Result.GetOutputResult>> callback
)
{
var task = new GetOutputTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetOutputResult>(task.Result, task.Error));
}
public IFuture<Result.GetOutputResult> GetOutputFuture(
Request.GetOutputRequest request
)
{
return new GetOutputTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetOutputResult> GetOutputAsync(
Request.GetOutputRequest request
)
{
AsyncResult<Result.GetOutputResult> result = null;
await GetOutput(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public GetOutputTask GetOutputAsync(
Request.GetOutputRequest request
)
{
return new GetOutputTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.GetOutputResult> GetOutputAsync(
Request.GetOutputRequest request
)
{
var task = new GetOutputTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
}
}