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.3.17 ▾
|
/*
* 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.Gs2Chat
{
public class Gs2ChatWebSocketClient : AbstractGs2Client
{
public static string Endpoint = "chat";
protected Gs2WebSocketSession Gs2WebSocketSession => (Gs2WebSocketSession) Gs2Session;
public Gs2ChatWebSocketClient(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.AllowCreateRoom != null)
{
jsonWriter.WritePropertyName("allowCreateRoom");
jsonWriter.Write(request.AllowCreateRoom.ToString());
}
if (request.MessageLifeTimeDays != null)
{
jsonWriter.WritePropertyName("messageLifeTimeDays");
jsonWriter.Write(request.MessageLifeTimeDays.ToString());
}
if (request.PostMessageScript != null)
{
jsonWriter.WritePropertyName("postMessageScript");
request.PostMessageScript.WriteJson(jsonWriter);
}
if (request.CreateRoomScript != null)
{
jsonWriter.WritePropertyName("createRoomScript");
request.CreateRoomScript.WriteJson(jsonWriter);
}
if (request.DeleteRoomScript != null)
{
jsonWriter.WritePropertyName("deleteRoomScript");
request.DeleteRoomScript.WriteJson(jsonWriter);
}
if (request.SubscribeRoomScript != null)
{
jsonWriter.WritePropertyName("subscribeRoomScript");
request.SubscribeRoomScript.WriteJson(jsonWriter);
}
if (request.UnsubscribeRoomScript != null)
{
jsonWriter.WritePropertyName("unsubscribeRoomScript");
request.UnsubscribeRoomScript.WriteJson(jsonWriter);
}
if (request.PostNotification != null)
{
jsonWriter.WritePropertyName("postNotification");
request.PostNotification.WriteJson(jsonWriter);
}
if (request.LogSetting != null)
{
jsonWriter.WritePropertyName("logSetting");
request.LogSetting.WriteJson(jsonWriter);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"chat",
"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.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"chat",
"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.AllowCreateRoom != null)
{
jsonWriter.WritePropertyName("allowCreateRoom");
jsonWriter.Write(request.AllowCreateRoom.ToString());
}
if (request.MessageLifeTimeDays != null)
{
jsonWriter.WritePropertyName("messageLifeTimeDays");
jsonWriter.Write(request.MessageLifeTimeDays.ToString());
}
if (request.PostMessageScript != null)
{
jsonWriter.WritePropertyName("postMessageScript");
request.PostMessageScript.WriteJson(jsonWriter);
}
if (request.CreateRoomScript != null)
{
jsonWriter.WritePropertyName("createRoomScript");
request.CreateRoomScript.WriteJson(jsonWriter);
}
if (request.DeleteRoomScript != null)
{
jsonWriter.WritePropertyName("deleteRoomScript");
request.DeleteRoomScript.WriteJson(jsonWriter);
}
if (request.SubscribeRoomScript != null)
{
jsonWriter.WritePropertyName("subscribeRoomScript");
request.SubscribeRoomScript.WriteJson(jsonWriter);
}
if (request.UnsubscribeRoomScript != null)
{
jsonWriter.WritePropertyName("unsubscribeRoomScript");
request.UnsubscribeRoomScript.WriteJson(jsonWriter);
}
if (request.PostNotification != null)
{
jsonWriter.WritePropertyName("postNotification");
request.PostNotification.WriteJson(jsonWriter);
}
if (request.LogSetting != null)
{
jsonWriter.WritePropertyName("logSetting");
request.LogSetting.WriteJson(jsonWriter);
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"chat",
"namespace",
"updateNamespace",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator UpdateNamespace(
Request.UpdateNamespaceRequest request,
UnityAction<AsyncResult<Result.UpdateNamespaceResult>> callback
)
{
var task = new UpdateNamespaceTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.UpdateNamespaceResult>(task.Result, task.Error));
}
public IFuture<Result.UpdateNamespaceResult> UpdateNamespaceFuture(
Request.UpdateNamespaceRequest request
)
{
return new UpdateNamespaceTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UpdateNamespaceResult> UpdateNamespaceAsync(
Request.UpdateNamespaceRequest request
)
{
var task = new UpdateNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public UpdateNamespaceTask UpdateNamespaceAsync(
Request.UpdateNamespaceRequest request
)
{
return new UpdateNamespaceTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.UpdateNamespaceResult> UpdateNamespaceAsync(
Request.UpdateNamespaceRequest request
)
{
var task = new UpdateNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DeleteNamespaceTask : Gs2WebSocketSessionTask<Request.DeleteNamespaceRequest, Result.DeleteNamespaceResult>
{
public DeleteNamespaceTask(IGs2Session session, Request.DeleteNamespaceRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DeleteNamespaceRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"chat",
"namespace",
"deleteNamespace",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteNamespace(
Request.DeleteNamespaceRequest request,
UnityAction<AsyncResult<Result.DeleteNamespaceResult>> callback
)
{
var task = new DeleteNamespaceTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteNamespaceResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteNamespaceResult> DeleteNamespaceFuture(
Request.DeleteNamespaceRequest request
)
{
return new DeleteNamespaceTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteNamespaceResult> DeleteNamespaceAsync(
Request.DeleteNamespaceRequest request
)
{
var task = new DeleteNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DeleteNamespaceTask DeleteNamespaceAsync(
Request.DeleteNamespaceRequest request
)
{
return new DeleteNamespaceTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DeleteNamespaceResult> DeleteNamespaceAsync(
Request.DeleteNamespaceRequest request
)
{
var task = new DeleteNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DumpUserDataByUserIdTask : Gs2WebSocketSessionTask<Request.DumpUserDataByUserIdRequest, Result.DumpUserDataByUserIdResult>
{
public DumpUserDataByUserIdTask(IGs2Session session, Request.DumpUserDataByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DumpUserDataByUserIdRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.TimeOffsetToken != null)
{
jsonWriter.WritePropertyName("timeOffsetToken");
jsonWriter.Write(request.TimeOffsetToken.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"chat",
"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,
"chat",
"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,
"chat",
"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,
"chat",
"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,
"chat",
"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,
"chat",
"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 PostTask : Gs2WebSocketSessionTask<Request.PostRequest, Result.PostResult>
{
public PostTask(IGs2Session session, Request.PostRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.PostRequest 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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.Category != null)
{
jsonWriter.WritePropertyName("category");
jsonWriter.Write(request.Category.ToString());
}
if (request.Metadata != null)
{
jsonWriter.WritePropertyName("metadata");
jsonWriter.Write(request.Metadata.ToString());
}
if (request.Password != null)
{
jsonWriter.WritePropertyName("password");
jsonWriter.Write(request.Password.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,
"chat",
"message",
"post",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
public override void OnError(Gs2.Core.Exception.Gs2Exception error)
{
if (error.Errors.Count(v => v.code == "room.allowUserIds.notInclude") > 0) {
base.OnError(new Exception.NoAccessPrivilegesException(error));
}
else if (error.Errors.Count(v => v.code == "room.password.require") > 0) {
base.OnError(new Exception.PasswordRequiredException(error));
}
else if (error.Errors.Count(v => v.code == "room.password.invalid") > 0) {
base.OnError(new Exception.PasswordIncorrectException(error));
}
else {
base.OnError(error);
}
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator Post(
Request.PostRequest request,
UnityAction<AsyncResult<Result.PostResult>> callback
)
{
var task = new PostTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.PostResult>(task.Result, task.Error));
}
public IFuture<Result.PostResult> PostFuture(
Request.PostRequest request
)
{
return new PostTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.PostResult> PostAsync(
Request.PostRequest request
)
{
var task = new PostTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public PostTask PostAsync(
Request.PostRequest request
)
{
return new PostTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.PostResult> PostAsync(
Request.PostRequest request
)
{
var task = new PostTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class PostByUserIdTask : Gs2WebSocketSessionTask<Request.PostByUserIdRequest, Result.PostByUserIdResult>
{
public PostByUserIdTask(IGs2Session session, Request.PostByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.PostByUserIdRequest 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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.Category != null)
{
jsonWriter.WritePropertyName("category");
jsonWriter.Write(request.Category.ToString());
}
if (request.Metadata != null)
{
jsonWriter.WritePropertyName("metadata");
jsonWriter.Write(request.Metadata.ToString());
}
if (request.Password != null)
{
jsonWriter.WritePropertyName("password");
jsonWriter.Write(request.Password.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,
"chat",
"message",
"postByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
public override void OnError(Gs2.Core.Exception.Gs2Exception error)
{
if (error.Errors.Count(v => v.code == "room.allowUserIds.notInclude") > 0) {
base.OnError(new Exception.NoAccessPrivilegesException(error));
}
else if (error.Errors.Count(v => v.code == "room.password.require") > 0) {
base.OnError(new Exception.PasswordRequiredException(error));
}
else if (error.Errors.Count(v => v.code == "room.password.invalid") > 0) {
base.OnError(new Exception.PasswordIncorrectException(error));
}
else {
base.OnError(error);
}
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator PostByUserId(
Request.PostByUserIdRequest request,
UnityAction<AsyncResult<Result.PostByUserIdResult>> callback
)
{
var task = new PostByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.PostByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.PostByUserIdResult> PostByUserIdFuture(
Request.PostByUserIdRequest request
)
{
return new PostByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.PostByUserIdResult> PostByUserIdAsync(
Request.PostByUserIdRequest request
)
{
var task = new PostByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public PostByUserIdTask PostByUserIdAsync(
Request.PostByUserIdRequest request
)
{
return new PostByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.PostByUserIdResult> PostByUserIdAsync(
Request.PostByUserIdRequest request
)
{
var task = new PostByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetMessageTask : Gs2WebSocketSessionTask<Request.GetMessageRequest, Result.GetMessageResult>
{
public GetMessageTask(IGs2Session session, Request.GetMessageRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetMessageRequest 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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.MessageName != null)
{
jsonWriter.WritePropertyName("messageName");
jsonWriter.Write(request.MessageName.ToString());
}
if (request.Password != null)
{
jsonWriter.WritePropertyName("password");
jsonWriter.Write(request.Password.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.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,
"chat",
"message",
"getMessage",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
public override void OnError(Gs2.Core.Exception.Gs2Exception error)
{
if (error.Errors.Count(v => v.code == "room.allowUserIds.notInclude") > 0) {
base.OnError(new Exception.NoAccessPrivilegesException(error));
}
else if (error.Errors.Count(v => v.code == "room.password.require") > 0) {
base.OnError(new Exception.PasswordRequiredException(error));
}
else if (error.Errors.Count(v => v.code == "room.password.invalid") > 0) {
base.OnError(new Exception.PasswordIncorrectException(error));
}
else {
base.OnError(error);
}
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetMessage(
Request.GetMessageRequest request,
UnityAction<AsyncResult<Result.GetMessageResult>> callback
)
{
var task = new GetMessageTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetMessageResult>(task.Result, task.Error));
}
public IFuture<Result.GetMessageResult> GetMessageFuture(
Request.GetMessageRequest request
)
{
return new GetMessageTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetMessageResult> GetMessageAsync(
Request.GetMessageRequest request
)
{
var task = new GetMessageTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetMessageTask GetMessageAsync(
Request.GetMessageRequest request
)
{
return new GetMessageTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetMessageResult> GetMessageAsync(
Request.GetMessageRequest request
)
{
var task = new GetMessageTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetMessageByUserIdTask : Gs2WebSocketSessionTask<Request.GetMessageByUserIdRequest, Result.GetMessageByUserIdResult>
{
public GetMessageByUserIdTask(IGs2Session session, Request.GetMessageByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetMessageByUserIdRequest 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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.MessageName != null)
{
jsonWriter.WritePropertyName("messageName");
jsonWriter.Write(request.MessageName.ToString());
}
if (request.Password != null)
{
jsonWriter.WritePropertyName("password");
jsonWriter.Write(request.Password.ToString());
}
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,
"chat",
"message",
"getMessageByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
public override void OnError(Gs2.Core.Exception.Gs2Exception error)
{
if (error.Errors.Count(v => v.code == "room.allowUserIds.notInclude") > 0) {
base.OnError(new Exception.NoAccessPrivilegesException(error));
}
else if (error.Errors.Count(v => v.code == "room.password.require") > 0) {
base.OnError(new Exception.PasswordRequiredException(error));
}
else if (error.Errors.Count(v => v.code == "room.password.invalid") > 0) {
base.OnError(new Exception.PasswordIncorrectException(error));
}
else {
base.OnError(error);
}
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetMessageByUserId(
Request.GetMessageByUserIdRequest request,
UnityAction<AsyncResult<Result.GetMessageByUserIdResult>> callback
)
{
var task = new GetMessageByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetMessageByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.GetMessageByUserIdResult> GetMessageByUserIdFuture(
Request.GetMessageByUserIdRequest request
)
{
return new GetMessageByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetMessageByUserIdResult> GetMessageByUserIdAsync(
Request.GetMessageByUserIdRequest request
)
{
var task = new GetMessageByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetMessageByUserIdTask GetMessageByUserIdAsync(
Request.GetMessageByUserIdRequest request
)
{
return new GetMessageByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetMessageByUserIdResult> GetMessageByUserIdAsync(
Request.GetMessageByUserIdRequest request
)
{
var task = new GetMessageByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DeleteMessageTask : Gs2WebSocketSessionTask<Request.DeleteMessageRequest, Result.DeleteMessageResult>
{
public DeleteMessageTask(IGs2Session session, Request.DeleteMessageRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DeleteMessageRequest 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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.MessageName != null)
{
jsonWriter.WritePropertyName("messageName");
jsonWriter.Write(request.MessageName.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,
"chat",
"message",
"deleteMessage",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteMessage(
Request.DeleteMessageRequest request,
UnityAction<AsyncResult<Result.DeleteMessageResult>> callback
)
{
var task = new DeleteMessageTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteMessageResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteMessageResult> DeleteMessageFuture(
Request.DeleteMessageRequest request
)
{
return new DeleteMessageTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteMessageResult> DeleteMessageAsync(
Request.DeleteMessageRequest request
)
{
var task = new DeleteMessageTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DeleteMessageTask DeleteMessageAsync(
Request.DeleteMessageRequest request
)
{
return new DeleteMessageTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DeleteMessageResult> DeleteMessageAsync(
Request.DeleteMessageRequest request
)
{
var task = new DeleteMessageTask(
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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.NotificationTypes != null)
{
jsonWriter.WritePropertyName("notificationTypes");
jsonWriter.WriteArrayStart();
foreach(var item in request.NotificationTypes)
{
item.WriteJson(jsonWriter);
}
jsonWriter.WriteArrayEnd();
}
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,
"chat",
"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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.NotificationTypes != null)
{
jsonWriter.WritePropertyName("notificationTypes");
jsonWriter.WriteArrayStart();
foreach(var item in request.NotificationTypes)
{
item.WriteJson(jsonWriter);
}
jsonWriter.WriteArrayEnd();
}
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,
"chat",
"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 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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.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,
"chat",
"subscribe",
"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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
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,
"chat",
"subscribe",
"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 UpdateNotificationTypeTask : Gs2WebSocketSessionTask<Request.UpdateNotificationTypeRequest, Result.UpdateNotificationTypeResult>
{
public UpdateNotificationTypeTask(IGs2Session session, Request.UpdateNotificationTypeRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.UpdateNotificationTypeRequest 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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.ToString());
}
if (request.NotificationTypes != null)
{
jsonWriter.WritePropertyName("notificationTypes");
jsonWriter.WriteArrayStart();
foreach(var item in request.NotificationTypes)
{
item.WriteJson(jsonWriter);
}
jsonWriter.WriteArrayEnd();
}
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,
"chat",
"subscribe",
"updateNotificationType",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator UpdateNotificationType(
Request.UpdateNotificationTypeRequest request,
UnityAction<AsyncResult<Result.UpdateNotificationTypeResult>> callback
)
{
var task = new UpdateNotificationTypeTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.UpdateNotificationTypeResult>(task.Result, task.Error));
}
public IFuture<Result.UpdateNotificationTypeResult> UpdateNotificationTypeFuture(
Request.UpdateNotificationTypeRequest request
)
{
return new UpdateNotificationTypeTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UpdateNotificationTypeResult> UpdateNotificationTypeAsync(
Request.UpdateNotificationTypeRequest request
)
{
var task = new UpdateNotificationTypeTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public UpdateNotificationTypeTask UpdateNotificationTypeAsync(
Request.UpdateNotificationTypeRequest request
)
{
return new UpdateNotificationTypeTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.UpdateNotificationTypeResult> UpdateNotificationTypeAsync(
Request.UpdateNotificationTypeRequest request
)
{
var task = new UpdateNotificationTypeTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class UpdateNotificationTypeByUserIdTask : Gs2WebSocketSessionTask<Request.UpdateNotificationTypeByUserIdRequest, Result.UpdateNotificationTypeByUserIdResult>
{
public UpdateNotificationTypeByUserIdTask(IGs2Session session, Request.UpdateNotificationTypeByUserIdRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.UpdateNotificationTypeByUserIdRequest 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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.UserId != null)
{
jsonWriter.WritePropertyName("userId");
jsonWriter.Write(request.UserId.ToString());
}
if (request.NotificationTypes != null)
{
jsonWriter.WritePropertyName("notificationTypes");
jsonWriter.WriteArrayStart();
foreach(var item in request.NotificationTypes)
{
item.WriteJson(jsonWriter);
}
jsonWriter.WriteArrayEnd();
}
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,
"chat",
"subscribe",
"updateNotificationTypeByUserId",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator UpdateNotificationTypeByUserId(
Request.UpdateNotificationTypeByUserIdRequest request,
UnityAction<AsyncResult<Result.UpdateNotificationTypeByUserIdResult>> callback
)
{
var task = new UpdateNotificationTypeByUserIdTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.UpdateNotificationTypeByUserIdResult>(task.Result, task.Error));
}
public IFuture<Result.UpdateNotificationTypeByUserIdResult> UpdateNotificationTypeByUserIdFuture(
Request.UpdateNotificationTypeByUserIdRequest request
)
{
return new UpdateNotificationTypeByUserIdTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.UpdateNotificationTypeByUserIdResult> UpdateNotificationTypeByUserIdAsync(
Request.UpdateNotificationTypeByUserIdRequest request
)
{
var task = new UpdateNotificationTypeByUserIdTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public UpdateNotificationTypeByUserIdTask UpdateNotificationTypeByUserIdAsync(
Request.UpdateNotificationTypeByUserIdRequest request
)
{
return new UpdateNotificationTypeByUserIdTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.UpdateNotificationTypeByUserIdResult> UpdateNotificationTypeByUserIdAsync(
Request.UpdateNotificationTypeByUserIdRequest request
)
{
var task = new UpdateNotificationTypeByUserIdTask(
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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
if (request.AccessToken != null)
{
jsonWriter.WritePropertyName("accessToken");
jsonWriter.Write(request.AccessToken.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,
"chat",
"subscribe",
"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.RoomName != null)
{
jsonWriter.WritePropertyName("roomName");
jsonWriter.Write(request.RoomName.ToString());
}
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.DuplicationAvoider != null)
{
jsonWriter.WritePropertyName("xGs2DuplicationAvoider");
jsonWriter.Write(request.DuplicationAvoider);
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"chat",
"subscribe",
"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
}
}