Repository URL to install this package:
Version:
2025.5.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.
*/
#pragma warning disable CS0618 // Obsolete with a message
using System;
using System.Collections.Generic;
using System.Text;
using System.Linq;
using Gs2.Core;
using Gs2.Core.Model;
using Gs2.Core.Net;
using Gs2.Util.LitJson;
#if UNITY_2017_1_OR_NEWER
using System.Collections;
using UnityEngine.Events;
using UnityEngine.Networking;
#if GS2_ENABLE_UNITASK
using Cysharp.Threading.Tasks;
#endif
#else
using System.Threading.Tasks;
using System.Threading;
#endif
namespace Gs2.Gs2Log
{
public class Gs2LogWebSocketClient : AbstractGs2Client
{
public static string Endpoint = "log";
protected Gs2WebSocketSession Gs2WebSocketSession => (Gs2WebSocketSession) Gs2Session;
public Gs2LogWebSocketClient(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.Type != null)
{
jsonWriter.WritePropertyName("type");
jsonWriter.Write(request.Type.ToString());
}
if (request.GcpCredentialJson != null)
{
jsonWriter.WritePropertyName("gcpCredentialJson");
jsonWriter.Write(request.GcpCredentialJson.ToString());
}
if (request.BigQueryDatasetName != null)
{
jsonWriter.WritePropertyName("bigQueryDatasetName");
jsonWriter.Write(request.BigQueryDatasetName.ToString());
}
if (request.LogExpireDays != null)
{
jsonWriter.WritePropertyName("logExpireDays");
jsonWriter.Write(request.LogExpireDays.ToString());
}
if (request.AwsRegion != null)
{
jsonWriter.WritePropertyName("awsRegion");
jsonWriter.Write(request.AwsRegion.ToString());
}
if (request.AwsAccessKeyId != null)
{
jsonWriter.WritePropertyName("awsAccessKeyId");
jsonWriter.Write(request.AwsAccessKeyId.ToString());
}
if (request.AwsSecretAccessKey != null)
{
jsonWriter.WritePropertyName("awsSecretAccessKey");
jsonWriter.Write(request.AwsSecretAccessKey.ToString());
}
if (request.FirehoseStreamName != null)
{
jsonWriter.WritePropertyName("firehoseStreamName");
jsonWriter.Write(request.FirehoseStreamName.ToString());
}
if (request.FirehoseCompressData != null)
{
jsonWriter.WritePropertyName("firehoseCompressData");
jsonWriter.Write(request.FirehoseCompressData.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,
"log",
"namespace",
"createNamespace",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CreateNamespace(
Request.CreateNamespaceRequest request,
UnityAction<AsyncResult<Result.CreateNamespaceResult>> callback
)
{
var task = new CreateNamespaceTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CreateNamespaceResult>(task.Result, task.Error));
}
public IFuture<Result.CreateNamespaceResult> CreateNamespaceFuture(
Request.CreateNamespaceRequest request
)
{
return new CreateNamespaceTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CreateNamespaceResult> CreateNamespaceAsync(
Request.CreateNamespaceRequest request
)
{
var task = new CreateNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CreateNamespaceTask CreateNamespaceAsync(
Request.CreateNamespaceRequest request
)
{
return new CreateNamespaceTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CreateNamespaceResult> CreateNamespaceAsync(
Request.CreateNamespaceRequest request
)
{
var task = new CreateNamespaceTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetNamespaceStatusTask : Gs2WebSocketSessionTask<Request.GetNamespaceStatusRequest, Result.GetNamespaceStatusResult>
{
public GetNamespaceStatusTask(IGs2Session session, Request.GetNamespaceStatusRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetNamespaceStatusRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"log",
"namespace",
"getNamespaceStatus",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetNamespaceStatus(
Request.GetNamespaceStatusRequest request,
UnityAction<AsyncResult<Result.GetNamespaceStatusResult>> callback
)
{
var task = new GetNamespaceStatusTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetNamespaceStatusResult>(task.Result, task.Error));
}
public IFuture<Result.GetNamespaceStatusResult> GetNamespaceStatusFuture(
Request.GetNamespaceStatusRequest request
)
{
return new GetNamespaceStatusTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetNamespaceStatusResult> GetNamespaceStatusAsync(
Request.GetNamespaceStatusRequest request
)
{
var task = new GetNamespaceStatusTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetNamespaceStatusTask GetNamespaceStatusAsync(
Request.GetNamespaceStatusRequest request
)
{
return new GetNamespaceStatusTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetNamespaceStatusResult> GetNamespaceStatusAsync(
Request.GetNamespaceStatusRequest request
)
{
var task = new GetNamespaceStatusTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetNamespaceTask : Gs2WebSocketSessionTask<Request.GetNamespaceRequest, Result.GetNamespaceResult>
{
public GetNamespaceTask(IGs2Session session, Request.GetNamespaceRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetNamespaceRequest request)
{
var stringBuilder = new StringBuilder();
var jsonWriter = new JsonWriter(stringBuilder);
jsonWriter.WriteObjectStart();
if (request.NamespaceName != null)
{
jsonWriter.WritePropertyName("namespaceName");
jsonWriter.Write(request.NamespaceName.ToString());
}
if (request.ContextStack != null)
{
jsonWriter.WritePropertyName("contextStack");
jsonWriter.Write(request.ContextStack.ToString());
}
if (request.DryRun)
{
jsonWriter.WritePropertyName("xGs2DryRun");
jsonWriter.Write("true");
}
AddHeader(
Session.Credential,
"log",
"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.Type != null)
{
jsonWriter.WritePropertyName("type");
jsonWriter.Write(request.Type.ToString());
}
if (request.GcpCredentialJson != null)
{
jsonWriter.WritePropertyName("gcpCredentialJson");
jsonWriter.Write(request.GcpCredentialJson.ToString());
}
if (request.BigQueryDatasetName != null)
{
jsonWriter.WritePropertyName("bigQueryDatasetName");
jsonWriter.Write(request.BigQueryDatasetName.ToString());
}
if (request.LogExpireDays != null)
{
jsonWriter.WritePropertyName("logExpireDays");
jsonWriter.Write(request.LogExpireDays.ToString());
}
if (request.AwsRegion != null)
{
jsonWriter.WritePropertyName("awsRegion");
jsonWriter.Write(request.AwsRegion.ToString());
}
if (request.AwsAccessKeyId != null)
{
jsonWriter.WritePropertyName("awsAccessKeyId");
jsonWriter.Write(request.AwsAccessKeyId.ToString());
}
if (request.AwsSecretAccessKey != null)
{
jsonWriter.WritePropertyName("awsSecretAccessKey");
jsonWriter.Write(request.AwsSecretAccessKey.ToString());
}
if (request.FirehoseStreamName != null)
{
jsonWriter.WritePropertyName("firehoseStreamName");
jsonWriter.Write(request.FirehoseStreamName.ToString());
}
if (request.FirehoseCompressData != null)
{
jsonWriter.WritePropertyName("firehoseCompressData");
jsonWriter.Write(request.FirehoseCompressData.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,
"log",
"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,
"log",
"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 CreateInsightTask : Gs2WebSocketSessionTask<Request.CreateInsightRequest, Result.CreateInsightResult>
{
public CreateInsightTask(IGs2Session session, Request.CreateInsightRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.CreateInsightRequest 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,
"log",
"insight",
"createInsight",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator CreateInsight(
Request.CreateInsightRequest request,
UnityAction<AsyncResult<Result.CreateInsightResult>> callback
)
{
var task = new CreateInsightTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.CreateInsightResult>(task.Result, task.Error));
}
public IFuture<Result.CreateInsightResult> CreateInsightFuture(
Request.CreateInsightRequest request
)
{
return new CreateInsightTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.CreateInsightResult> CreateInsightAsync(
Request.CreateInsightRequest request
)
{
var task = new CreateInsightTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public CreateInsightTask CreateInsightAsync(
Request.CreateInsightRequest request
)
{
return new CreateInsightTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.CreateInsightResult> CreateInsightAsync(
Request.CreateInsightRequest request
)
{
var task = new CreateInsightTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class GetInsightTask : Gs2WebSocketSessionTask<Request.GetInsightRequest, Result.GetInsightResult>
{
public GetInsightTask(IGs2Session session, Request.GetInsightRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.GetInsightRequest 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.InsightName != null)
{
jsonWriter.WritePropertyName("insightName");
jsonWriter.Write(request.InsightName.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,
"log",
"insight",
"getInsight",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator GetInsight(
Request.GetInsightRequest request,
UnityAction<AsyncResult<Result.GetInsightResult>> callback
)
{
var task = new GetInsightTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.GetInsightResult>(task.Result, task.Error));
}
public IFuture<Result.GetInsightResult> GetInsightFuture(
Request.GetInsightRequest request
)
{
return new GetInsightTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.GetInsightResult> GetInsightAsync(
Request.GetInsightRequest request
)
{
var task = new GetInsightTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public GetInsightTask GetInsightAsync(
Request.GetInsightRequest request
)
{
return new GetInsightTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.GetInsightResult> GetInsightAsync(
Request.GetInsightRequest request
)
{
var task = new GetInsightTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
public class DeleteInsightTask : Gs2WebSocketSessionTask<Request.DeleteInsightRequest, Result.DeleteInsightResult>
{
public DeleteInsightTask(IGs2Session session, Request.DeleteInsightRequest request) : base(session, request)
{
}
protected override IGs2SessionRequest CreateRequest(Request.DeleteInsightRequest 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.InsightName != null)
{
jsonWriter.WritePropertyName("insightName");
jsonWriter.Write(request.InsightName.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,
"log",
"insight",
"deleteInsight",
jsonWriter
);
jsonWriter.WriteObjectEnd();
return WebSocketSessionRequestFactory.New<WebSocketSessionRequest>(stringBuilder.ToString());
}
}
#if UNITY_2017_1_OR_NEWER
public IEnumerator DeleteInsight(
Request.DeleteInsightRequest request,
UnityAction<AsyncResult<Result.DeleteInsightResult>> callback
)
{
var task = new DeleteInsightTask(
Gs2WebSocketSession,
request
);
yield return task;
callback.Invoke(new AsyncResult<Result.DeleteInsightResult>(task.Result, task.Error));
}
public IFuture<Result.DeleteInsightResult> DeleteInsightFuture(
Request.DeleteInsightRequest request
)
{
return new DeleteInsightTask(
Gs2WebSocketSession,
request
);
}
#if GS2_ENABLE_UNITASK
public async UniTask<Result.DeleteInsightResult> DeleteInsightAsync(
Request.DeleteInsightRequest request
)
{
var task = new DeleteInsightTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#else
public DeleteInsightTask DeleteInsightAsync(
Request.DeleteInsightRequest request
)
{
return new DeleteInsightTask(
Gs2WebSocketSession,
request
);
}
#endif
#else
public async Task<Result.DeleteInsightResult> DeleteInsightAsync(
Request.DeleteInsightRequest request
)
{
var task = new DeleteInsightTask(
Gs2WebSocketSession,
request
);
return await task.Invoke();
}
#endif
}
}