Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
pip-gs2 / io.gs2.csharp.sdk js
Repository URL to install this package:
|
Version:
2025.4.1 ▾
|
/*
* 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.Gs2Ranking
{
public class Gs2RankingWebSocketClient : AbstractGs2Client
{
public static string Endpoint = "ranking";
protected Gs2WebSocketSession Gs2WebSocketSession => (Gs2WebSocketSession) Gs2Session;
public Gs2RankingWebSocketClient(Gs2WebSocketSession Gs2WebSocketSession) : base(Gs2WebSocketSession)
{
}
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,
"ranking",
"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,
"ranking",
"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,
"ranking",
"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,
"ranking",
"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 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,
"ranking",
"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,
"ranking",
"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 SubscribeTask : Gs2WebSocketSessionTask<Request.SubscribeRequest, Result.SubscribeResult>
{
public SubscribeTask(IGs2Session session, Request.SubscribeRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.SubscribeRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.TargetUserId != null)
{
jsonWriter.WritePropertyName("targetUserId");
jsonWriter.Write(request.TargetUserId.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,
"ranking",
"subscribe",
"subscribe",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator Subscribe(
Request.SubscribeRequest request,
UnityAction<AsyncResult<Result.SubscribeResult>> callback
)
{
var task = new SubscribeTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.SubscribeResult>(task.Result, task.Error));
}
public IFuture<Result.SubscribeResult> SubscribeFuture(
Request.SubscribeRequest request
)
{
return new SubscribeTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.SubscribeResult> SubscribeAsync(
Request.SubscribeRequest request
)
{
var task = new SubscribeTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public SubscribeTask SubscribeAsync(
Request.SubscribeRequest request
)
{
return new SubscribeTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.SubscribeResult> SubscribeAsync(
Request.SubscribeRequest request
)
{
var task = new SubscribeTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class SubscribeByUserIdTask : Gs2WebSocketSessionTask<Request.SubscribeByUserIdRequest, Result.SubscribeByUserIdResult>
{
public SubscribeByUserIdTask(IGs2Session session, Request.SubscribeByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.SubscribeByUserIdRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TargetUserId != null)
{
jsonWriter.WritePropertyName("targetUserId");
jsonWriter.Write(request.TargetUserId.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,
"ranking",
"subscribe",
"subscribeByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator SubscribeByUserId(
Request.SubscribeByUserIdRequest request,
UnityAction<AsyncResult<Result.SubscribeByUserIdResult>> callback
)
{
var task = new SubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.SubscribeByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.SubscribeByUserIdResult> SubscribeByUserIdFuture(
Request.SubscribeByUserIdRequest request
)
{
return new SubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.SubscribeByUserIdResult> SubscribeByUserIdAsync(
Request.SubscribeByUserIdRequest request
)
{
var task = new SubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public SubscribeByUserIdTask SubscribeByUserIdAsync(
Request.SubscribeByUserIdRequest request
)
{
return new SubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.SubscribeByUserIdResult> SubscribeByUserIdAsync(
Request.SubscribeByUserIdRequest request
)
{
var task = new SubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetScoreTask : Gs2WebSocketSessionTask<Request.GetScoreRequest, Result.GetScoreResult>
{
public GetScoreTask(IGs2Session session, Request.GetScoreRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetScoreRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.ScorerUserId != null)
{
jsonWriter.WritePropertyName("scorerUserId");
jsonWriter.Write(request.ScorerUserId.ToString());
}
if (request.UniqueId != null)
{
jsonWriter.WritePropertyName("uniqueId");
jsonWriter.Write(request.UniqueId.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,
"ranking",
"score",
"getScore",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetScore(
Request.GetScoreRequest request,
UnityAction<AsyncResult<Result.GetScoreResult>> callback
)
{
var task = new GetScoreTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetScoreResult>(task.Result, task.Error));
}
public IFuture<Result.GetScoreResult> GetScoreFuture(
Request.GetScoreRequest request
)
{
return new GetScoreTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetScoreResult> GetScoreAsync(
Request.GetScoreRequest request
)
{
var task = new GetScoreTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetScoreTask GetScoreAsync(
Request.GetScoreRequest request
)
{
return new GetScoreTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetScoreResult> GetScoreAsync(
Request.GetScoreRequest request
)
{
var task = new GetScoreTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetScoreByUserIdTask : Gs2WebSocketSessionTask<Request.GetScoreByUserIdRequest, Result.GetScoreByUserIdResult>
{
public GetScoreByUserIdTask(IGs2Session session, Request.GetScoreByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetScoreByUserIdRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.ScorerUserId != null)
{
jsonWriter.WritePropertyName("scorerUserId");
jsonWriter.Write(request.ScorerUserId.ToString());
}
if (request.UniqueId != null)
{
jsonWriter.WritePropertyName("uniqueId");
jsonWriter.Write(request.UniqueId.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,
"ranking",
"score",
"getScoreByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetScoreByUserId(
Request.GetScoreByUserIdRequest request,
UnityAction<AsyncResult<Result.GetScoreByUserIdResult>> callback
)
{
var task = new GetScoreByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetScoreByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.GetScoreByUserIdResult> GetScoreByUserIdFuture(
Request.GetScoreByUserIdRequest request
)
{
return new GetScoreByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetScoreByUserIdResult> GetScoreByUserIdAsync(
Request.GetScoreByUserIdRequest request
)
{
var task = new GetScoreByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetScoreByUserIdTask GetScoreByUserIdAsync(
Request.GetScoreByUserIdRequest request
)
{
return new GetScoreByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetScoreByUserIdResult> GetScoreByUserIdAsync(
Request.GetScoreByUserIdRequest request
)
{
var task = new GetScoreByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetRankingTask : Gs2WebSocketSessionTask<Request.GetRankingRequest, Result.GetRankingResult>
{
public GetRankingTask(IGs2Session session, Request.GetRankingRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetRankingRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.ScorerUserId != null)
{
jsonWriter.WritePropertyName("scorerUserId");
jsonWriter.Write(request.ScorerUserId.ToString());
}
if (request.UniqueId != null)
{
jsonWriter.WritePropertyName("uniqueId");
jsonWriter.Write(request.UniqueId.ToString());
}
if (request.AdditionalScopeName != null)
{
jsonWriter.WritePropertyName("additionalScopeName");
jsonWriter.Write(request.AdditionalScopeName.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,
"ranking",
"ranking",
"getRanking",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetRanking(
Request.GetRankingRequest request,
UnityAction<AsyncResult<Result.GetRankingResult>> callback
)
{
var task = new GetRankingTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetRankingResult>(task.Result, task.Error));
}
public IFuture<Result.GetRankingResult> GetRankingFuture(
Request.GetRankingRequest request
)
{
return new GetRankingTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetRankingResult> GetRankingAsync(
Request.GetRankingRequest request
)
{
var task = new GetRankingTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetRankingTask GetRankingAsync(
Request.GetRankingRequest request
)
{
return new GetRankingTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetRankingResult> GetRankingAsync(
Request.GetRankingRequest request
)
{
var task = new GetRankingTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetRankingByUserIdTask : Gs2WebSocketSessionTask<Request.GetRankingByUserIdRequest, Result.GetRankingByUserIdResult>
{
public GetRankingByUserIdTask(IGs2Session session, Request.GetRankingByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetRankingByUserIdRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.ScorerUserId != null)
{
jsonWriter.WritePropertyName("scorerUserId");
jsonWriter.Write(request.ScorerUserId.ToString());
}
if (request.UniqueId != null)
{
jsonWriter.WritePropertyName("uniqueId");
jsonWriter.Write(request.UniqueId.ToString());
}
if (request.AdditionalScopeName != null)
{
jsonWriter.WritePropertyName("additionalScopeName");
jsonWriter.Write(request.AdditionalScopeName.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,
"ranking",
"ranking",
"getRankingByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetRankingByUserId(
Request.GetRankingByUserIdRequest request,
UnityAction<AsyncResult<Result.GetRankingByUserIdResult>> callback
)
{
var task = new GetRankingByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetRankingByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.GetRankingByUserIdResult> GetRankingByUserIdFuture(
Request.GetRankingByUserIdRequest request
)
{
return new GetRankingByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetRankingByUserIdResult> GetRankingByUserIdAsync(
Request.GetRankingByUserIdRequest request
)
{
var task = new GetRankingByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetRankingByUserIdTask GetRankingByUserIdAsync(
Request.GetRankingByUserIdRequest request
)
{
return new GetRankingByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetRankingByUserIdResult> GetRankingByUserIdAsync(
Request.GetRankingByUserIdRequest request
)
{
var task = new GetRankingByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class PutScoreTask : Gs2WebSocketSessionTask<Request.PutScoreRequest, Result.PutScoreResult>
{
public PutScoreTask(IGs2Session session, Request.PutScoreRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.PutScoreRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.Score != null)
{
jsonWriter.WritePropertyName("score");
jsonWriter.Write(request.Score.ToString());
}
if (request.Metadata != null)
{
jsonWriter.WritePropertyName("metadata");
jsonWriter.Write(request.Metadata.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,
"ranking",
"ranking",
"putScore",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator PutScore(
Request.PutScoreRequest request,
UnityAction<AsyncResult<Result.PutScoreResult>> callback
)
{
var task = new PutScoreTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.PutScoreResult>(task.Result, task.Error));
}
public IFuture<Result.PutScoreResult> PutScoreFuture(
Request.PutScoreRequest request
)
{
return new PutScoreTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.PutScoreResult> PutScoreAsync(
Request.PutScoreRequest request
)
{
var task = new PutScoreTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public PutScoreTask PutScoreAsync(
Request.PutScoreRequest request
)
{
return new PutScoreTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.PutScoreResult> PutScoreAsync(
Request.PutScoreRequest request
)
{
var task = new PutScoreTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class PutScoreByUserIdTask : Gs2WebSocketSessionTask<Request.PutScoreByUserIdRequest, Result.PutScoreByUserIdResult>
{
public PutScoreByUserIdTask(IGs2Session session, Request.PutScoreByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.PutScoreByUserIdRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.Score != null)
{
jsonWriter.WritePropertyName("score");
jsonWriter.Write(request.Score.ToString());
}
if (request.Metadata != null)
{
jsonWriter.WritePropertyName("metadata");
jsonWriter.Write(request.Metadata.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,
"ranking",
"ranking",
"putScoreByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator PutScoreByUserId(
Request.PutScoreByUserIdRequest request,
UnityAction<AsyncResult<Result.PutScoreByUserIdResult>> callback
)
{
var task = new PutScoreByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.PutScoreByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.PutScoreByUserIdResult> PutScoreByUserIdFuture(
Request.PutScoreByUserIdRequest request
)
{
return new PutScoreByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.PutScoreByUserIdResult> PutScoreByUserIdAsync(
Request.PutScoreByUserIdRequest request
)
{
var task = new PutScoreByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public PutScoreByUserIdTask PutScoreByUserIdAsync(
Request.PutScoreByUserIdRequest request
)
{
return new PutScoreByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.PutScoreByUserIdResult> PutScoreByUserIdAsync(
Request.PutScoreByUserIdRequest request
)
{
var task = new PutScoreByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class CalcRankingTask : Gs2WebSocketSessionTask<Request.CalcRankingRequest, Result.CalcRankingResult>
{
public CalcRankingTask(IGs2Session session, Request.CalcRankingRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CalcRankingRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.AdditionalScopeName != null)
{
jsonWriter.WritePropertyName("additionalScopeName");
jsonWriter.Write(request.AdditionalScopeName.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,
"ranking",
"ranking",
"calcRanking",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CalcRanking(
Request.CalcRankingRequest request,
UnityAction<AsyncResult<Result.CalcRankingResult>> callback
)
{
var task = new CalcRankingTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CalcRankingResult>(task.Result, task.Error));
}
public IFuture<Result.CalcRankingResult> CalcRankingFuture(
Request.CalcRankingRequest request
)
{
return new CalcRankingTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CalcRankingResult> CalcRankingAsync(
Request.CalcRankingRequest request
)
{
var task = new CalcRankingTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CalcRankingTask CalcRankingAsync(
Request.CalcRankingRequest request
)
{
return new CalcRankingTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CalcRankingResult> CalcRankingAsync(
Request.CalcRankingRequest request
)
{
var task = new CalcRankingTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetSubscribeTask : Gs2WebSocketSessionTask<Request.GetSubscribeRequest, Result.GetSubscribeResult>
{
public GetSubscribeTask(IGs2Session session, Request.GetSubscribeRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetSubscribeRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.TargetUserId != null)
{
jsonWriter.WritePropertyName("targetUserId");
jsonWriter.Write(request.TargetUserId.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,
"ranking",
"subscribeUser",
"getSubscribe",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetSubscribe(
Request.GetSubscribeRequest request,
UnityAction<AsyncResult<Result.GetSubscribeResult>> callback
)
{
var task = new GetSubscribeTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetSubscribeResult>(task.Result, task.Error));
}
public IFuture<Result.GetSubscribeResult> GetSubscribeFuture(
Request.GetSubscribeRequest request
)
{
return new GetSubscribeTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetSubscribeResult> GetSubscribeAsync(
Request.GetSubscribeRequest request
)
{
var task = new GetSubscribeTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetSubscribeTask GetSubscribeAsync(
Request.GetSubscribeRequest request
)
{
return new GetSubscribeTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetSubscribeResult> GetSubscribeAsync(
Request.GetSubscribeRequest request
)
{
var task = new GetSubscribeTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetSubscribeByUserIdTask : Gs2WebSocketSessionTask<Request.GetSubscribeByUserIdRequest, Result.GetSubscribeByUserIdResult>
{
public GetSubscribeByUserIdTask(IGs2Session session, Request.GetSubscribeByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetSubscribeByUserIdRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TargetUserId != null)
{
jsonWriter.WritePropertyName("targetUserId");
jsonWriter.Write(request.TargetUserId.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,
"ranking",
"subscribeUser",
"getSubscribeByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetSubscribeByUserId(
Request.GetSubscribeByUserIdRequest request,
UnityAction<AsyncResult<Result.GetSubscribeByUserIdResult>> callback
)
{
var task = new GetSubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetSubscribeByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.GetSubscribeByUserIdResult> GetSubscribeByUserIdFuture(
Request.GetSubscribeByUserIdRequest request
)
{
return new GetSubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetSubscribeByUserIdResult> GetSubscribeByUserIdAsync(
Request.GetSubscribeByUserIdRequest request
)
{
var task = new GetSubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetSubscribeByUserIdTask GetSubscribeByUserIdAsync(
Request.GetSubscribeByUserIdRequest request
)
{
return new GetSubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetSubscribeByUserIdResult> GetSubscribeByUserIdAsync(
Request.GetSubscribeByUserIdRequest request
)
{
var task = new GetSubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class UnsubscribeTask : Gs2WebSocketSessionTask<Request.UnsubscribeRequest, Result.UnsubscribeResult>
{
public UnsubscribeTask(IGs2Session session, Request.UnsubscribeRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.UnsubscribeRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.TargetUserId != null)
{
jsonWriter.WritePropertyName("targetUserId");
jsonWriter.Write(request.TargetUserId.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,
"ranking",
"subscribeUser",
"unsubscribe",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator Unsubscribe(
Request.UnsubscribeRequest request,
UnityAction<AsyncResult<Result.UnsubscribeResult>> callback
)
{
var task = new UnsubscribeTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.UnsubscribeResult>(task.Result, task.Error));
}
public IFuture<Result.UnsubscribeResult> UnsubscribeFuture(
Request.UnsubscribeRequest request
)
{
return new UnsubscribeTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UnsubscribeResult> UnsubscribeAsync(
Request.UnsubscribeRequest request
)
{
var task = new UnsubscribeTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public UnsubscribeTask UnsubscribeAsync(
Request.UnsubscribeRequest request
)
{
return new UnsubscribeTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.UnsubscribeResult> UnsubscribeAsync(
Request.UnsubscribeRequest request
)
{
var task = new UnsubscribeTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class UnsubscribeByUserIdTask : Gs2WebSocketSessionTask<Request.UnsubscribeByUserIdRequest, Result.UnsubscribeByUserIdResult>
{
public UnsubscribeByUserIdTask(IGs2Session session, Request.UnsubscribeByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.UnsubscribeByUserIdRequest 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.CategoryName != null)
{
jsonWriter.WritePropertyName("categoryName");
jsonWriter.Write(request.CategoryName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TargetUserId != null)
{
jsonWriter.WritePropertyName("targetUserId");
jsonWriter.Write(request.TargetUserId.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,
"ranking",
"subscribeUser",
"unsubscribeByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator UnsubscribeByUserId(
Request.UnsubscribeByUserIdRequest request,
UnityAction<AsyncResult<Result.UnsubscribeByUserIdResult>> callback
)
{
var task = new UnsubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.UnsubscribeByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.UnsubscribeByUserIdResult> UnsubscribeByUserIdFuture(
Request.UnsubscribeByUserIdRequest request
)
{
return new UnsubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UnsubscribeByUserIdResult> UnsubscribeByUserIdAsync(
Request.UnsubscribeByUserIdRequest request
)
{
var task = new UnsubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public UnsubscribeByUserIdTask UnsubscribeByUserIdAsync(
Request.UnsubscribeByUserIdRequest request
)
{
return new UnsubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.UnsubscribeByUserIdResult> UnsubscribeByUserIdAsync(
Request.UnsubscribeByUserIdRequest request
)
{
var task = new UnsubscribeByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
}
}