Repository URL to install this package:
Version:
2025.4.10 ▾
|
/*
* Copyright 2016 Game Server Services, Inc. or its affiliates. All Rights
* Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* or in the "license" file accompanying this file. This file is distributed
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
#pragma warning disable CS0618 // Obsolete with a message
using System;
using System.Collections.Generic;
using System.Text;
using System.Linq;
using Gs2.Core;
using Gs2.Core.Model;
using Gs2.Core.Net;
using Gs2.Util.LitJson;
#if UNITY_2017_1_OR_NEWER
using System.Collections;
using UnityEngine.Events;
using UnityEngine.Networking;
#if GS2_ENABLE_UNITASK
using Cysharp.Threading.Tasks;
#endif
#else
using System.Threading.Tasks;
using System.Threading;
#endif
namespace Gs2.Gs2Schedule
{
public class Gs2ScheduleWebSocketClient : AbstractGs2Client
{
public static string Endpoint = "schedule";
protected Gs2WebSocketSession Gs2WebSocketSession => (Gs2WebSocketSession) Gs2Session;
public Gs2ScheduleWebSocketClient(Gs2WebSocketSession Gs2WebSocketSession) : base(Gs2WebSocketSession)
{
}
public class CreateNamespaceTask : Gs2WebSocketSessionTask<Request.CreateNamespaceRequest, Result.CreateNamespaceResult>
{
public CreateNamespaceTask(IGs2Session session, Request.CreateNamespaceRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CreateNamespaceRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.Name != null)
{
jsonWriter.WritePropertyName("name");
jsonWriter.Write(request.Name.ToString());
}
if (request.Description != null)
{
jsonWriter.WritePropertyName("description");
jsonWriter.Write(request.Description.ToString());
}
if (request.LogSetting != null)
{
jsonWriter.WritePropertyName("logSetting");
request.LogSetting.WriteJson(jsonWriter);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"createNamespace",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CreateNamespace(
Request.CreateNamespaceRequest request,
UnityAction<AsyncResult<Result.CreateNamespaceResult>> callback
)
{
var task = new CreateNamespaceTask(
Gs2WebSocketSession,
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(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CreateNamespaceResult> CreateNamespaceAsync(
Request.CreateNamespaceRequest request
)
{
var task = new CreateNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CreateNamespaceTask CreateNamespaceAsync(
Request.CreateNamespaceRequest request
)
{
return new CreateNamespaceTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CreateNamespaceResult> CreateNamespaceAsync(
Request.CreateNamespaceRequest request
)
{
var task = new CreateNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetNamespaceStatusTask : Gs2WebSocketSessionTask<Request.GetNamespaceStatusRequest, Result.GetNamespaceStatusResult>
{
public GetNamespaceStatusTask(IGs2Session session, Request.GetNamespaceStatusRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetNamespaceStatusRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"getNamespaceStatus",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetNamespaceStatus(
Request.GetNamespaceStatusRequest request,
UnityAction<AsyncResult<Result.GetNamespaceStatusResult>> callback
)
{
var task = new GetNamespaceStatusTask(
Gs2WebSocketSession,
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(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetNamespaceStatusResult> GetNamespaceStatusAsync(
Request.GetNamespaceStatusRequest request
)
{
var task = new GetNamespaceStatusTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetNamespaceStatusTask GetNamespaceStatusAsync(
Request.GetNamespaceStatusRequest request
)
{
return new GetNamespaceStatusTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetNamespaceStatusResult> GetNamespaceStatusAsync(
Request.GetNamespaceStatusRequest request
)
{
var task = new GetNamespaceStatusTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetNamespaceTask : Gs2WebSocketSessionTask<Request.GetNamespaceRequest, Result.GetNamespaceResult>
{
public GetNamespaceTask(IGs2Session session, Request.GetNamespaceRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetNamespaceRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"getNamespace",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetNamespace(
Request.GetNamespaceRequest request,
UnityAction<AsyncResult<Result.GetNamespaceResult>> callback
)
{
var task = new GetNamespaceTask(
Gs2WebSocketSession,
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(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetNamespaceResult> GetNamespaceAsync(
Request.GetNamespaceRequest request
)
{
var task = new GetNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetNamespaceTask GetNamespaceAsync(
Request.GetNamespaceRequest request
)
{
return new GetNamespaceTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetNamespaceResult> GetNamespaceAsync(
Request.GetNamespaceRequest request
)
{
var task = new GetNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class UpdateNamespaceTask : Gs2WebSocketSessionTask<Request.UpdateNamespaceRequest, Result.UpdateNamespaceResult>
{
public UpdateNamespaceTask(IGs2Session session, Request.UpdateNamespaceRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.UpdateNamespaceRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.Description != null)
{
jsonWriter.WritePropertyName("description");
jsonWriter.Write(request.Description.ToString());
}
if (request.LogSetting != null)
{
jsonWriter.WritePropertyName("logSetting");
request.LogSetting.WriteJson(jsonWriter);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"updateNamespace",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator UpdateNamespace(
Request.UpdateNamespaceRequest request,
UnityAction<AsyncResult<Result.UpdateNamespaceResult>> callback
)
{
var task = new UpdateNamespaceTask(
Gs2WebSocketSession,
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(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UpdateNamespaceResult> UpdateNamespaceAsync(
Request.UpdateNamespaceRequest request
)
{
var task = new UpdateNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public UpdateNamespaceTask UpdateNamespaceAsync(
Request.UpdateNamespaceRequest request
)
{
return new UpdateNamespaceTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.UpdateNamespaceResult> UpdateNamespaceAsync(
Request.UpdateNamespaceRequest request
)
{
var task = new UpdateNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DeleteNamespaceTask : Gs2WebSocketSessionTask<Request.DeleteNamespaceRequest, Result.DeleteNamespaceResult>
{
public DeleteNamespaceTask(IGs2Session session, Request.DeleteNamespaceRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DeleteNamespaceRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"deleteNamespace",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteNamespace(
Request.DeleteNamespaceRequest request,
UnityAction<AsyncResult<Result.DeleteNamespaceResult>> callback
)
{
var task = new DeleteNamespaceTask(
Gs2WebSocketSession,
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(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteNamespaceResult> DeleteNamespaceAsync(
Request.DeleteNamespaceRequest request
)
{
var task = new DeleteNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DeleteNamespaceTask DeleteNamespaceAsync(
Request.DeleteNamespaceRequest request
)
{
return new DeleteNamespaceTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DeleteNamespaceResult> DeleteNamespaceAsync(
Request.DeleteNamespaceRequest request
)
{
var task = new DeleteNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DumpUserDataByUserIdTask : Gs2WebSocketSessionTask<Request.DumpUserDataByUserIdRequest, Result.DumpUserDataByUserIdResult>
{
public DumpUserDataByUserIdTask(IGs2Session session, Request.DumpUserDataByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DumpUserDataByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"dumpUserDataByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DumpUserDataByUserId(
Request.DumpUserDataByUserIdRequest request,
UnityAction<AsyncResult<Result.DumpUserDataByUserIdResult>> callback
)
{
var task = new DumpUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DumpUserDataByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.DumpUserDataByUserIdResult> DumpUserDataByUserIdFuture(
Request.DumpUserDataByUserIdRequest request
)
{
return new DumpUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DumpUserDataByUserIdResult> DumpUserDataByUserIdAsync(
Request.DumpUserDataByUserIdRequest request
)
{
var task = new DumpUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DumpUserDataByUserIdTask DumpUserDataByUserIdAsync(
Request.DumpUserDataByUserIdRequest request
)
{
return new DumpUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DumpUserDataByUserIdResult> DumpUserDataByUserIdAsync(
Request.DumpUserDataByUserIdRequest request
)
{
var task = new DumpUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class CheckDumpUserDataByUserIdTask : Gs2WebSocketSessionTask<Request.CheckDumpUserDataByUserIdRequest, Result.CheckDumpUserDataByUserIdResult>
{
public CheckDumpUserDataByUserIdTask(IGs2Session session, Request.CheckDumpUserDataByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CheckDumpUserDataByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"checkDumpUserDataByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CheckDumpUserDataByUserId(
Request.CheckDumpUserDataByUserIdRequest request,
UnityAction<AsyncResult<Result.CheckDumpUserDataByUserIdResult>> callback
)
{
var task = new CheckDumpUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CheckDumpUserDataByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.CheckDumpUserDataByUserIdResult> CheckDumpUserDataByUserIdFuture(
Request.CheckDumpUserDataByUserIdRequest request
)
{
return new CheckDumpUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CheckDumpUserDataByUserIdResult> CheckDumpUserDataByUserIdAsync(
Request.CheckDumpUserDataByUserIdRequest request
)
{
var task = new CheckDumpUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CheckDumpUserDataByUserIdTask CheckDumpUserDataByUserIdAsync(
Request.CheckDumpUserDataByUserIdRequest request
)
{
return new CheckDumpUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CheckDumpUserDataByUserIdResult> CheckDumpUserDataByUserIdAsync(
Request.CheckDumpUserDataByUserIdRequest request
)
{
var task = new CheckDumpUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class CleanUserDataByUserIdTask : Gs2WebSocketSessionTask<Request.CleanUserDataByUserIdRequest, Result.CleanUserDataByUserIdResult>
{
public CleanUserDataByUserIdTask(IGs2Session session, Request.CleanUserDataByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CleanUserDataByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"cleanUserDataByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CleanUserDataByUserId(
Request.CleanUserDataByUserIdRequest request,
UnityAction<AsyncResult<Result.CleanUserDataByUserIdResult>> callback
)
{
var task = new CleanUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CleanUserDataByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.CleanUserDataByUserIdResult> CleanUserDataByUserIdFuture(
Request.CleanUserDataByUserIdRequest request
)
{
return new CleanUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CleanUserDataByUserIdResult> CleanUserDataByUserIdAsync(
Request.CleanUserDataByUserIdRequest request
)
{
var task = new CleanUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CleanUserDataByUserIdTask CleanUserDataByUserIdAsync(
Request.CleanUserDataByUserIdRequest request
)
{
return new CleanUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CleanUserDataByUserIdResult> CleanUserDataByUserIdAsync(
Request.CleanUserDataByUserIdRequest request
)
{
var task = new CleanUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class CheckCleanUserDataByUserIdTask : Gs2WebSocketSessionTask<Request.CheckCleanUserDataByUserIdRequest, Result.CheckCleanUserDataByUserIdResult>
{
public CheckCleanUserDataByUserIdTask(IGs2Session session, Request.CheckCleanUserDataByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CheckCleanUserDataByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"checkCleanUserDataByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CheckCleanUserDataByUserId(
Request.CheckCleanUserDataByUserIdRequest request,
UnityAction<AsyncResult<Result.CheckCleanUserDataByUserIdResult>> callback
)
{
var task = new CheckCleanUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CheckCleanUserDataByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.CheckCleanUserDataByUserIdResult> CheckCleanUserDataByUserIdFuture(
Request.CheckCleanUserDataByUserIdRequest request
)
{
return new CheckCleanUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CheckCleanUserDataByUserIdResult> CheckCleanUserDataByUserIdAsync(
Request.CheckCleanUserDataByUserIdRequest request
)
{
var task = new CheckCleanUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CheckCleanUserDataByUserIdTask CheckCleanUserDataByUserIdAsync(
Request.CheckCleanUserDataByUserIdRequest request
)
{
return new CheckCleanUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CheckCleanUserDataByUserIdResult> CheckCleanUserDataByUserIdAsync(
Request.CheckCleanUserDataByUserIdRequest request
)
{
var task = new CheckCleanUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class PrepareImportUserDataByUserIdTask : Gs2WebSocketSessionTask<Request.PrepareImportUserDataByUserIdRequest, Result.PrepareImportUserDataByUserIdResult>
{
public PrepareImportUserDataByUserIdTask(IGs2Session session, Request.PrepareImportUserDataByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.PrepareImportUserDataByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"prepareImportUserDataByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator PrepareImportUserDataByUserId(
Request.PrepareImportUserDataByUserIdRequest request,
UnityAction<AsyncResult<Result.PrepareImportUserDataByUserIdResult>> callback
)
{
var task = new PrepareImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.PrepareImportUserDataByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.PrepareImportUserDataByUserIdResult> PrepareImportUserDataByUserIdFuture(
Request.PrepareImportUserDataByUserIdRequest request
)
{
return new PrepareImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.PrepareImportUserDataByUserIdResult> PrepareImportUserDataByUserIdAsync(
Request.PrepareImportUserDataByUserIdRequest request
)
{
var task = new PrepareImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public PrepareImportUserDataByUserIdTask PrepareImportUserDataByUserIdAsync(
Request.PrepareImportUserDataByUserIdRequest request
)
{
return new PrepareImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.PrepareImportUserDataByUserIdResult> PrepareImportUserDataByUserIdAsync(
Request.PrepareImportUserDataByUserIdRequest request
)
{
var task = new PrepareImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class ImportUserDataByUserIdTask : Gs2WebSocketSessionTask<Request.ImportUserDataByUserIdRequest, Result.ImportUserDataByUserIdResult>
{
public ImportUserDataByUserIdTask(IGs2Session session, Request.ImportUserDataByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.ImportUserDataByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.UploadToken != null)
{
jsonWriter.WritePropertyName("uploadToken");
jsonWriter.Write(request.UploadToken.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"importUserDataByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator ImportUserDataByUserId(
Request.ImportUserDataByUserIdRequest request,
UnityAction<AsyncResult<Result.ImportUserDataByUserIdResult>> callback
)
{
var task = new ImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.ImportUserDataByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.ImportUserDataByUserIdResult> ImportUserDataByUserIdFuture(
Request.ImportUserDataByUserIdRequest request
)
{
return new ImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.ImportUserDataByUserIdResult> ImportUserDataByUserIdAsync(
Request.ImportUserDataByUserIdRequest request
)
{
var task = new ImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public ImportUserDataByUserIdTask ImportUserDataByUserIdAsync(
Request.ImportUserDataByUserIdRequest request
)
{
return new ImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.ImportUserDataByUserIdResult> ImportUserDataByUserIdAsync(
Request.ImportUserDataByUserIdRequest request
)
{
var task = new ImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class CheckImportUserDataByUserIdTask : Gs2WebSocketSessionTask<Request.CheckImportUserDataByUserIdRequest, Result.CheckImportUserDataByUserIdResult>
{
public CheckImportUserDataByUserIdTask(IGs2Session session, Request.CheckImportUserDataByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CheckImportUserDataByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.UploadToken != null)
{
jsonWriter.WritePropertyName("uploadToken");
jsonWriter.Write(request.UploadToken.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"namespace",
"checkImportUserDataByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CheckImportUserDataByUserId(
Request.CheckImportUserDataByUserIdRequest request,
UnityAction<AsyncResult<Result.CheckImportUserDataByUserIdResult>> callback
)
{
var task = new CheckImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CheckImportUserDataByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.CheckImportUserDataByUserIdResult> CheckImportUserDataByUserIdFuture(
Request.CheckImportUserDataByUserIdRequest request
)
{
return new CheckImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CheckImportUserDataByUserIdResult> CheckImportUserDataByUserIdAsync(
Request.CheckImportUserDataByUserIdRequest request
)
{
var task = new CheckImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CheckImportUserDataByUserIdTask CheckImportUserDataByUserIdAsync(
Request.CheckImportUserDataByUserIdRequest request
)
{
return new CheckImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CheckImportUserDataByUserIdResult> CheckImportUserDataByUserIdAsync(
Request.CheckImportUserDataByUserIdRequest request
)
{
var task = new CheckImportUserDataByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class CreateEventMasterTask : Gs2WebSocketSessionTask<Request.CreateEventMasterRequest, Result.CreateEventMasterResult>
{
public CreateEventMasterTask(IGs2Session session, Request.CreateEventMasterRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CreateEventMasterRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.Name != null)
{
jsonWriter.WritePropertyName("name");
jsonWriter.Write(request.Name.ToString());
}
if (request.Description != null)
{
jsonWriter.WritePropertyName("description");
jsonWriter.Write(request.Description.ToString());
}
if (request.Metadata != null)
{
jsonWriter.WritePropertyName("metadata");
jsonWriter.Write(request.Metadata.ToString());
}
if (request.ScheduleType != null)
{
jsonWriter.WritePropertyName("scheduleType");
jsonWriter.Write(request.ScheduleType.ToString());
}
if (request.AbsoluteBegin != null)
{
jsonWriter.WritePropertyName("absoluteBegin");
jsonWriter.Write(request.AbsoluteBegin.ToString());
}
if (request.AbsoluteEnd != null)
{
jsonWriter.WritePropertyName("absoluteEnd");
jsonWriter.Write(request.AbsoluteEnd.ToString());
}
if (request.RepeatType != null)
{
jsonWriter.WritePropertyName("repeatType");
jsonWriter.Write(request.RepeatType.ToString());
}
if (request.RepeatBeginDayOfMonth != null)
{
jsonWriter.WritePropertyName("repeatBeginDayOfMonth");
jsonWriter.Write(request.RepeatBeginDayOfMonth.ToString());
}
if (request.RepeatEndDayOfMonth != null)
{
jsonWriter.WritePropertyName("repeatEndDayOfMonth");
jsonWriter.Write(request.RepeatEndDayOfMonth.ToString());
}
if (request.RepeatBeginDayOfWeek != null)
{
jsonWriter.WritePropertyName("repeatBeginDayOfWeek");
jsonWriter.Write(request.RepeatBeginDayOfWeek.ToString());
}
if (request.RepeatEndDayOfWeek != null)
{
jsonWriter.WritePropertyName("repeatEndDayOfWeek");
jsonWriter.Write(request.RepeatEndDayOfWeek.ToString());
}
if (request.RepeatBeginHour != null)
{
jsonWriter.WritePropertyName("repeatBeginHour");
jsonWriter.Write(request.RepeatBeginHour.ToString());
}
if (request.RepeatEndHour != null)
{
jsonWriter.WritePropertyName("repeatEndHour");
jsonWriter.Write(request.RepeatEndHour.ToString());
}
if (request.RelativeTriggerName != null)
{
jsonWriter.WritePropertyName("relativeTriggerName");
jsonWriter.Write(request.RelativeTriggerName.ToString());
}
if (request.RepeatSetting != null)
{
jsonWriter.WritePropertyName("repeatSetting");
request.RepeatSetting.WriteJson(jsonWriter);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"eventMaster",
"createEventMaster",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CreateEventMaster(
Request.CreateEventMasterRequest request,
UnityAction<AsyncResult<Result.CreateEventMasterResult>> callback
)
{
var task = new CreateEventMasterTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CreateEventMasterResult>(task.Result, task.Error));
}
public IFuture<Result.CreateEventMasterResult> CreateEventMasterFuture(
Request.CreateEventMasterRequest request
)
{
return new CreateEventMasterTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CreateEventMasterResult> CreateEventMasterAsync(
Request.CreateEventMasterRequest request
)
{
var task = new CreateEventMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CreateEventMasterTask CreateEventMasterAsync(
Request.CreateEventMasterRequest request
)
{
return new CreateEventMasterTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CreateEventMasterResult> CreateEventMasterAsync(
Request.CreateEventMasterRequest request
)
{
var task = new CreateEventMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetEventMasterTask : Gs2WebSocketSessionTask<Request.GetEventMasterRequest, Result.GetEventMasterResult>
{
public GetEventMasterTask(IGs2Session session, Request.GetEventMasterRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetEventMasterRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.EventName != null)
{
jsonWriter.WritePropertyName("eventName");
jsonWriter.Write(request.EventName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"eventMaster",
"getEventMaster",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetEventMaster(
Request.GetEventMasterRequest request,
UnityAction<AsyncResult<Result.GetEventMasterResult>> callback
)
{
var task = new GetEventMasterTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetEventMasterResult>(task.Result, task.Error));
}
public IFuture<Result.GetEventMasterResult> GetEventMasterFuture(
Request.GetEventMasterRequest request
)
{
return new GetEventMasterTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetEventMasterResult> GetEventMasterAsync(
Request.GetEventMasterRequest request
)
{
var task = new GetEventMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetEventMasterTask GetEventMasterAsync(
Request.GetEventMasterRequest request
)
{
return new GetEventMasterTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetEventMasterResult> GetEventMasterAsync(
Request.GetEventMasterRequest request
)
{
var task = new GetEventMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class UpdateEventMasterTask : Gs2WebSocketSessionTask<Request.UpdateEventMasterRequest, Result.UpdateEventMasterResult>
{
public UpdateEventMasterTask(IGs2Session session, Request.UpdateEventMasterRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.UpdateEventMasterRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.EventName != null)
{
jsonWriter.WritePropertyName("eventName");
jsonWriter.Write(request.EventName.ToString());
}
if (request.Description != null)
{
jsonWriter.WritePropertyName("description");
jsonWriter.Write(request.Description.ToString());
}
if (request.Metadata != null)
{
jsonWriter.WritePropertyName("metadata");
jsonWriter.Write(request.Metadata.ToString());
}
if (request.ScheduleType != null)
{
jsonWriter.WritePropertyName("scheduleType");
jsonWriter.Write(request.ScheduleType.ToString());
}
if (request.AbsoluteBegin != null)
{
jsonWriter.WritePropertyName("absoluteBegin");
jsonWriter.Write(request.AbsoluteBegin.ToString());
}
if (request.AbsoluteEnd != null)
{
jsonWriter.WritePropertyName("absoluteEnd");
jsonWriter.Write(request.AbsoluteEnd.ToString());
}
if (request.RepeatType != null)
{
jsonWriter.WritePropertyName("repeatType");
jsonWriter.Write(request.RepeatType.ToString());
}
if (request.RepeatBeginDayOfMonth != null)
{
jsonWriter.WritePropertyName("repeatBeginDayOfMonth");
jsonWriter.Write(request.RepeatBeginDayOfMonth.ToString());
}
if (request.RepeatEndDayOfMonth != null)
{
jsonWriter.WritePropertyName("repeatEndDayOfMonth");
jsonWriter.Write(request.RepeatEndDayOfMonth.ToString());
}
if (request.RepeatBeginDayOfWeek != null)
{
jsonWriter.WritePropertyName("repeatBeginDayOfWeek");
jsonWriter.Write(request.RepeatBeginDayOfWeek.ToString());
}
if (request.RepeatEndDayOfWeek != null)
{
jsonWriter.WritePropertyName("repeatEndDayOfWeek");
jsonWriter.Write(request.RepeatEndDayOfWeek.ToString());
}
if (request.RepeatBeginHour != null)
{
jsonWriter.WritePropertyName("repeatBeginHour");
jsonWriter.Write(request.RepeatBeginHour.ToString());
}
if (request.RepeatEndHour != null)
{
jsonWriter.WritePropertyName("repeatEndHour");
jsonWriter.Write(request.RepeatEndHour.ToString());
}
if (request.RelativeTriggerName != null)
{
jsonWriter.WritePropertyName("relativeTriggerName");
jsonWriter.Write(request.RelativeTriggerName.ToString());
}
if (request.RepeatSetting != null)
{
jsonWriter.WritePropertyName("repeatSetting");
request.RepeatSetting.WriteJson(jsonWriter);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"eventMaster",
"updateEventMaster",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator UpdateEventMaster(
Request.UpdateEventMasterRequest request,
UnityAction<AsyncResult<Result.UpdateEventMasterResult>> callback
)
{
var task = new UpdateEventMasterTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.UpdateEventMasterResult>(task.Result, task.Error));
}
public IFuture<Result.UpdateEventMasterResult> UpdateEventMasterFuture(
Request.UpdateEventMasterRequest request
)
{
return new UpdateEventMasterTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UpdateEventMasterResult> UpdateEventMasterAsync(
Request.UpdateEventMasterRequest request
)
{
var task = new UpdateEventMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public UpdateEventMasterTask UpdateEventMasterAsync(
Request.UpdateEventMasterRequest request
)
{
return new UpdateEventMasterTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.UpdateEventMasterResult> UpdateEventMasterAsync(
Request.UpdateEventMasterRequest request
)
{
var task = new UpdateEventMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DeleteEventMasterTask : Gs2WebSocketSessionTask<Request.DeleteEventMasterRequest, Result.DeleteEventMasterResult>
{
public DeleteEventMasterTask(IGs2Session session, Request.DeleteEventMasterRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DeleteEventMasterRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.EventName != null)
{
jsonWriter.WritePropertyName("eventName");
jsonWriter.Write(request.EventName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"eventMaster",
"deleteEventMaster",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteEventMaster(
Request.DeleteEventMasterRequest request,
UnityAction<AsyncResult<Result.DeleteEventMasterResult>> callback
)
{
var task = new DeleteEventMasterTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteEventMasterResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteEventMasterResult> DeleteEventMasterFuture(
Request.DeleteEventMasterRequest request
)
{
return new DeleteEventMasterTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteEventMasterResult> DeleteEventMasterAsync(
Request.DeleteEventMasterRequest request
)
{
var task = new DeleteEventMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DeleteEventMasterTask DeleteEventMasterAsync(
Request.DeleteEventMasterRequest request
)
{
return new DeleteEventMasterTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DeleteEventMasterResult> DeleteEventMasterAsync(
Request.DeleteEventMasterRequest request
)
{
var task = new DeleteEventMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetTriggerTask : Gs2WebSocketSessionTask<Request.GetTriggerRequest, Result.GetTriggerResult>
{
public GetTriggerTask(IGs2Session session, Request.GetTriggerRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetTriggerRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.TriggerName != null)
{
jsonWriter.WritePropertyName("triggerName");
jsonWriter.Write(request.TriggerName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("xGs2AccessToken");
jsonWriter.Write(request.AccessToken);
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"trigger",
"getTrigger",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetTrigger(
Request.GetTriggerRequest request,
UnityAction<AsyncResult<Result.GetTriggerResult>> callback
)
{
var task = new GetTriggerTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetTriggerResult>(task.Result, task.Error));
}
public IFuture<Result.GetTriggerResult> GetTriggerFuture(
Request.GetTriggerRequest request
)
{
return new GetTriggerTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetTriggerResult> GetTriggerAsync(
Request.GetTriggerRequest request
)
{
var task = new GetTriggerTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetTriggerTask GetTriggerAsync(
Request.GetTriggerRequest request
)
{
return new GetTriggerTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetTriggerResult> GetTriggerAsync(
Request.GetTriggerRequest request
)
{
var task = new GetTriggerTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetTriggerByUserIdTask : Gs2WebSocketSessionTask<Request.GetTriggerByUserIdRequest, Result.GetTriggerByUserIdResult>
{
public GetTriggerByUserIdTask(IGs2Session session, Request.GetTriggerByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetTriggerByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TriggerName != null)
{
jsonWriter.WritePropertyName("triggerName");
jsonWriter.Write(request.TriggerName.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"trigger",
"getTriggerByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetTriggerByUserId(
Request.GetTriggerByUserIdRequest request,
UnityAction<AsyncResult<Result.GetTriggerByUserIdResult>> callback
)
{
var task = new GetTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetTriggerByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.GetTriggerByUserIdResult> GetTriggerByUserIdFuture(
Request.GetTriggerByUserIdRequest request
)
{
return new GetTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetTriggerByUserIdResult> GetTriggerByUserIdAsync(
Request.GetTriggerByUserIdRequest request
)
{
var task = new GetTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetTriggerByUserIdTask GetTriggerByUserIdAsync(
Request.GetTriggerByUserIdRequest request
)
{
return new GetTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetTriggerByUserIdResult> GetTriggerByUserIdAsync(
Request.GetTriggerByUserIdRequest request
)
{
var task = new GetTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class TriggerByUserIdTask : Gs2WebSocketSessionTask<Request.TriggerByUserIdRequest, Result.TriggerByUserIdResult>
{
public TriggerByUserIdTask(IGs2Session session, Request.TriggerByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.TriggerByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.TriggerName != null)
{
jsonWriter.WritePropertyName("triggerName");
jsonWriter.Write(request.TriggerName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TriggerStrategy != null)
{
jsonWriter.WritePropertyName("triggerStrategy");
jsonWriter.Write(request.TriggerStrategy.ToString());
}
if (request.Ttl != null)
{
jsonWriter.WritePropertyName("ttl");
jsonWriter.Write(request.Ttl.ToString());
}
if (request.EventId != null)
{
jsonWriter.WritePropertyName("eventId");
jsonWriter.Write(request.EventId.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DuplicationAvoider != null)
{
jsonWriter.WritePropertyName("xGs2DuplicationAvoider");
jsonWriter.Write(request.DuplicationAvoider);
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"trigger",
"triggerByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator TriggerByUserId(
Request.TriggerByUserIdRequest request,
UnityAction<AsyncResult<Result.TriggerByUserIdResult>> callback
)
{
var task = new TriggerByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.TriggerByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.TriggerByUserIdResult> TriggerByUserIdFuture(
Request.TriggerByUserIdRequest request
)
{
return new TriggerByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.TriggerByUserIdResult> TriggerByUserIdAsync(
Request.TriggerByUserIdRequest request
)
{
var task = new TriggerByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public TriggerByUserIdTask TriggerByUserIdAsync(
Request.TriggerByUserIdRequest request
)
{
return new TriggerByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.TriggerByUserIdResult> TriggerByUserIdAsync(
Request.TriggerByUserIdRequest request
)
{
var task = new TriggerByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class TriggerByStampSheetTask : Gs2WebSocketSessionTask<Request.TriggerByStampSheetRequest, Result.TriggerByStampSheetResult>
{
public TriggerByStampSheetTask(IGs2Session session, Request.TriggerByStampSheetRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.TriggerByStampSheetRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.StampSheet != null)
{
jsonWriter.WritePropertyName("stampSheet");
jsonWriter.Write(request.StampSheet.ToString());
}
if (request.KeyId != null)
{
jsonWriter.WritePropertyName("keyId");
jsonWriter.Write(request.KeyId.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"trigger",
"triggerByStampSheet",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator TriggerByStampSheet(
Request.TriggerByStampSheetRequest request,
UnityAction<AsyncResult<Result.TriggerByStampSheetResult>> callback
)
{
var task = new TriggerByStampSheetTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.TriggerByStampSheetResult>(task.Result, task.Error));
}
public IFuture<Result.TriggerByStampSheetResult> TriggerByStampSheetFuture(
Request.TriggerByStampSheetRequest request
)
{
return new TriggerByStampSheetTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.TriggerByStampSheetResult> TriggerByStampSheetAsync(
Request.TriggerByStampSheetRequest request
)
{
var task = new TriggerByStampSheetTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public TriggerByStampSheetTask TriggerByStampSheetAsync(
Request.TriggerByStampSheetRequest request
)
{
return new TriggerByStampSheetTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.TriggerByStampSheetResult> TriggerByStampSheetAsync(
Request.TriggerByStampSheetRequest request
)
{
var task = new TriggerByStampSheetTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DeleteTriggerTask : Gs2WebSocketSessionTask<Request.DeleteTriggerRequest, Result.DeleteTriggerResult>
{
public DeleteTriggerTask(IGs2Session session, Request.DeleteTriggerRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DeleteTriggerRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.TriggerName != null)
{
jsonWriter.WritePropertyName("triggerName");
jsonWriter.Write(request.TriggerName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("xGs2AccessToken");
jsonWriter.Write(request.AccessToken);
}
if (request.DuplicationAvoider != null)
{
jsonWriter.WritePropertyName("xGs2DuplicationAvoider");
jsonWriter.Write(request.DuplicationAvoider);
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"trigger",
"deleteTrigger",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteTrigger(
Request.DeleteTriggerRequest request,
UnityAction<AsyncResult<Result.DeleteTriggerResult>> callback
)
{
var task = new DeleteTriggerTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteTriggerResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteTriggerResult> DeleteTriggerFuture(
Request.DeleteTriggerRequest request
)
{
return new DeleteTriggerTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteTriggerResult> DeleteTriggerAsync(
Request.DeleteTriggerRequest request
)
{
var task = new DeleteTriggerTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DeleteTriggerTask DeleteTriggerAsync(
Request.DeleteTriggerRequest request
)
{
return new DeleteTriggerTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DeleteTriggerResult> DeleteTriggerAsync(
Request.DeleteTriggerRequest request
)
{
var task = new DeleteTriggerTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DeleteTriggerByUserIdTask : Gs2WebSocketSessionTask<Request.DeleteTriggerByUserIdRequest, Result.DeleteTriggerByUserIdResult>
{
public DeleteTriggerByUserIdTask(IGs2Session session, Request.DeleteTriggerByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DeleteTriggerByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TriggerName != null)
{
jsonWriter.WritePropertyName("triggerName");
jsonWriter.Write(request.TriggerName.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DuplicationAvoider != null)
{
jsonWriter.WritePropertyName("xGs2DuplicationAvoider");
jsonWriter.Write(request.DuplicationAvoider);
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"trigger",
"deleteTriggerByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteTriggerByUserId(
Request.DeleteTriggerByUserIdRequest request,
UnityAction<AsyncResult<Result.DeleteTriggerByUserIdResult>> callback
)
{
var task = new DeleteTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteTriggerByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteTriggerByUserIdResult> DeleteTriggerByUserIdFuture(
Request.DeleteTriggerByUserIdRequest request
)
{
return new DeleteTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteTriggerByUserIdResult> DeleteTriggerByUserIdAsync(
Request.DeleteTriggerByUserIdRequest request
)
{
var task = new DeleteTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DeleteTriggerByUserIdTask DeleteTriggerByUserIdAsync(
Request.DeleteTriggerByUserIdRequest request
)
{
return new DeleteTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DeleteTriggerByUserIdResult> DeleteTriggerByUserIdAsync(
Request.DeleteTriggerByUserIdRequest request
)
{
var task = new DeleteTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class VerifyTriggerTask : Gs2WebSocketSessionTask<Request.VerifyTriggerRequest, Result.VerifyTriggerResult>
{
public VerifyTriggerTask(IGs2Session session, Request.VerifyTriggerRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.VerifyTriggerRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.TriggerName != null)
{
jsonWriter.WritePropertyName("triggerName");
jsonWriter.Write(request.TriggerName.ToString());
}
if (request.VerifyType != null)
{
jsonWriter.WritePropertyName("verifyType");
jsonWriter.Write(request.VerifyType.ToString());
}
if (request.ElapsedMinutes != null)
{
jsonWriter.WritePropertyName("elapsedMinutes");
jsonWriter.Write(request.ElapsedMinutes.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("xGs2AccessToken");
jsonWriter.Write(request.AccessToken);
}
if (request.DuplicationAvoider != null)
{
jsonWriter.WritePropertyName("xGs2DuplicationAvoider");
jsonWriter.Write(request.DuplicationAvoider);
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"trigger",
"verifyTrigger",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator VerifyTrigger(
Request.VerifyTriggerRequest request,
UnityAction<AsyncResult<Result.VerifyTriggerResult>> callback
)
{
var task = new VerifyTriggerTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.VerifyTriggerResult>(task.Result, task.Error));
}
public IFuture<Result.VerifyTriggerResult> VerifyTriggerFuture(
Request.VerifyTriggerRequest request
)
{
return new VerifyTriggerTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.VerifyTriggerResult> VerifyTriggerAsync(
Request.VerifyTriggerRequest request
)
{
var task = new VerifyTriggerTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public VerifyTriggerTask VerifyTriggerAsync(
Request.VerifyTriggerRequest request
)
{
return new VerifyTriggerTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.VerifyTriggerResult> VerifyTriggerAsync(
Request.VerifyTriggerRequest request
)
{
var task = new VerifyTriggerTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class VerifyTriggerByUserIdTask : Gs2WebSocketSessionTask<Request.VerifyTriggerByUserIdRequest, Result.VerifyTriggerByUserIdResult>
{
public VerifyTriggerByUserIdTask(IGs2Session session, Request.VerifyTriggerByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.VerifyTriggerByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TriggerName != null)
{
jsonWriter.WritePropertyName("triggerName");
jsonWriter.Write(request.TriggerName.ToString());
}
if (request.VerifyType != null)
{
jsonWriter.WritePropertyName("verifyType");
jsonWriter.Write(request.VerifyType.ToString());
}
if (request.ElapsedMinutes != null)
{
jsonWriter.WritePropertyName("elapsedMinutes");
jsonWriter.Write(request.ElapsedMinutes.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DuplicationAvoider != null)
{
jsonWriter.WritePropertyName("xGs2DuplicationAvoider");
jsonWriter.Write(request.DuplicationAvoider);
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"trigger",
"verifyTriggerByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator VerifyTriggerByUserId(
Request.VerifyTriggerByUserIdRequest request,
UnityAction<AsyncResult<Result.VerifyTriggerByUserIdResult>> callback
)
{
var task = new VerifyTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.VerifyTriggerByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.VerifyTriggerByUserIdResult> VerifyTriggerByUserIdFuture(
Request.VerifyTriggerByUserIdRequest request
)
{
return new VerifyTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.VerifyTriggerByUserIdResult> VerifyTriggerByUserIdAsync(
Request.VerifyTriggerByUserIdRequest request
)
{
var task = new VerifyTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public VerifyTriggerByUserIdTask VerifyTriggerByUserIdAsync(
Request.VerifyTriggerByUserIdRequest request
)
{
return new VerifyTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.VerifyTriggerByUserIdResult> VerifyTriggerByUserIdAsync(
Request.VerifyTriggerByUserIdRequest request
)
{
var task = new VerifyTriggerByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetEventTask : Gs2WebSocketSessionTask<Request.GetEventRequest, Result.GetEventResult>
{
public GetEventTask(IGs2Session session, Request.GetEventRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetEventRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.EventName != null)
{
jsonWriter.WritePropertyName("eventName");
jsonWriter.Write(request.EventName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.IsInSchedule != null)
{
jsonWriter.WritePropertyName("isInSchedule");
jsonWriter.Write(request.IsInSchedule.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("xGs2AccessToken");
jsonWriter.Write(request.AccessToken);
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"event",
"getEvent",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetEvent(
Request.GetEventRequest request,
UnityAction<AsyncResult<Result.GetEventResult>> callback
)
{
var task = new GetEventTask(
Gs2WebSocketSession,
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(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetEventResult> GetEventAsync(
Request.GetEventRequest request
)
{
var task = new GetEventTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetEventTask GetEventAsync(
Request.GetEventRequest request
)
{
return new GetEventTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetEventResult> GetEventAsync(
Request.GetEventRequest request
)
{
var task = new GetEventTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetEventByUserIdTask : Gs2WebSocketSessionTask<Request.GetEventByUserIdRequest, Result.GetEventByUserIdResult>
{
public GetEventByUserIdTask(IGs2Session session, Request.GetEventByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetEventByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.EventName != null)
{
jsonWriter.WritePropertyName("eventName");
jsonWriter.Write(request.EventName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.IsInSchedule != null)
{
jsonWriter.WritePropertyName("isInSchedule");
jsonWriter.Write(request.IsInSchedule.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"event",
"getEventByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetEventByUserId(
Request.GetEventByUserIdRequest request,
UnityAction<AsyncResult<Result.GetEventByUserIdResult>> callback
)
{
var task = new GetEventByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetEventByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.GetEventByUserIdResult> GetEventByUserIdFuture(
Request.GetEventByUserIdRequest request
)
{
return new GetEventByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetEventByUserIdResult> GetEventByUserIdAsync(
Request.GetEventByUserIdRequest request
)
{
var task = new GetEventByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetEventByUserIdTask GetEventByUserIdAsync(
Request.GetEventByUserIdRequest request
)
{
return new GetEventByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetEventByUserIdResult> GetEventByUserIdAsync(
Request.GetEventByUserIdRequest request
)
{
var task = new GetEventByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetRawEventTask : Gs2WebSocketSessionTask<Request.GetRawEventRequest, Result.GetRawEventResult>
{
public GetRawEventTask(IGs2Session session, Request.GetRawEventRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetRawEventRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.EventName != null)
{
jsonWriter.WritePropertyName("eventName");
jsonWriter.Write(request.EventName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"event",
"getRawEvent",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetRawEvent(
Request.GetRawEventRequest request,
UnityAction<AsyncResult<Result.GetRawEventResult>> callback
)
{
var task = new GetRawEventTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetRawEventResult>(task.Result, task.Error));
}
public IFuture<Result.GetRawEventResult> GetRawEventFuture(
Request.GetRawEventRequest request
)
{
return new GetRawEventTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetRawEventResult> GetRawEventAsync(
Request.GetRawEventRequest request
)
{
var task = new GetRawEventTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetRawEventTask GetRawEventAsync(
Request.GetRawEventRequest request
)
{
return new GetRawEventTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetRawEventResult> GetRawEventAsync(
Request.GetRawEventRequest request
)
{
var task = new GetRawEventTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class VerifyEventTask : Gs2WebSocketSessionTask<Request.VerifyEventRequest, Result.VerifyEventResult>
{
public VerifyEventTask(IGs2Session session, Request.VerifyEventRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.VerifyEventRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.EventName != null)
{
jsonWriter.WritePropertyName("eventName");
jsonWriter.Write(request.EventName.ToString());
}
if (request.VerifyType != null)
{
jsonWriter.WritePropertyName("verifyType");
jsonWriter.Write(request.VerifyType.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("xGs2AccessToken");
jsonWriter.Write(request.AccessToken);
}
if (request.DuplicationAvoider != null)
{
jsonWriter.WritePropertyName("xGs2DuplicationAvoider");
jsonWriter.Write(request.DuplicationAvoider);
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"event",
"verifyEvent",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator VerifyEvent(
Request.VerifyEventRequest request,
UnityAction<AsyncResult<Result.VerifyEventResult>> callback
)
{
var task = new VerifyEventTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.VerifyEventResult>(task.Result, task.Error));
}
public IFuture<Result.VerifyEventResult> VerifyEventFuture(
Request.VerifyEventRequest request
)
{
return new VerifyEventTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.VerifyEventResult> VerifyEventAsync(
Request.VerifyEventRequest request
)
{
var task = new VerifyEventTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public VerifyEventTask VerifyEventAsync(
Request.VerifyEventRequest request
)
{
return new VerifyEventTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.VerifyEventResult> VerifyEventAsync(
Request.VerifyEventRequest request
)
{
var task = new VerifyEventTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class VerifyEventByUserIdTask : Gs2WebSocketSessionTask<Request.VerifyEventByUserIdRequest, Result.VerifyEventByUserIdResult>
{
public VerifyEventByUserIdTask(IGs2Session session, Request.VerifyEventByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.VerifyEventByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.EventName != null)
{
jsonWriter.WritePropertyName("eventName");
jsonWriter.Write(request.EventName.ToString());
}
if (request.VerifyType != null)
{
jsonWriter.WritePropertyName("verifyType");
jsonWriter.Write(request.VerifyType.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DuplicationAvoider != null)
{
jsonWriter.WritePropertyName("xGs2DuplicationAvoider");
jsonWriter.Write(request.DuplicationAvoider);
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"event",
"verifyEventByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator VerifyEventByUserId(
Request.VerifyEventByUserIdRequest request,
UnityAction<AsyncResult<Result.VerifyEventByUserIdResult>> callback
)
{
var task = new VerifyEventByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.VerifyEventByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.VerifyEventByUserIdResult> VerifyEventByUserIdFuture(
Request.VerifyEventByUserIdRequest request
)
{
return new VerifyEventByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.VerifyEventByUserIdResult> VerifyEventByUserIdAsync(
Request.VerifyEventByUserIdRequest request
)
{
var task = new VerifyEventByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public VerifyEventByUserIdTask VerifyEventByUserIdAsync(
Request.VerifyEventByUserIdRequest request
)
{
return new VerifyEventByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.VerifyEventByUserIdResult> VerifyEventByUserIdAsync(
Request.VerifyEventByUserIdRequest request
)
{
var task = new VerifyEventByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class PreUpdateCurrentEventMasterTask : Gs2WebSocketSessionTask<Request.PreUpdateCurrentEventMasterRequest, Result.PreUpdateCurrentEventMasterResult>
{
public PreUpdateCurrentEventMasterTask(IGs2Session session, Request.PreUpdateCurrentEventMasterRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.PreUpdateCurrentEventMasterRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"schedule",
"currentEventMaster",
"preUpdateCurrentEventMaster",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator PreUpdateCurrentEventMaster(
Request.PreUpdateCurrentEventMasterRequest request,
UnityAction<AsyncResult<Result.PreUpdateCurrentEventMasterResult>> callback
)
{
var task = new PreUpdateCurrentEventMasterTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.PreUpdateCurrentEventMasterResult>(task.Result, task.Error));
}
public IFuture<Result.PreUpdateCurrentEventMasterResult> PreUpdateCurrentEventMasterFuture(
Request.PreUpdateCurrentEventMasterRequest request
)
{
return new PreUpdateCurrentEventMasterTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.PreUpdateCurrentEventMasterResult> PreUpdateCurrentEventMasterAsync(
Request.PreUpdateCurrentEventMasterRequest request
)
{
var task = new PreUpdateCurrentEventMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public PreUpdateCurrentEventMasterTask PreUpdateCurrentEventMasterAsync(
Request.PreUpdateCurrentEventMasterRequest request
)
{
return new PreUpdateCurrentEventMasterTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.PreUpdateCurrentEventMasterResult> PreUpdateCurrentEventMasterAsync(
Request.PreUpdateCurrentEventMasterRequest request
)
{
var task = new PreUpdateCurrentEventMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
}
}