Repository URL to install this package:
Version:
2025.3.14 ▾
|
/*
* 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.
*/
#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.Gs2Log.Request;
using Gs2.Gs2Log.Result;
using Gs2.Util.LitJson;
namespace Gs2.Gs2Log
{
public class Gs2LogRestClient : AbstractGs2Client
{
#if UNITY_2017_1_OR_NEWER
private readonly CertificateHandler _certificateHandler;
#endif
public static string Endpoint = "log";
protected Gs2RestSession Gs2RestSession => (Gs2RestSession) Gs2Session;
public Gs2LogRestClient(Gs2RestSession Gs2RestSession) : base(Gs2RestSession)
{
}
#if UNITY_2017_1_OR_NEWER
public Gs2LogRestClient(Gs2RestSession gs2RestSession, CertificateHandler certificateHandler) : base(gs2RestSession)
{
_certificateHandler = certificateHandler;
}
#endif
public class DescribeNamespacesTask : Gs2RestSessionTask<DescribeNamespacesRequest, DescribeNamespacesResult>
{
public DescribeNamespacesTask(IGs2Session session, RestSessionRequestFactory factory, DescribeNamespacesRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DescribeNamespacesRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/";
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 DescribeNamespaces(
Request.DescribeNamespacesRequest request,
UnityAction<AsyncResult<Result.DescribeNamespacesResult>> callback
)
{
var task = new DescribeNamespacesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DescribeNamespacesResult>(task.Result, task.Error));
}
public IFuture<Result.DescribeNamespacesResult> DescribeNamespacesFuture(
Request.DescribeNamespacesRequest request
)
{
return new DescribeNamespacesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DescribeNamespacesResult> DescribeNamespacesAsync(
Request.DescribeNamespacesRequest request
)
{
AsyncResult<Result.DescribeNamespacesResult> result = null;
await DescribeNamespaces(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DescribeNamespacesTask DescribeNamespacesAsync(
Request.DescribeNamespacesRequest request
)
{
return new DescribeNamespacesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DescribeNamespacesResult> DescribeNamespacesAsync(
Request.DescribeNamespacesRequest request
)
{
var task = new DescribeNamespacesTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class CreateNamespaceTask : Gs2RestSessionTask<CreateNamespaceRequest, CreateNamespaceResult>
{
public CreateNamespaceTask(IGs2Session session, RestSessionRequestFactory factory, CreateNamespaceRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(CreateNamespaceRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/";
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.Type != null)
{
jsonWriter.WritePropertyName("type");
jsonWriter.Write(request.Type);
}
if (request.GcpCredentialJson != null)
{
jsonWriter.WritePropertyName("gcpCredentialJson");
jsonWriter.Write(request.GcpCredentialJson);
}
if (request.BigQueryDatasetName != null)
{
jsonWriter.WritePropertyName("bigQueryDatasetName");
jsonWriter.Write(request.BigQueryDatasetName);
}
if (request.LogExpireDays != null)
{
jsonWriter.WritePropertyName("logExpireDays");
jsonWriter.Write(request.LogExpireDays.ToString());
}
if (request.AwsRegion != null)
{
jsonWriter.WritePropertyName("awsRegion");
jsonWriter.Write(request.AwsRegion);
}
if (request.AwsAccessKeyId != null)
{
jsonWriter.WritePropertyName("awsAccessKeyId");
jsonWriter.Write(request.AwsAccessKeyId);
}
if (request.AwsSecretAccessKey != null)
{
jsonWriter.WritePropertyName("awsSecretAccessKey");
jsonWriter.Write(request.AwsSecretAccessKey);
}
if (request.FirehoseStreamName != null)
{
jsonWriter.WritePropertyName("firehoseStreamName");
jsonWriter.Write(request.FirehoseStreamName);
}
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 CreateNamespace(
Request.CreateNamespaceRequest request,
UnityAction<AsyncResult<Result.CreateNamespaceResult>> callback
)
{
var task = new CreateNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CreateNamespaceResult>(task.Result, task.Error));
}
public IFuture<Result.CreateNamespaceResult> CreateNamespaceFuture(
Request.CreateNamespaceRequest request
)
{
return new CreateNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CreateNamespaceResult> CreateNamespaceAsync(
Request.CreateNamespaceRequest request
)
{
AsyncResult<Result.CreateNamespaceResult> result = null;
await CreateNamespace(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public CreateNamespaceTask CreateNamespaceAsync(
Request.CreateNamespaceRequest request
)
{
return new CreateNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.CreateNamespaceResult> CreateNamespaceAsync(
Request.CreateNamespaceRequest request
)
{
var task = new CreateNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class GetNamespaceStatusTask : Gs2RestSessionTask<GetNamespaceStatusRequest, GetNamespaceStatusResult>
{
public GetNamespaceStatusTask(IGs2Session session, RestSessionRequestFactory factory, GetNamespaceStatusRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(GetNamespaceStatusRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/status";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.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 GetNamespaceStatus(
Request.GetNamespaceStatusRequest request,
UnityAction<AsyncResult<Result.GetNamespaceStatusResult>> callback
)
{
var task = new GetNamespaceStatusTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetNamespaceStatusResult>(task.Result, task.Error));
}
public IFuture<Result.GetNamespaceStatusResult> GetNamespaceStatusFuture(
Request.GetNamespaceStatusRequest request
)
{
return new GetNamespaceStatusTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetNamespaceStatusResult> GetNamespaceStatusAsync(
Request.GetNamespaceStatusRequest request
)
{
AsyncResult<Result.GetNamespaceStatusResult> result = null;
await GetNamespaceStatus(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public GetNamespaceStatusTask GetNamespaceStatusAsync(
Request.GetNamespaceStatusRequest request
)
{
return new GetNamespaceStatusTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.GetNamespaceStatusResult> GetNamespaceStatusAsync(
Request.GetNamespaceStatusRequest request
)
{
var task = new GetNamespaceStatusTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class GetNamespaceTask : Gs2RestSessionTask<GetNamespaceRequest, GetNamespaceResult>
{
public GetNamespaceTask(IGs2Session session, RestSessionRequestFactory factory, GetNamespaceRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(GetNamespaceRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.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 GetNamespace(
Request.GetNamespaceRequest request,
UnityAction<AsyncResult<Result.GetNamespaceResult>> callback
)
{
var task = new GetNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetNamespaceResult>(task.Result, task.Error));
}
public IFuture<Result.GetNamespaceResult> GetNamespaceFuture(
Request.GetNamespaceRequest request
)
{
return new GetNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetNamespaceResult> GetNamespaceAsync(
Request.GetNamespaceRequest request
)
{
AsyncResult<Result.GetNamespaceResult> result = null;
await GetNamespace(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public GetNamespaceTask GetNamespaceAsync(
Request.GetNamespaceRequest request
)
{
return new GetNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.GetNamespaceResult> GetNamespaceAsync(
Request.GetNamespaceRequest request
)
{
var task = new GetNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class UpdateNamespaceTask : Gs2RestSessionTask<UpdateNamespaceRequest, UpdateNamespaceResult>
{
public UpdateNamespaceTask(IGs2Session session, RestSessionRequestFactory factory, UpdateNamespaceRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(UpdateNamespaceRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.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.Type != null)
{
jsonWriter.WritePropertyName("type");
jsonWriter.Write(request.Type);
}
if (request.GcpCredentialJson != null)
{
jsonWriter.WritePropertyName("gcpCredentialJson");
jsonWriter.Write(request.GcpCredentialJson);
}
if (request.BigQueryDatasetName != null)
{
jsonWriter.WritePropertyName("bigQueryDatasetName");
jsonWriter.Write(request.BigQueryDatasetName);
}
if (request.LogExpireDays != null)
{
jsonWriter.WritePropertyName("logExpireDays");
jsonWriter.Write(request.LogExpireDays.ToString());
}
if (request.AwsRegion != null)
{
jsonWriter.WritePropertyName("awsRegion");
jsonWriter.Write(request.AwsRegion);
}
if (request.AwsAccessKeyId != null)
{
jsonWriter.WritePropertyName("awsAccessKeyId");
jsonWriter.Write(request.AwsAccessKeyId);
}
if (request.AwsSecretAccessKey != null)
{
jsonWriter.WritePropertyName("awsSecretAccessKey");
jsonWriter.Write(request.AwsSecretAccessKey);
}
if (request.FirehoseStreamName != null)
{
jsonWriter.WritePropertyName("firehoseStreamName");
jsonWriter.Write(request.FirehoseStreamName);
}
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 UpdateNamespace(
Request.UpdateNamespaceRequest request,
UnityAction<AsyncResult<Result.UpdateNamespaceResult>> callback
)
{
var task = new UpdateNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.UpdateNamespaceResult>(task.Result, task.Error));
}
public IFuture<Result.UpdateNamespaceResult> UpdateNamespaceFuture(
Request.UpdateNamespaceRequest request
)
{
return new UpdateNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UpdateNamespaceResult> UpdateNamespaceAsync(
Request.UpdateNamespaceRequest request
)
{
AsyncResult<Result.UpdateNamespaceResult> result = null;
await UpdateNamespace(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public UpdateNamespaceTask UpdateNamespaceAsync(
Request.UpdateNamespaceRequest request
)
{
return new UpdateNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.UpdateNamespaceResult> UpdateNamespaceAsync(
Request.UpdateNamespaceRequest request
)
{
var task = new UpdateNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class DeleteNamespaceTask : Gs2RestSessionTask<DeleteNamespaceRequest, DeleteNamespaceResult>
{
public DeleteNamespaceTask(IGs2Session session, RestSessionRequestFactory factory, DeleteNamespaceRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DeleteNamespaceRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.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 DeleteNamespace(
Request.DeleteNamespaceRequest request,
UnityAction<AsyncResult<Result.DeleteNamespaceResult>> callback
)
{
var task = new DeleteNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteNamespaceResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteNamespaceResult> DeleteNamespaceFuture(
Request.DeleteNamespaceRequest request
)
{
return new DeleteNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteNamespaceResult> DeleteNamespaceAsync(
Request.DeleteNamespaceRequest request
)
{
AsyncResult<Result.DeleteNamespaceResult> result = null;
await DeleteNamespace(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DeleteNamespaceTask DeleteNamespaceAsync(
Request.DeleteNamespaceRequest request
)
{
return new DeleteNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DeleteNamespaceResult> DeleteNamespaceAsync(
Request.DeleteNamespaceRequest request
)
{
var task = new DeleteNamespaceTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class QueryAccessLogTask : Gs2RestSessionTask<QueryAccessLogRequest, QueryAccessLogResult>
{
public QueryAccessLogTask(IGs2Session session, RestSessionRequestFactory factory, QueryAccessLogRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(QueryAccessLogRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/log/access";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.Service != null) {
sessionRequest.AddQueryString("service", $"{request.Service}");
}
if (request.Method != null) {
sessionRequest.AddQueryString("method", $"{request.Method}");
}
if (request.UserId != null) {
sessionRequest.AddQueryString("userId", $"{request.UserId}");
}
if (request.Begin != null) {
sessionRequest.AddQueryString("begin", $"{request.Begin}");
}
if (request.End != null) {
sessionRequest.AddQueryString("end", $"{request.End}");
}
if (request.LongTerm != null) {
sessionRequest.AddQueryString("longTerm", $"{request.LongTerm}");
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator QueryAccessLog(
Request.QueryAccessLogRequest request,
UnityAction<AsyncResult<Result.QueryAccessLogResult>> callback
)
{
var task = new QueryAccessLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.QueryAccessLogResult>(task.Result, task.Error));
}
public IFuture<Result.QueryAccessLogResult> QueryAccessLogFuture(
Request.QueryAccessLogRequest request
)
{
return new QueryAccessLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.QueryAccessLogResult> QueryAccessLogAsync(
Request.QueryAccessLogRequest request
)
{
AsyncResult<Result.QueryAccessLogResult> result = null;
await QueryAccessLog(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public QueryAccessLogTask QueryAccessLogAsync(
Request.QueryAccessLogRequest request
)
{
return new QueryAccessLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.QueryAccessLogResult> QueryAccessLogAsync(
Request.QueryAccessLogRequest request
)
{
var task = new QueryAccessLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class CountAccessLogTask : Gs2RestSessionTask<CountAccessLogRequest, CountAccessLogResult>
{
public CountAccessLogTask(IGs2Session session, RestSessionRequestFactory factory, CountAccessLogRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(CountAccessLogRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/log/access/count";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.Service != null) {
sessionRequest.AddQueryString("service", $"{request.Service}");
}
if (request.Method != null) {
sessionRequest.AddQueryString("method", $"{request.Method}");
}
if (request.UserId != null) {
sessionRequest.AddQueryString("userId", $"{request.UserId}");
}
if (request.Begin != null) {
sessionRequest.AddQueryString("begin", $"{request.Begin}");
}
if (request.End != null) {
sessionRequest.AddQueryString("end", $"{request.End}");
}
if (request.LongTerm != null) {
sessionRequest.AddQueryString("longTerm", $"{request.LongTerm}");
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CountAccessLog(
Request.CountAccessLogRequest request,
UnityAction<AsyncResult<Result.CountAccessLogResult>> callback
)
{
var task = new CountAccessLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CountAccessLogResult>(task.Result, task.Error));
}
public IFuture<Result.CountAccessLogResult> CountAccessLogFuture(
Request.CountAccessLogRequest request
)
{
return new CountAccessLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CountAccessLogResult> CountAccessLogAsync(
Request.CountAccessLogRequest request
)
{
AsyncResult<Result.CountAccessLogResult> result = null;
await CountAccessLog(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public CountAccessLogTask CountAccessLogAsync(
Request.CountAccessLogRequest request
)
{
return new CountAccessLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.CountAccessLogResult> CountAccessLogAsync(
Request.CountAccessLogRequest request
)
{
var task = new CountAccessLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class QueryIssueStampSheetLogTask : Gs2RestSessionTask<QueryIssueStampSheetLogRequest, QueryIssueStampSheetLogResult>
{
public QueryIssueStampSheetLogTask(IGs2Session session, RestSessionRequestFactory factory, QueryIssueStampSheetLogRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(QueryIssueStampSheetLogRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/log/issue/stamp/sheet";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.Service != null) {
sessionRequest.AddQueryString("service", $"{request.Service}");
}
if (request.Method != null) {
sessionRequest.AddQueryString("method", $"{request.Method}");
}
if (request.UserId != null) {
sessionRequest.AddQueryString("userId", $"{request.UserId}");
}
if (request.Action != null) {
sessionRequest.AddQueryString("action", $"{request.Action}");
}
if (request.Begin != null) {
sessionRequest.AddQueryString("begin", $"{request.Begin}");
}
if (request.End != null) {
sessionRequest.AddQueryString("end", $"{request.End}");
}
if (request.LongTerm != null) {
sessionRequest.AddQueryString("longTerm", $"{request.LongTerm}");
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator QueryIssueStampSheetLog(
Request.QueryIssueStampSheetLogRequest request,
UnityAction<AsyncResult<Result.QueryIssueStampSheetLogResult>> callback
)
{
var task = new QueryIssueStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.QueryIssueStampSheetLogResult>(task.Result, task.Error));
}
public IFuture<Result.QueryIssueStampSheetLogResult> QueryIssueStampSheetLogFuture(
Request.QueryIssueStampSheetLogRequest request
)
{
return new QueryIssueStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.QueryIssueStampSheetLogResult> QueryIssueStampSheetLogAsync(
Request.QueryIssueStampSheetLogRequest request
)
{
AsyncResult<Result.QueryIssueStampSheetLogResult> result = null;
await QueryIssueStampSheetLog(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public QueryIssueStampSheetLogTask QueryIssueStampSheetLogAsync(
Request.QueryIssueStampSheetLogRequest request
)
{
return new QueryIssueStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.QueryIssueStampSheetLogResult> QueryIssueStampSheetLogAsync(
Request.QueryIssueStampSheetLogRequest request
)
{
var task = new QueryIssueStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class CountIssueStampSheetLogTask : Gs2RestSessionTask<CountIssueStampSheetLogRequest, CountIssueStampSheetLogResult>
{
public CountIssueStampSheetLogTask(IGs2Session session, RestSessionRequestFactory factory, CountIssueStampSheetLogRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(CountIssueStampSheetLogRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/log/issue/stamp/sheet/count";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.Service != null) {
sessionRequest.AddQueryString("service", $"{request.Service}");
}
if (request.Method != null) {
sessionRequest.AddQueryString("method", $"{request.Method}");
}
if (request.UserId != null) {
sessionRequest.AddQueryString("userId", $"{request.UserId}");
}
if (request.Action != null) {
sessionRequest.AddQueryString("action", $"{request.Action}");
}
if (request.Begin != null) {
sessionRequest.AddQueryString("begin", $"{request.Begin}");
}
if (request.End != null) {
sessionRequest.AddQueryString("end", $"{request.End}");
}
if (request.LongTerm != null) {
sessionRequest.AddQueryString("longTerm", $"{request.LongTerm}");
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CountIssueStampSheetLog(
Request.CountIssueStampSheetLogRequest request,
UnityAction<AsyncResult<Result.CountIssueStampSheetLogResult>> callback
)
{
var task = new CountIssueStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CountIssueStampSheetLogResult>(task.Result, task.Error));
}
public IFuture<Result.CountIssueStampSheetLogResult> CountIssueStampSheetLogFuture(
Request.CountIssueStampSheetLogRequest request
)
{
return new CountIssueStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CountIssueStampSheetLogResult> CountIssueStampSheetLogAsync(
Request.CountIssueStampSheetLogRequest request
)
{
AsyncResult<Result.CountIssueStampSheetLogResult> result = null;
await CountIssueStampSheetLog(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public CountIssueStampSheetLogTask CountIssueStampSheetLogAsync(
Request.CountIssueStampSheetLogRequest request
)
{
return new CountIssueStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.CountIssueStampSheetLogResult> CountIssueStampSheetLogAsync(
Request.CountIssueStampSheetLogRequest request
)
{
var task = new CountIssueStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class QueryExecuteStampSheetLogTask : Gs2RestSessionTask<QueryExecuteStampSheetLogRequest, QueryExecuteStampSheetLogResult>
{
public QueryExecuteStampSheetLogTask(IGs2Session session, RestSessionRequestFactory factory, QueryExecuteStampSheetLogRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(QueryExecuteStampSheetLogRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/log/execute/stamp/sheet";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.Service != null) {
sessionRequest.AddQueryString("service", $"{request.Service}");
}
if (request.Method != null) {
sessionRequest.AddQueryString("method", $"{request.Method}");
}
if (request.UserId != null) {
sessionRequest.AddQueryString("userId", $"{request.UserId}");
}
if (request.Action != null) {
sessionRequest.AddQueryString("action", $"{request.Action}");
}
if (request.Begin != null) {
sessionRequest.AddQueryString("begin", $"{request.Begin}");
}
if (request.End != null) {
sessionRequest.AddQueryString("end", $"{request.End}");
}
if (request.LongTerm != null) {
sessionRequest.AddQueryString("longTerm", $"{request.LongTerm}");
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator QueryExecuteStampSheetLog(
Request.QueryExecuteStampSheetLogRequest request,
UnityAction<AsyncResult<Result.QueryExecuteStampSheetLogResult>> callback
)
{
var task = new QueryExecuteStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.QueryExecuteStampSheetLogResult>(task.Result, task.Error));
}
public IFuture<Result.QueryExecuteStampSheetLogResult> QueryExecuteStampSheetLogFuture(
Request.QueryExecuteStampSheetLogRequest request
)
{
return new QueryExecuteStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.QueryExecuteStampSheetLogResult> QueryExecuteStampSheetLogAsync(
Request.QueryExecuteStampSheetLogRequest request
)
{
AsyncResult<Result.QueryExecuteStampSheetLogResult> result = null;
await QueryExecuteStampSheetLog(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public QueryExecuteStampSheetLogTask QueryExecuteStampSheetLogAsync(
Request.QueryExecuteStampSheetLogRequest request
)
{
return new QueryExecuteStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.QueryExecuteStampSheetLogResult> QueryExecuteStampSheetLogAsync(
Request.QueryExecuteStampSheetLogRequest request
)
{
var task = new QueryExecuteStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class CountExecuteStampSheetLogTask : Gs2RestSessionTask<CountExecuteStampSheetLogRequest, CountExecuteStampSheetLogResult>
{
public CountExecuteStampSheetLogTask(IGs2Session session, RestSessionRequestFactory factory, CountExecuteStampSheetLogRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(CountExecuteStampSheetLogRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/log/execute/stamp/sheet/count";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.Service != null) {
sessionRequest.AddQueryString("service", $"{request.Service}");
}
if (request.Method != null) {
sessionRequest.AddQueryString("method", $"{request.Method}");
}
if (request.UserId != null) {
sessionRequest.AddQueryString("userId", $"{request.UserId}");
}
if (request.Action != null) {
sessionRequest.AddQueryString("action", $"{request.Action}");
}
if (request.Begin != null) {
sessionRequest.AddQueryString("begin", $"{request.Begin}");
}
if (request.End != null) {
sessionRequest.AddQueryString("end", $"{request.End}");
}
if (request.LongTerm != null) {
sessionRequest.AddQueryString("longTerm", $"{request.LongTerm}");
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CountExecuteStampSheetLog(
Request.CountExecuteStampSheetLogRequest request,
UnityAction<AsyncResult<Result.CountExecuteStampSheetLogResult>> callback
)
{
var task = new CountExecuteStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CountExecuteStampSheetLogResult>(task.Result, task.Error));
}
public IFuture<Result.CountExecuteStampSheetLogResult> CountExecuteStampSheetLogFuture(
Request.CountExecuteStampSheetLogRequest request
)
{
return new CountExecuteStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CountExecuteStampSheetLogResult> CountExecuteStampSheetLogAsync(
Request.CountExecuteStampSheetLogRequest request
)
{
AsyncResult<Result.CountExecuteStampSheetLogResult> result = null;
await CountExecuteStampSheetLog(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public CountExecuteStampSheetLogTask CountExecuteStampSheetLogAsync(
Request.CountExecuteStampSheetLogRequest request
)
{
return new CountExecuteStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.CountExecuteStampSheetLogResult> CountExecuteStampSheetLogAsync(
Request.CountExecuteStampSheetLogRequest request
)
{
var task = new CountExecuteStampSheetLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class QueryExecuteStampTaskLogTask : Gs2RestSessionTask<QueryExecuteStampTaskLogRequest, QueryExecuteStampTaskLogResult>
{
public QueryExecuteStampTaskLogTask(IGs2Session session, RestSessionRequestFactory factory, QueryExecuteStampTaskLogRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(QueryExecuteStampTaskLogRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/log/execute/stamp/task";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.Service != null) {
sessionRequest.AddQueryString("service", $"{request.Service}");
}
if (request.Method != null) {
sessionRequest.AddQueryString("method", $"{request.Method}");
}
if (request.UserId != null) {
sessionRequest.AddQueryString("userId", $"{request.UserId}");
}
if (request.Action != null) {
sessionRequest.AddQueryString("action", $"{request.Action}");
}
if (request.Begin != null) {
sessionRequest.AddQueryString("begin", $"{request.Begin}");
}
if (request.End != null) {
sessionRequest.AddQueryString("end", $"{request.End}");
}
if (request.LongTerm != null) {
sessionRequest.AddQueryString("longTerm", $"{request.LongTerm}");
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator QueryExecuteStampTaskLog(
Request.QueryExecuteStampTaskLogRequest request,
UnityAction<AsyncResult<Result.QueryExecuteStampTaskLogResult>> callback
)
{
var task = new QueryExecuteStampTaskLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.QueryExecuteStampTaskLogResult>(task.Result, task.Error));
}
public IFuture<Result.QueryExecuteStampTaskLogResult> QueryExecuteStampTaskLogFuture(
Request.QueryExecuteStampTaskLogRequest request
)
{
return new QueryExecuteStampTaskLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.QueryExecuteStampTaskLogResult> QueryExecuteStampTaskLogAsync(
Request.QueryExecuteStampTaskLogRequest request
)
{
AsyncResult<Result.QueryExecuteStampTaskLogResult> result = null;
await QueryExecuteStampTaskLog(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public QueryExecuteStampTaskLogTask QueryExecuteStampTaskLogAsync(
Request.QueryExecuteStampTaskLogRequest request
)
{
return new QueryExecuteStampTaskLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.QueryExecuteStampTaskLogResult> QueryExecuteStampTaskLogAsync(
Request.QueryExecuteStampTaskLogRequest request
)
{
var task = new QueryExecuteStampTaskLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class CountExecuteStampTaskLogTask : Gs2RestSessionTask<CountExecuteStampTaskLogRequest, CountExecuteStampTaskLogResult>
{
public CountExecuteStampTaskLogTask(IGs2Session session, RestSessionRequestFactory factory, CountExecuteStampTaskLogRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(CountExecuteStampTaskLogRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/log/execute/stamp/task/count";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.Service != null) {
sessionRequest.AddQueryString("service", $"{request.Service}");
}
if (request.Method != null) {
sessionRequest.AddQueryString("method", $"{request.Method}");
}
if (request.UserId != null) {
sessionRequest.AddQueryString("userId", $"{request.UserId}");
}
if (request.Action != null) {
sessionRequest.AddQueryString("action", $"{request.Action}");
}
if (request.Begin != null) {
sessionRequest.AddQueryString("begin", $"{request.Begin}");
}
if (request.End != null) {
sessionRequest.AddQueryString("end", $"{request.End}");
}
if (request.LongTerm != null) {
sessionRequest.AddQueryString("longTerm", $"{request.LongTerm}");
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CountExecuteStampTaskLog(
Request.CountExecuteStampTaskLogRequest request,
UnityAction<AsyncResult<Result.CountExecuteStampTaskLogResult>> callback
)
{
var task = new CountExecuteStampTaskLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CountExecuteStampTaskLogResult>(task.Result, task.Error));
}
public IFuture<Result.CountExecuteStampTaskLogResult> CountExecuteStampTaskLogFuture(
Request.CountExecuteStampTaskLogRequest request
)
{
return new CountExecuteStampTaskLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CountExecuteStampTaskLogResult> CountExecuteStampTaskLogAsync(
Request.CountExecuteStampTaskLogRequest request
)
{
AsyncResult<Result.CountExecuteStampTaskLogResult> result = null;
await CountExecuteStampTaskLog(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public CountExecuteStampTaskLogTask CountExecuteStampTaskLogAsync(
Request.CountExecuteStampTaskLogRequest request
)
{
return new CountExecuteStampTaskLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.CountExecuteStampTaskLogResult> CountExecuteStampTaskLogAsync(
Request.CountExecuteStampTaskLogRequest request
)
{
var task = new CountExecuteStampTaskLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class QueryInGameLogTask : Gs2RestSessionTask<QueryInGameLogRequest, QueryInGameLogResult>
{
public QueryInGameLogTask(IGs2Session session, RestSessionRequestFactory factory, QueryInGameLogRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(QueryInGameLogRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/ingame/log";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Post(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId);
}
if (request.Tags != null)
{
jsonWriter.WritePropertyName("tags");
jsonWriter.WriteArrayStart();
foreach(var item in request.Tags)
{
item.WriteJson(jsonWriter);
}
jsonWriter.WriteArrayEnd();
}
if (request.Begin != null)
{
jsonWriter.WritePropertyName("begin");
jsonWriter.Write(request.Begin.ToString());
}
if (request.End != null)
{
jsonWriter.WritePropertyName("end");
jsonWriter.Write(request.End.ToString());
}
if (request.LongTerm != null)
{
jsonWriter.WritePropertyName("longTerm");
jsonWriter.Write(request.LongTerm.ToString());
}
if (request.PageToken != null)
{
jsonWriter.WritePropertyName("pageToken");
jsonWriter.Write(request.PageToken);
}
if (request.Limit != null)
{
jsonWriter.WritePropertyName("limit");
jsonWriter.Write(request.Limit.ToString());
}
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.DuplicationAvoider != null)
{
sessionRequest.AddHeader("X-GS2-DUPLICATION-AVOIDER", request.DuplicationAvoider);
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator QueryInGameLog(
Request.QueryInGameLogRequest request,
UnityAction<AsyncResult<Result.QueryInGameLogResult>> callback
)
{
var task = new QueryInGameLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.QueryInGameLogResult>(task.Result, task.Error));
}
public IFuture<Result.QueryInGameLogResult> QueryInGameLogFuture(
Request.QueryInGameLogRequest request
)
{
return new QueryInGameLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.QueryInGameLogResult> QueryInGameLogAsync(
Request.QueryInGameLogRequest request
)
{
AsyncResult<Result.QueryInGameLogResult> result = null;
await QueryInGameLog(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public QueryInGameLogTask QueryInGameLogAsync(
Request.QueryInGameLogRequest request
)
{
return new QueryInGameLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.QueryInGameLogResult> QueryInGameLogAsync(
Request.QueryInGameLogRequest request
)
{
var task = new QueryInGameLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class SendInGameLogTask : Gs2RestSessionTask<SendInGameLogRequest, SendInGameLogResult>
{
public SendInGameLogTask(IGs2Session session, RestSessionRequestFactory factory, SendInGameLogRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(SendInGameLogRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/ingame/log/user/me/send";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Post(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.Tags != null)
{
jsonWriter.WritePropertyName("tags");
jsonWriter.WriteArrayStart();
foreach(var item in request.Tags)
{
item.WriteJson(jsonWriter);
}
jsonWriter.WriteArrayEnd();
}
if (request.Payload != null)
{
jsonWriter.WritePropertyName("payload");
jsonWriter.Write(request.Payload);
}
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.AccessToken != null)
{
sessionRequest.AddHeader("X-GS2-ACCESS-TOKEN", request.AccessToken);
}
if (request.DuplicationAvoider != null)
{
sessionRequest.AddHeader("X-GS2-DUPLICATION-AVOIDER", request.DuplicationAvoider);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator SendInGameLog(
Request.SendInGameLogRequest request,
UnityAction<AsyncResult<Result.SendInGameLogResult>> callback
)
{
var task = new SendInGameLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.SendInGameLogResult>(task.Result, task.Error));
}
public IFuture<Result.SendInGameLogResult> SendInGameLogFuture(
Request.SendInGameLogRequest request
)
{
return new SendInGameLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.SendInGameLogResult> SendInGameLogAsync(
Request.SendInGameLogRequest request
)
{
AsyncResult<Result.SendInGameLogResult> result = null;
await SendInGameLog(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public SendInGameLogTask SendInGameLogAsync(
Request.SendInGameLogRequest request
)
{
return new SendInGameLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.SendInGameLogResult> SendInGameLogAsync(
Request.SendInGameLogRequest request
)
{
var task = new SendInGameLogTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class SendInGameLogByUserIdTask : Gs2RestSessionTask<SendInGameLogByUserIdRequest, SendInGameLogByUserIdResult>
{
public SendInGameLogByUserIdTask(IGs2Session session, RestSessionRequestFactory factory, SendInGameLogByUserIdRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(SendInGameLogByUserIdRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/ingame/log/user/{userId}/send";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
url = url.Replace("{userId}", !string.IsNullOrEmpty(request.UserId) ? request.UserId.ToString() : "null");
var sessionRequest = Factory.Post(url);
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.Tags != null)
{
jsonWriter.WritePropertyName("tags");
jsonWriter.WriteArrayStart();
foreach(var item in request.Tags)
{
item.WriteJson(jsonWriter);
}
jsonWriter.WriteArrayEnd();
}
if (request.Payload != null)
{
jsonWriter.WritePropertyName("payload");
jsonWriter.Write(request.Payload);
}
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.DuplicationAvoider != null)
{
sessionRequest.AddHeader("X-GS2-DUPLICATION-AVOIDER", request.DuplicationAvoider);
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator SendInGameLogByUserId(
Request.SendInGameLogByUserIdRequest request,
UnityAction<AsyncResult<Result.SendInGameLogByUserIdResult>> callback
)
{
var task = new SendInGameLogByUserIdTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.SendInGameLogByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.SendInGameLogByUserIdResult> SendInGameLogByUserIdFuture(
Request.SendInGameLogByUserIdRequest request
)
{
return new SendInGameLogByUserIdTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.SendInGameLogByUserIdResult> SendInGameLogByUserIdAsync(
Request.SendInGameLogByUserIdRequest request
)
{
AsyncResult<Result.SendInGameLogByUserIdResult> result = null;
await SendInGameLogByUserId(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public SendInGameLogByUserIdTask SendInGameLogByUserIdAsync(
Request.SendInGameLogByUserIdRequest request
)
{
return new SendInGameLogByUserIdTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.SendInGameLogByUserIdResult> SendInGameLogByUserIdAsync(
Request.SendInGameLogByUserIdRequest request
)
{
var task = new SendInGameLogByUserIdTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class QueryAccessLogWithTelemetryTask : Gs2RestSessionTask<QueryAccessLogWithTelemetryRequest, QueryAccessLogWithTelemetryResult>
{
public QueryAccessLogWithTelemetryTask(IGs2Session session, RestSessionRequestFactory factory, QueryAccessLogWithTelemetryRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(QueryAccessLogWithTelemetryRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/log/access/telemetry";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
var sessionRequest = Factory.Get(url);
if (request.ContextStack != null)
{
sessionRequest.AddQueryString("contextStack", request.ContextStack);
}
if (request.UserId != null) {
sessionRequest.AddQueryString("userId", $"{request.UserId}");
}
if (request.Begin != null) {
sessionRequest.AddQueryString("begin", $"{request.Begin}");
}
if (request.End != null) {
sessionRequest.AddQueryString("end", $"{request.End}");
}
if (request.LongTerm != null) {
sessionRequest.AddQueryString("longTerm", $"{request.LongTerm}");
}
if (request.PageToken != null) {
sessionRequest.AddQueryString("pageToken", $"{request.PageToken}");
}
if (request.Limit != null) {
sessionRequest.AddQueryString("limit", $"{request.Limit}");
}
if (request.TimeOffsetToken != null)
{
sessionRequest.AddHeader("X-GS2-TIME-OFFSET-TOKEN", request.TimeOffsetToken);
}
if (request.DryRun)
{
sessionRequest.AddHeader("X-GS2-DRY-RUN", "true");
}
AddHeader(
Session.Credential,
sessionRequest
);
return sessionRequest;
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator QueryAccessLogWithTelemetry(
Request.QueryAccessLogWithTelemetryRequest request,
UnityAction<AsyncResult<Result.QueryAccessLogWithTelemetryResult>> callback
)
{
var task = new QueryAccessLogWithTelemetryTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.QueryAccessLogWithTelemetryResult>(task.Result, task.Error));
}
public IFuture<Result.QueryAccessLogWithTelemetryResult> QueryAccessLogWithTelemetryFuture(
Request.QueryAccessLogWithTelemetryRequest request
)
{
return new QueryAccessLogWithTelemetryTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.QueryAccessLogWithTelemetryResult> QueryAccessLogWithTelemetryAsync(
Request.QueryAccessLogWithTelemetryRequest request
)
{
AsyncResult<Result.QueryAccessLogWithTelemetryResult> result = null;
await QueryAccessLogWithTelemetry(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public QueryAccessLogWithTelemetryTask QueryAccessLogWithTelemetryAsync(
Request.QueryAccessLogWithTelemetryRequest request
)
{
return new QueryAccessLogWithTelemetryTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.QueryAccessLogWithTelemetryResult> QueryAccessLogWithTelemetryAsync(
Request.QueryAccessLogWithTelemetryRequest request
)
{
var task = new QueryAccessLogWithTelemetryTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class DescribeInsightsTask : Gs2RestSessionTask<DescribeInsightsRequest, DescribeInsightsResult>
{
public DescribeInsightsTask(IGs2Session session, RestSessionRequestFactory factory, DescribeInsightsRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DescribeInsightsRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/insight";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.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 DescribeInsights(
Request.DescribeInsightsRequest request,
UnityAction<AsyncResult<Result.DescribeInsightsResult>> callback
)
{
var task = new DescribeInsightsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DescribeInsightsResult>(task.Result, task.Error));
}
public IFuture<Result.DescribeInsightsResult> DescribeInsightsFuture(
Request.DescribeInsightsRequest request
)
{
return new DescribeInsightsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DescribeInsightsResult> DescribeInsightsAsync(
Request.DescribeInsightsRequest request
)
{
AsyncResult<Result.DescribeInsightsResult> result = null;
await DescribeInsights(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DescribeInsightsTask DescribeInsightsAsync(
Request.DescribeInsightsRequest request
)
{
return new DescribeInsightsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DescribeInsightsResult> DescribeInsightsAsync(
Request.DescribeInsightsRequest request
)
{
var task = new DescribeInsightsTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class CreateInsightTask : Gs2RestSessionTask<CreateInsightRequest, CreateInsightResult>
{
public CreateInsightTask(IGs2Session session, RestSessionRequestFactory factory, CreateInsightRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(CreateInsightRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/insight";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.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 CreateInsight(
Request.CreateInsightRequest request,
UnityAction<AsyncResult<Result.CreateInsightResult>> callback
)
{
var task = new CreateInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CreateInsightResult>(task.Result, task.Error));
}
public IFuture<Result.CreateInsightResult> CreateInsightFuture(
Request.CreateInsightRequest request
)
{
return new CreateInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CreateInsightResult> CreateInsightAsync(
Request.CreateInsightRequest request
)
{
AsyncResult<Result.CreateInsightResult> result = null;
await CreateInsight(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public CreateInsightTask CreateInsightAsync(
Request.CreateInsightRequest request
)
{
return new CreateInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.CreateInsightResult> CreateInsightAsync(
Request.CreateInsightRequest request
)
{
var task = new CreateInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class GetInsightTask : Gs2RestSessionTask<GetInsightRequest, GetInsightResult>
{
public GetInsightTask(IGs2Session session, RestSessionRequestFactory factory, GetInsightRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(GetInsightRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/insight/{insightName}";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
url = url.Replace("{insightName}", !string.IsNullOrEmpty(request.InsightName) ? request.InsightName.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 GetInsight(
Request.GetInsightRequest request,
UnityAction<AsyncResult<Result.GetInsightResult>> callback
)
{
var task = new GetInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetInsightResult>(task.Result, task.Error));
}
public IFuture<Result.GetInsightResult> GetInsightFuture(
Request.GetInsightRequest request
)
{
return new GetInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetInsightResult> GetInsightAsync(
Request.GetInsightRequest request
)
{
AsyncResult<Result.GetInsightResult> result = null;
await GetInsight(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public GetInsightTask GetInsightAsync(
Request.GetInsightRequest request
)
{
return new GetInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.GetInsightResult> GetInsightAsync(
Request.GetInsightRequest request
)
{
var task = new GetInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
public class DeleteInsightTask : Gs2RestSessionTask<DeleteInsightRequest, DeleteInsightResult>
{
public DeleteInsightTask(IGs2Session session, RestSessionRequestFactory factory, DeleteInsightRequest request) : base(session, factory, request)
{
}
protected override IGs2SessionRequest CreateRequest(DeleteInsightRequest request)
{
var url = Gs2RestSession.EndpointHost
.Replace("{service}", "log")
.Replace("{region}", Session.Region.DisplayName())
+ "/{namespaceName}/insight/{insightName}";
url = url.Replace("{namespaceName}", !string.IsNullOrEmpty(request.NamespaceName) ? request.NamespaceName.ToString() : "null");
url = url.Replace("{insightName}", !string.IsNullOrEmpty(request.InsightName) ? request.InsightName.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 DeleteInsight(
Request.DeleteInsightRequest request,
UnityAction<AsyncResult<Result.DeleteInsightResult>> callback
)
{
var task = new DeleteInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteInsightResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteInsightResult> DeleteInsightFuture(
Request.DeleteInsightRequest request
)
{
return new DeleteInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteInsightResult> DeleteInsightAsync(
Request.DeleteInsightRequest request
)
{
AsyncResult<Result.DeleteInsightResult> result = null;
await DeleteInsight(
request,
r => result = r
);
if (result.Error != null)
{
throw result.Error;
}
return result.Result;
}
#else
public DeleteInsightTask DeleteInsightAsync(
Request.DeleteInsightRequest request
)
{
return new DeleteInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new UnityRestSessionRequest(_certificateHandler)),
request
);
}
#endif
#else
public async Task<Result.DeleteInsightResult> DeleteInsightAsync(
Request.DeleteInsightRequest request
)
{
var task = new DeleteInsightTask(
Gs2RestSession,
new RestSessionRequestFactory(() => new DotNetRestSessionRequest()),
request
);
return await task.Invoke();
}
#endif
}
}