Repository URL to install this package:
|
Version:
2022.5.6 ▾
|
/*
* 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.
*/
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.Gs2Limit
{
public class Gs2LimitWebSocketClient : AbstractGs2Client
{
public static string Endpoint = "limit";
protected Gs2WebSocketSession Gs2WebSocketSession => (Gs2WebSocketSession) Gs2Session;
public Gs2LimitWebSocketClient(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.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"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 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.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"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.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"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.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"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 GetCounterTask : Gs2WebSocketSessionTask<Request.GetCounterRequest, Result.GetCounterResult>
{
public GetCounterTask(IGs2Session session, Request.GetCounterRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetCounterRequest 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.LimitName != null)
{
jsonWriter.WritePropertyName("limitName");
jsonWriter.Write(request.LimitName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.CounterName != null)
{
jsonWriter.WritePropertyName("counterName");
jsonWriter.Write(request.CounterName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("xGs2AccessToken");
jsonWriter.Write(request.AccessToken);
}
AddHeader(
Session.Credential,
"limit",
"counter",
"getCounter",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetCounter(
Request.GetCounterRequest request,
UnityAction<AsyncResult<Result.GetCounterResult>> callback
)
{
var task = new GetCounterTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetCounterResult>(task.Result, task.Error));
}
public IFuture<Result.GetCounterResult> GetCounterFuture(
Request.GetCounterRequest request
)
{
return new GetCounterTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetCounterResult> GetCounterAsync(
Request.GetCounterRequest request
)
{
var task = new GetCounterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetCounterTask GetCounterAsync(
Request.GetCounterRequest request
)
{
return new GetCounterTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetCounterResult> GetCounterAsync(
Request.GetCounterRequest request
)
{
var task = new GetCounterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetCounterByUserIdTask : Gs2WebSocketSessionTask<Request.GetCounterByUserIdRequest, Result.GetCounterByUserIdResult>
{
public GetCounterByUserIdTask(IGs2Session session, Request.GetCounterByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetCounterByUserIdRequest 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.LimitName != null)
{
jsonWriter.WritePropertyName("limitName");
jsonWriter.Write(request.LimitName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.CounterName != null)
{
jsonWriter.WritePropertyName("counterName");
jsonWriter.Write(request.CounterName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"counter",
"getCounterByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetCounterByUserId(
Request.GetCounterByUserIdRequest request,
UnityAction<AsyncResult<Result.GetCounterByUserIdResult>> callback
)
{
var task = new GetCounterByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetCounterByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.GetCounterByUserIdResult> GetCounterByUserIdFuture(
Request.GetCounterByUserIdRequest request
)
{
return new GetCounterByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetCounterByUserIdResult> GetCounterByUserIdAsync(
Request.GetCounterByUserIdRequest request
)
{
var task = new GetCounterByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetCounterByUserIdTask GetCounterByUserIdAsync(
Request.GetCounterByUserIdRequest request
)
{
return new GetCounterByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetCounterByUserIdResult> GetCounterByUserIdAsync(
Request.GetCounterByUserIdRequest request
)
{
var task = new GetCounterByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class CountUpTask : Gs2WebSocketSessionTask<Request.CountUpRequest, Result.CountUpResult>
{
public CountUpTask(IGs2Session session, Request.CountUpRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CountUpRequest 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.LimitName != null)
{
jsonWriter.WritePropertyName("limitName");
jsonWriter.Write(request.LimitName.ToString());
}
if (request.CounterName != null)
{
jsonWriter.WritePropertyName("counterName");
jsonWriter.Write(request.CounterName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.CountUpValue != null)
{
jsonWriter.WritePropertyName("countUpValue");
jsonWriter.Write(request.CountUpValue.ToString());
}
if (request.MaxValue != null)
{
jsonWriter.WritePropertyName("maxValue");
jsonWriter.Write(request.MaxValue.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("xGs2AccessToken");
jsonWriter.Write(request.AccessToken);
}
AddHeader(
Session.Credential,
"limit",
"counter",
"countUp",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CountUp(
Request.CountUpRequest request,
UnityAction<AsyncResult<Result.CountUpResult>> callback
)
{
var task = new CountUpTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CountUpResult>(task.Result, task.Error));
}
public IFuture<Result.CountUpResult> CountUpFuture(
Request.CountUpRequest request
)
{
return new CountUpTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CountUpResult> CountUpAsync(
Request.CountUpRequest request
)
{
var task = new CountUpTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CountUpTask CountUpAsync(
Request.CountUpRequest request
)
{
return new CountUpTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CountUpResult> CountUpAsync(
Request.CountUpRequest request
)
{
var task = new CountUpTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class CountUpByUserIdTask : Gs2WebSocketSessionTask<Request.CountUpByUserIdRequest, Result.CountUpByUserIdResult>
{
public CountUpByUserIdTask(IGs2Session session, Request.CountUpByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CountUpByUserIdRequest 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.LimitName != null)
{
jsonWriter.WritePropertyName("limitName");
jsonWriter.Write(request.LimitName.ToString());
}
if (request.CounterName != null)
{
jsonWriter.WritePropertyName("counterName");
jsonWriter.Write(request.CounterName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.CountUpValue != null)
{
jsonWriter.WritePropertyName("countUpValue");
jsonWriter.Write(request.CountUpValue.ToString());
}
if (request.MaxValue != null)
{
jsonWriter.WritePropertyName("maxValue");
jsonWriter.Write(request.MaxValue.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
if (request.DuplicationAvoider != null)
{
jsonWriter.WritePropertyName("xGs2DuplicationAvoider");
jsonWriter.Write(request.DuplicationAvoider);
}
AddHeader(
Session.Credential,
"limit",
"counter",
"countUpByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CountUpByUserId(
Request.CountUpByUserIdRequest request,
UnityAction<AsyncResult<Result.CountUpByUserIdResult>> callback
)
{
var task = new CountUpByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CountUpByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.CountUpByUserIdResult> CountUpByUserIdFuture(
Request.CountUpByUserIdRequest request
)
{
return new CountUpByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CountUpByUserIdResult> CountUpByUserIdAsync(
Request.CountUpByUserIdRequest request
)
{
var task = new CountUpByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CountUpByUserIdTask CountUpByUserIdAsync(
Request.CountUpByUserIdRequest request
)
{
return new CountUpByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CountUpByUserIdResult> CountUpByUserIdAsync(
Request.CountUpByUserIdRequest request
)
{
var task = new CountUpByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DeleteCounterByUserIdTask : Gs2WebSocketSessionTask<Request.DeleteCounterByUserIdRequest, Result.DeleteCounterByUserIdResult>
{
public DeleteCounterByUserIdTask(IGs2Session session, Request.DeleteCounterByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DeleteCounterByUserIdRequest 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.LimitName != null)
{
jsonWriter.WritePropertyName("limitName");
jsonWriter.Write(request.LimitName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.CounterName != null)
{
jsonWriter.WritePropertyName("counterName");
jsonWriter.Write(request.CounterName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
if (request.DuplicationAvoider != null)
{
jsonWriter.WritePropertyName("xGs2DuplicationAvoider");
jsonWriter.Write(request.DuplicationAvoider);
}
AddHeader(
Session.Credential,
"limit",
"counter",
"deleteCounterByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteCounterByUserId(
Request.DeleteCounterByUserIdRequest request,
UnityAction<AsyncResult<Result.DeleteCounterByUserIdResult>> callback
)
{
var task = new DeleteCounterByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteCounterByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteCounterByUserIdResult> DeleteCounterByUserIdFuture(
Request.DeleteCounterByUserIdRequest request
)
{
return new DeleteCounterByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteCounterByUserIdResult> DeleteCounterByUserIdAsync(
Request.DeleteCounterByUserIdRequest request
)
{
var task = new DeleteCounterByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DeleteCounterByUserIdTask DeleteCounterByUserIdAsync(
Request.DeleteCounterByUserIdRequest request
)
{
return new DeleteCounterByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DeleteCounterByUserIdResult> DeleteCounterByUserIdAsync(
Request.DeleteCounterByUserIdRequest request
)
{
var task = new DeleteCounterByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DeleteByStampSheetTask : Gs2WebSocketSessionTask<Request.DeleteByStampSheetRequest, Result.DeleteByStampSheetResult>
{
public DeleteByStampSheetTask(IGs2Session session, Request.DeleteByStampSheetRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DeleteByStampSheetRequest 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.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"counter",
"deleteByStampSheet",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteByStampSheet(
Request.DeleteByStampSheetRequest request,
UnityAction<AsyncResult<Result.DeleteByStampSheetResult>> callback
)
{
var task = new DeleteByStampSheetTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteByStampSheetResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteByStampSheetResult> DeleteByStampSheetFuture(
Request.DeleteByStampSheetRequest request
)
{
return new DeleteByStampSheetTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteByStampSheetResult> DeleteByStampSheetAsync(
Request.DeleteByStampSheetRequest request
)
{
var task = new DeleteByStampSheetTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DeleteByStampSheetTask DeleteByStampSheetAsync(
Request.DeleteByStampSheetRequest request
)
{
return new DeleteByStampSheetTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DeleteByStampSheetResult> DeleteByStampSheetAsync(
Request.DeleteByStampSheetRequest request
)
{
var task = new DeleteByStampSheetTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class CreateLimitModelMasterTask : Gs2WebSocketSessionTask<Request.CreateLimitModelMasterRequest, Result.CreateLimitModelMasterResult>
{
public CreateLimitModelMasterTask(IGs2Session session, Request.CreateLimitModelMasterRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CreateLimitModelMasterRequest 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.ResetType != null)
{
jsonWriter.WritePropertyName("resetType");
jsonWriter.Write(request.ResetType.ToString());
}
if (request.ResetDayOfMonth != null)
{
jsonWriter.WritePropertyName("resetDayOfMonth");
jsonWriter.Write(request.ResetDayOfMonth.ToString());
}
if (request.ResetDayOfWeek != null)
{
jsonWriter.WritePropertyName("resetDayOfWeek");
jsonWriter.Write(request.ResetDayOfWeek.ToString());
}
if (request.ResetHour != null)
{
jsonWriter.WritePropertyName("resetHour");
jsonWriter.Write(request.ResetHour.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"limitModelMaster",
"createLimitModelMaster",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CreateLimitModelMaster(
Request.CreateLimitModelMasterRequest request,
UnityAction<AsyncResult<Result.CreateLimitModelMasterResult>> callback
)
{
var task = new CreateLimitModelMasterTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CreateLimitModelMasterResult>(task.Result, task.Error));
}
public IFuture<Result.CreateLimitModelMasterResult> CreateLimitModelMasterFuture(
Request.CreateLimitModelMasterRequest request
)
{
return new CreateLimitModelMasterTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CreateLimitModelMasterResult> CreateLimitModelMasterAsync(
Request.CreateLimitModelMasterRequest request
)
{
var task = new CreateLimitModelMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CreateLimitModelMasterTask CreateLimitModelMasterAsync(
Request.CreateLimitModelMasterRequest request
)
{
return new CreateLimitModelMasterTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CreateLimitModelMasterResult> CreateLimitModelMasterAsync(
Request.CreateLimitModelMasterRequest request
)
{
var task = new CreateLimitModelMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetLimitModelMasterTask : Gs2WebSocketSessionTask<Request.GetLimitModelMasterRequest, Result.GetLimitModelMasterResult>
{
public GetLimitModelMasterTask(IGs2Session session, Request.GetLimitModelMasterRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetLimitModelMasterRequest 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.LimitName != null)
{
jsonWriter.WritePropertyName("limitName");
jsonWriter.Write(request.LimitName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"limitModelMaster",
"getLimitModelMaster",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetLimitModelMaster(
Request.GetLimitModelMasterRequest request,
UnityAction<AsyncResult<Result.GetLimitModelMasterResult>> callback
)
{
var task = new GetLimitModelMasterTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetLimitModelMasterResult>(task.Result, task.Error));
}
public IFuture<Result.GetLimitModelMasterResult> GetLimitModelMasterFuture(
Request.GetLimitModelMasterRequest request
)
{
return new GetLimitModelMasterTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetLimitModelMasterResult> GetLimitModelMasterAsync(
Request.GetLimitModelMasterRequest request
)
{
var task = new GetLimitModelMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetLimitModelMasterTask GetLimitModelMasterAsync(
Request.GetLimitModelMasterRequest request
)
{
return new GetLimitModelMasterTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetLimitModelMasterResult> GetLimitModelMasterAsync(
Request.GetLimitModelMasterRequest request
)
{
var task = new GetLimitModelMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class UpdateLimitModelMasterTask : Gs2WebSocketSessionTask<Request.UpdateLimitModelMasterRequest, Result.UpdateLimitModelMasterResult>
{
public UpdateLimitModelMasterTask(IGs2Session session, Request.UpdateLimitModelMasterRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.UpdateLimitModelMasterRequest 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.LimitName != null)
{
jsonWriter.WritePropertyName("limitName");
jsonWriter.Write(request.LimitName.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.ResetType != null)
{
jsonWriter.WritePropertyName("resetType");
jsonWriter.Write(request.ResetType.ToString());
}
if (request.ResetDayOfMonth != null)
{
jsonWriter.WritePropertyName("resetDayOfMonth");
jsonWriter.Write(request.ResetDayOfMonth.ToString());
}
if (request.ResetDayOfWeek != null)
{
jsonWriter.WritePropertyName("resetDayOfWeek");
jsonWriter.Write(request.ResetDayOfWeek.ToString());
}
if (request.ResetHour != null)
{
jsonWriter.WritePropertyName("resetHour");
jsonWriter.Write(request.ResetHour.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"limitModelMaster",
"updateLimitModelMaster",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator UpdateLimitModelMaster(
Request.UpdateLimitModelMasterRequest request,
UnityAction<AsyncResult<Result.UpdateLimitModelMasterResult>> callback
)
{
var task = new UpdateLimitModelMasterTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.UpdateLimitModelMasterResult>(task.Result, task.Error));
}
public IFuture<Result.UpdateLimitModelMasterResult> UpdateLimitModelMasterFuture(
Request.UpdateLimitModelMasterRequest request
)
{
return new UpdateLimitModelMasterTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UpdateLimitModelMasterResult> UpdateLimitModelMasterAsync(
Request.UpdateLimitModelMasterRequest request
)
{
var task = new UpdateLimitModelMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public UpdateLimitModelMasterTask UpdateLimitModelMasterAsync(
Request.UpdateLimitModelMasterRequest request
)
{
return new UpdateLimitModelMasterTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.UpdateLimitModelMasterResult> UpdateLimitModelMasterAsync(
Request.UpdateLimitModelMasterRequest request
)
{
var task = new UpdateLimitModelMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DeleteLimitModelMasterTask : Gs2WebSocketSessionTask<Request.DeleteLimitModelMasterRequest, Result.DeleteLimitModelMasterResult>
{
public DeleteLimitModelMasterTask(IGs2Session session, Request.DeleteLimitModelMasterRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DeleteLimitModelMasterRequest 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.LimitName != null)
{
jsonWriter.WritePropertyName("limitName");
jsonWriter.Write(request.LimitName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"limitModelMaster",
"deleteLimitModelMaster",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteLimitModelMaster(
Request.DeleteLimitModelMasterRequest request,
UnityAction<AsyncResult<Result.DeleteLimitModelMasterResult>> callback
)
{
var task = new DeleteLimitModelMasterTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteLimitModelMasterResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteLimitModelMasterResult> DeleteLimitModelMasterFuture(
Request.DeleteLimitModelMasterRequest request
)
{
return new DeleteLimitModelMasterTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteLimitModelMasterResult> DeleteLimitModelMasterAsync(
Request.DeleteLimitModelMasterRequest request
)
{
var task = new DeleteLimitModelMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DeleteLimitModelMasterTask DeleteLimitModelMasterAsync(
Request.DeleteLimitModelMasterRequest request
)
{
return new DeleteLimitModelMasterTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DeleteLimitModelMasterResult> DeleteLimitModelMasterAsync(
Request.DeleteLimitModelMasterRequest request
)
{
var task = new DeleteLimitModelMasterTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetLimitModelTask : Gs2WebSocketSessionTask<Request.GetLimitModelRequest, Result.GetLimitModelResult>
{
public GetLimitModelTask(IGs2Session session, Request.GetLimitModelRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetLimitModelRequest 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.LimitName != null)
{
jsonWriter.WritePropertyName("limitName");
jsonWriter.Write(request.LimitName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.RequestId != null)
{
jsonWriter.WritePropertyName("xGs2RequestId");
jsonWriter.Write(request.RequestId);
}
AddHeader(
Session.Credential,
"limit",
"limitModel",
"getLimitModel",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetLimitModel(
Request.GetLimitModelRequest request,
UnityAction<AsyncResult<Result.GetLimitModelResult>> callback
)
{
var task = new GetLimitModelTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetLimitModelResult>(task.Result, task.Error));
}
public IFuture<Result.GetLimitModelResult> GetLimitModelFuture(
Request.GetLimitModelRequest request
)
{
return new GetLimitModelTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetLimitModelResult> GetLimitModelAsync(
Request.GetLimitModelRequest request
)
{
var task = new GetLimitModelTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetLimitModelTask GetLimitModelAsync(
Request.GetLimitModelRequest request
)
{
return new GetLimitModelTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetLimitModelResult> GetLimitModelAsync(
Request.GetLimitModelRequest request
)
{
var task = new GetLimitModelTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
}
}