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.
*/
// ReSharper disable RedundantNameQualifier
// ReSharper disable RedundantUsingDirective
// ReSharper disable CheckNamespace
// ReSharper disable PartialTypeWithSinglePart
// ReSharper disable MemberCanBePrivate.Global
// ReSharper disable UnusedAutoPropertyAccessor.Global
// ReSharper disable UseObjectOrCollectionInitializer
// ReSharper disable ArrangeThisQualifier
// ReSharper disable NotAccessedField.Local
#pragma warning disable 1998
#pragma warning disable CS0169, CS0168
using System;
using System.Linq;
using System.Text.RegularExpressions;
using Gs2.Core.Model;
using Gs2.Core.Net;
using Gs2.Gs2Lottery.Domain.Iterator;
using Gs2.Gs2Lottery.Model.Cache;
using Gs2.Gs2Lottery.Request;
using Gs2.Gs2Lottery.Result;
using Gs2.Gs2Auth.Model;
using Gs2.Util.LitJson;
using Gs2.Core;
using Gs2.Core.Domain;
using Gs2.Core.Exception;
using Gs2.Core.Util;
#if UNITY_2017_1_OR_NEWER
using UnityEngine;
using UnityEngine.Scripting;
using System.Collections;
#if GS2_ENABLE_UNITASK
using Cysharp.Threading;
using Cysharp.Threading.Tasks;
using Cysharp.Threading.Tasks.Linq;
using System.Collections.Generic;
#endif
#else
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
#endif
namespace Gs2.Gs2Lottery.Domain.Model
{
public partial class NamespaceDomain {
private readonly Gs2.Core.Domain.Gs2 _gs2;
private readonly Gs2LotteryRestClient _client;
public string NamespaceName { get; } = null!;
public string Status { get; set; } = null!;
public string Url { get; set; } = null!;
public string UploadToken { get; set; } = null!;
public string UploadUrl { get; set; } = null!;
public string NextPageToken { get; set; } = null!;
public NamespaceDomain(
Gs2.Core.Domain.Gs2 gs2,
string namespaceName
) {
this._gs2 = gs2;
this._client = new Gs2LotteryRestClient(
gs2.RestSession
);
this.NamespaceName = namespaceName;
}
public Gs2.Gs2Lottery.Domain.Model.CurrentLotteryMasterDomain CurrentLotteryMaster(
) {
return new Gs2.Gs2Lottery.Domain.Model.CurrentLotteryMasterDomain(
this._gs2,
this.NamespaceName
);
}
#if UNITY_2017_1_OR_NEWER
public Gs2Iterator<Gs2.Gs2Lottery.Model.PrizeTable> PrizeTables(
)
{
return new DescribePrizeTablesIterator(
this._gs2,
this._client,
this.NamespaceName
);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if GS2_ENABLE_UNITASK
public IUniTaskAsyncEnumerable<Gs2.Gs2Lottery.Model.PrizeTable> PrizeTablesAsync(
#else
public DescribePrizeTablesIterator PrizeTablesAsync(
#endif
)
{
return new DescribePrizeTablesIterator(
this._gs2,
this._client,
this.NamespaceName
#if GS2_ENABLE_UNITASK
).GetAsyncEnumerator();
#else
);
#endif
}
#endif
public ulong SubscribePrizeTables(
Action<Gs2.Gs2Lottery.Model.PrizeTable[]> callback
)
{
return this._gs2.Cache.ListSubscribe<Gs2.Gs2Lottery.Model.PrizeTable>(
(null as Gs2.Gs2Lottery.Model.PrizeTable).CacheParentKey(
this.NamespaceName
),
callback,
() =>
{
#if UNITY_2017_1_OR_NEWER && GS2_ENABLE_UNITASK
async UniTask Impl() {
try {
await UniTask.SwitchToMainThread();
callback.Invoke(await PrizeTablesAsync(
).ToArrayAsync());
}
catch (System.Exception) {
// ignored
}
}
Impl().Forget();
#endif
}
);
}
#if UNITY_2017_1_OR_NEWER && GS2_ENABLE_UNITASK
public async UniTask<ulong> SubscribePrizeTablesWithInitialCallAsync(
Action<Gs2.Gs2Lottery.Model.PrizeTable[]> callback
)
{
var items = await PrizeTablesAsync(
).ToArrayAsync();
var callbackId = SubscribePrizeTables(
callback
);
callback.Invoke(items);
return callbackId;
}
#endif
public void UnsubscribePrizeTables(
ulong callbackId
)
{
this._gs2.Cache.ListUnsubscribe<Gs2.Gs2Lottery.Model.PrizeTable>(
(null as Gs2.Gs2Lottery.Model.PrizeTable).CacheParentKey(
this.NamespaceName
),
callbackId
);
}
public void InvalidatePrizeTables(
)
{
this._gs2.Cache.ClearListCache<Gs2.Gs2Lottery.Model.PrizeTable>(
(null as Gs2.Gs2Lottery.Model.PrizeTable).CacheParentKey(
this.NamespaceName
)
);
}
public Gs2.Gs2Lottery.Domain.Model.PrizeTableDomain PrizeTable(
string prizeTableName
) {
return new Gs2.Gs2Lottery.Domain.Model.PrizeTableDomain(
this._gs2,
this.NamespaceName,
prizeTableName
);
}
#if UNITY_2017_1_OR_NEWER
public Gs2Iterator<Gs2.Gs2Lottery.Model.LotteryModel> LotteryModels(
)
{
return new DescribeLotteryModelsIterator(
this._gs2,
this._client,
this.NamespaceName
);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if GS2_ENABLE_UNITASK
public IUniTaskAsyncEnumerable<Gs2.Gs2Lottery.Model.LotteryModel> LotteryModelsAsync(
#else
public DescribeLotteryModelsIterator LotteryModelsAsync(
#endif
)
{
return new DescribeLotteryModelsIterator(
this._gs2,
this._client,
this.NamespaceName
#if GS2_ENABLE_UNITASK
).GetAsyncEnumerator();
#else
);
#endif
}
#endif
public ulong SubscribeLotteryModels(
Action<Gs2.Gs2Lottery.Model.LotteryModel[]> callback
)
{
return this._gs2.Cache.ListSubscribe<Gs2.Gs2Lottery.Model.LotteryModel>(
(null as Gs2.Gs2Lottery.Model.LotteryModel).CacheParentKey(
this.NamespaceName
),
callback,
() =>
{
#if UNITY_2017_1_OR_NEWER && GS2_ENABLE_UNITASK
async UniTask Impl() {
try {
await UniTask.SwitchToMainThread();
callback.Invoke(await LotteryModelsAsync(
).ToArrayAsync());
}
catch (System.Exception) {
// ignored
}
}
Impl().Forget();
#endif
}
);
}
#if UNITY_2017_1_OR_NEWER && GS2_ENABLE_UNITASK
public async UniTask<ulong> SubscribeLotteryModelsWithInitialCallAsync(
Action<Gs2.Gs2Lottery.Model.LotteryModel[]> callback
)
{
var items = await LotteryModelsAsync(
).ToArrayAsync();
var callbackId = SubscribeLotteryModels(
callback
);
callback.Invoke(items);
return callbackId;
}
#endif
public void UnsubscribeLotteryModels(
ulong callbackId
)
{
this._gs2.Cache.ListUnsubscribe<Gs2.Gs2Lottery.Model.LotteryModel>(
(null as Gs2.Gs2Lottery.Model.LotteryModel).CacheParentKey(
this.NamespaceName
),
callbackId
);
}
public void InvalidateLotteryModels(
)
{
this._gs2.Cache.ClearListCache<Gs2.Gs2Lottery.Model.LotteryModel>(
(null as Gs2.Gs2Lottery.Model.LotteryModel).CacheParentKey(
this.NamespaceName
)
);
}
public Gs2.Gs2Lottery.Domain.Model.LotteryModelDomain LotteryModel(
string lotteryName
) {
return new Gs2.Gs2Lottery.Domain.Model.LotteryModelDomain(
this._gs2,
this.NamespaceName,
lotteryName
);
}
public Gs2.Gs2Lottery.Domain.Model.UserDomain User(
string userId
) {
return new Gs2.Gs2Lottery.Domain.Model.UserDomain(
this._gs2,
this.NamespaceName,
userId
);
}
public UserAccessTokenDomain AccessToken(
AccessToken accessToken
) {
return new UserAccessTokenDomain(
this._gs2,
this.NamespaceName,
accessToken
);
}
#if UNITY_2017_1_OR_NEWER
public Gs2Iterator<Gs2.Gs2Lottery.Model.PrizeTableMaster> PrizeTableMasters(
)
{
return new DescribePrizeTableMastersIterator(
this._gs2,
this._client,
this.NamespaceName
);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if GS2_ENABLE_UNITASK
public IUniTaskAsyncEnumerable<Gs2.Gs2Lottery.Model.PrizeTableMaster> PrizeTableMastersAsync(
#else
public DescribePrizeTableMastersIterator PrizeTableMastersAsync(
#endif
)
{
return new DescribePrizeTableMastersIterator(
this._gs2,
this._client,
this.NamespaceName
#if GS2_ENABLE_UNITASK
).GetAsyncEnumerator();
#else
);
#endif
}
#endif
public ulong SubscribePrizeTableMasters(
Action<Gs2.Gs2Lottery.Model.PrizeTableMaster[]> callback
)
{
return this._gs2.Cache.ListSubscribe<Gs2.Gs2Lottery.Model.PrizeTableMaster>(
(null as Gs2.Gs2Lottery.Model.PrizeTableMaster).CacheParentKey(
this.NamespaceName
),
callback,
() =>
{
#if UNITY_2017_1_OR_NEWER && GS2_ENABLE_UNITASK
async UniTask Impl() {
try {
await UniTask.SwitchToMainThread();
callback.Invoke(await PrizeTableMastersAsync(
).ToArrayAsync());
}
catch (System.Exception) {
// ignored
}
}
Impl().Forget();
#endif
}
);
}
#if UNITY_2017_1_OR_NEWER && GS2_ENABLE_UNITASK
public async UniTask<ulong> SubscribePrizeTableMastersWithInitialCallAsync(
Action<Gs2.Gs2Lottery.Model.PrizeTableMaster[]> callback
)
{
var items = await PrizeTableMastersAsync(
).ToArrayAsync();
var callbackId = SubscribePrizeTableMasters(
callback
);
callback.Invoke(items);
return callbackId;
}
#endif
public void UnsubscribePrizeTableMasters(
ulong callbackId
)
{
this._gs2.Cache.ListUnsubscribe<Gs2.Gs2Lottery.Model.PrizeTableMaster>(
(null as Gs2.Gs2Lottery.Model.PrizeTableMaster).CacheParentKey(
this.NamespaceName
),
callbackId
);
}
public void InvalidatePrizeTableMasters(
)
{
this._gs2.Cache.ClearListCache<Gs2.Gs2Lottery.Model.PrizeTableMaster>(
(null as Gs2.Gs2Lottery.Model.PrizeTableMaster).CacheParentKey(
this.NamespaceName
)
);
}
public Gs2.Gs2Lottery.Domain.Model.PrizeTableMasterDomain PrizeTableMaster(
string prizeTableName
) {
return new Gs2.Gs2Lottery.Domain.Model.PrizeTableMasterDomain(
this._gs2,
this.NamespaceName,
prizeTableName
);
}
#if UNITY_2017_1_OR_NEWER
public Gs2Iterator<Gs2.Gs2Lottery.Model.LotteryModelMaster> LotteryModelMasters(
)
{
return new DescribeLotteryModelMastersIterator(
this._gs2,
this._client,
this.NamespaceName
);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if GS2_ENABLE_UNITASK
public IUniTaskAsyncEnumerable<Gs2.Gs2Lottery.Model.LotteryModelMaster> LotteryModelMastersAsync(
#else
public DescribeLotteryModelMastersIterator LotteryModelMastersAsync(
#endif
)
{
return new DescribeLotteryModelMastersIterator(
this._gs2,
this._client,
this.NamespaceName
#if GS2_ENABLE_UNITASK
).GetAsyncEnumerator();
#else
);
#endif
}
#endif
public ulong SubscribeLotteryModelMasters(
Action<Gs2.Gs2Lottery.Model.LotteryModelMaster[]> callback
)
{
return this._gs2.Cache.ListSubscribe<Gs2.Gs2Lottery.Model.LotteryModelMaster>(
(null as Gs2.Gs2Lottery.Model.LotteryModelMaster).CacheParentKey(
this.NamespaceName
),
callback,
() =>
{
#if UNITY_2017_1_OR_NEWER && GS2_ENABLE_UNITASK
async UniTask Impl() {
try {
await UniTask.SwitchToMainThread();
callback.Invoke(await LotteryModelMastersAsync(
).ToArrayAsync());
}
catch (System.Exception) {
// ignored
}
}
Impl().Forget();
#endif
}
);
}
#if UNITY_2017_1_OR_NEWER && GS2_ENABLE_UNITASK
public async UniTask<ulong> SubscribeLotteryModelMastersWithInitialCallAsync(
Action<Gs2.Gs2Lottery.Model.LotteryModelMaster[]> callback
)
{
var items = await LotteryModelMastersAsync(
).ToArrayAsync();
var callbackId = SubscribeLotteryModelMasters(
callback
);
callback.Invoke(items);
return callbackId;
}
#endif
public void UnsubscribeLotteryModelMasters(
ulong callbackId
)
{
this._gs2.Cache.ListUnsubscribe<Gs2.Gs2Lottery.Model.LotteryModelMaster>(
(null as Gs2.Gs2Lottery.Model.LotteryModelMaster).CacheParentKey(
this.NamespaceName
),
callbackId
);
}
public void InvalidateLotteryModelMasters(
)
{
this._gs2.Cache.ClearListCache<Gs2.Gs2Lottery.Model.LotteryModelMaster>(
(null as Gs2.Gs2Lottery.Model.LotteryModelMaster).CacheParentKey(
this.NamespaceName
)
);
}
public Gs2.Gs2Lottery.Domain.Model.LotteryModelMasterDomain LotteryModelMaster(
string lotteryName
) {
return new Gs2.Gs2Lottery.Domain.Model.LotteryModelMasterDomain(
this._gs2,
this.NamespaceName,
lotteryName
);
}
}
public partial class NamespaceDomain {
#if UNITY_2017_1_OR_NEWER
public IFuture<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> GetStatusFuture(
GetNamespaceStatusRequest request
) {
IEnumerator Impl(IFuture<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> self)
{
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var future = request.InvokeFuture(
_gs2.Cache,
null,
() => this._client.GetNamespaceStatusFuture(request)
);
yield return future;
if (future.Error != null) {
self.OnError(future.Error);
yield break;
}
var result = future.Result;
var domain = this;
this.Status = domain.Status = result?.Status;
self.OnComplete(domain);
}
return new Gs2InlineFuture<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain>(Impl);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if UNITY_2017_1_OR_NEWER
public async UniTask<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> GetStatusAsync(
#else
public async Task<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> GetStatusAsync(
#endif
GetNamespaceStatusRequest request
) {
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var result = await request.InvokeAsync(
_gs2.Cache,
null,
() => this._client.GetNamespaceStatusAsync(request)
);
var domain = this;
this.Status = domain.Status = result?.Status;
return domain;
}
#endif
#if UNITY_2017_1_OR_NEWER
private IFuture<Gs2.Gs2Lottery.Model.Namespace> GetFuture(
GetNamespaceRequest request
) {
IEnumerator Impl(IFuture<Gs2.Gs2Lottery.Model.Namespace> self)
{
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var future = request.InvokeFuture(
_gs2.Cache,
null,
() => this._client.GetNamespaceFuture(request)
);
yield return future;
if (future.Error != null) {
self.OnError(future.Error);
yield break;
}
var result = future.Result;
self.OnComplete(result?.Item);
}
return new Gs2InlineFuture<Gs2.Gs2Lottery.Model.Namespace>(Impl);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if UNITY_2017_1_OR_NEWER
private async UniTask<Gs2.Gs2Lottery.Model.Namespace> GetAsync(
#else
private async Task<Gs2.Gs2Lottery.Model.Namespace> GetAsync(
#endif
GetNamespaceRequest request
) {
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var result = await request.InvokeAsync(
_gs2.Cache,
null,
() => this._client.GetNamespaceAsync(request)
);
return result?.Item;
}
#endif
#if UNITY_2017_1_OR_NEWER
public IFuture<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> UpdateFuture(
UpdateNamespaceRequest request
) {
IEnumerator Impl(IFuture<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> self)
{
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var future = request.InvokeFuture(
_gs2.Cache,
null,
() => this._client.UpdateNamespaceFuture(request)
);
yield return future;
if (future.Error != null) {
self.OnError(future.Error);
yield break;
}
var result = future.Result;
var domain = this;
self.OnComplete(domain);
}
return new Gs2InlineFuture<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain>(Impl);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if UNITY_2017_1_OR_NEWER
public async UniTask<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> UpdateAsync(
#else
public async Task<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> UpdateAsync(
#endif
UpdateNamespaceRequest request
) {
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var result = await request.InvokeAsync(
_gs2.Cache,
null,
() => this._client.UpdateNamespaceAsync(request)
);
var domain = this;
return domain;
}
#endif
#if UNITY_2017_1_OR_NEWER
public IFuture<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> DeleteFuture(
DeleteNamespaceRequest request
) {
IEnumerator Impl(IFuture<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> self)
{
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var future = request.InvokeFuture(
_gs2.Cache,
null,
() => this._client.DeleteNamespaceFuture(request)
);
yield return future;
if (future.Error != null) {
if (!(future.Error is NotFoundException)) {
self.OnError(future.Error);
yield break;
}
}
var result = future.Result;
var domain = this;
self.OnComplete(domain);
}
return new Gs2InlineFuture<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain>(Impl);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if UNITY_2017_1_OR_NEWER
public async UniTask<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> DeleteAsync(
#else
public async Task<Gs2.Gs2Lottery.Domain.Model.NamespaceDomain> DeleteAsync(
#endif
DeleteNamespaceRequest request
) {
try {
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var result = await request.InvokeAsync(
_gs2.Cache,
null,
() => this._client.DeleteNamespaceAsync(request)
);
}
catch (NotFoundException e) {}
var domain = this;
return domain;
}
#endif
#if UNITY_2017_1_OR_NEWER
public IFuture<Gs2.Gs2Lottery.Domain.Model.PrizeTableMasterDomain> CreatePrizeTableMasterFuture(
CreatePrizeTableMasterRequest request
) {
IEnumerator Impl(IFuture<Gs2.Gs2Lottery.Domain.Model.PrizeTableMasterDomain> self)
{
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var future = request.InvokeFuture(
_gs2.Cache,
null,
() => this._client.CreatePrizeTableMasterFuture(request)
);
yield return future;
if (future.Error != null) {
self.OnError(future.Error);
yield break;
}
var result = future.Result;
var domain = new Gs2.Gs2Lottery.Domain.Model.PrizeTableMasterDomain(
this._gs2,
this.NamespaceName,
result?.Item?.Name
);
self.OnComplete(domain);
}
return new Gs2InlineFuture<Gs2.Gs2Lottery.Domain.Model.PrizeTableMasterDomain>(Impl);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if UNITY_2017_1_OR_NEWER
public async UniTask<Gs2.Gs2Lottery.Domain.Model.PrizeTableMasterDomain> CreatePrizeTableMasterAsync(
#else
public async Task<Gs2.Gs2Lottery.Domain.Model.PrizeTableMasterDomain> CreatePrizeTableMasterAsync(
#endif
CreatePrizeTableMasterRequest request
) {
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var result = await request.InvokeAsync(
_gs2.Cache,
null,
() => this._client.CreatePrizeTableMasterAsync(request)
);
var domain = new Gs2.Gs2Lottery.Domain.Model.PrizeTableMasterDomain(
this._gs2,
this.NamespaceName,
result?.Item?.Name
);
return domain;
}
#endif
#if UNITY_2017_1_OR_NEWER
public IFuture<Gs2.Gs2Lottery.Domain.Model.LotteryModelMasterDomain> CreateLotteryModelMasterFuture(
CreateLotteryModelMasterRequest request
) {
IEnumerator Impl(IFuture<Gs2.Gs2Lottery.Domain.Model.LotteryModelMasterDomain> self)
{
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var future = request.InvokeFuture(
_gs2.Cache,
null,
() => this._client.CreateLotteryModelMasterFuture(request)
);
yield return future;
if (future.Error != null) {
self.OnError(future.Error);
yield break;
}
var result = future.Result;
var domain = new Gs2.Gs2Lottery.Domain.Model.LotteryModelMasterDomain(
this._gs2,
this.NamespaceName,
result?.Item?.Name
);
self.OnComplete(domain);
}
return new Gs2InlineFuture<Gs2.Gs2Lottery.Domain.Model.LotteryModelMasterDomain>(Impl);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if UNITY_2017_1_OR_NEWER
public async UniTask<Gs2.Gs2Lottery.Domain.Model.LotteryModelMasterDomain> CreateLotteryModelMasterAsync(
#else
public async Task<Gs2.Gs2Lottery.Domain.Model.LotteryModelMasterDomain> CreateLotteryModelMasterAsync(
#endif
CreateLotteryModelMasterRequest request
) {
request = request
.WithContextStack(string.IsNullOrEmpty(request.ContextStack) ? this._gs2.DefaultContextStack : request.ContextStack)
.WithNamespaceName(this.NamespaceName);
var result = await request.InvokeAsync(
_gs2.Cache,
null,
() => this._client.CreateLotteryModelMasterAsync(request)
);
var domain = new Gs2.Gs2Lottery.Domain.Model.LotteryModelMasterDomain(
this._gs2,
this.NamespaceName,
result?.Item?.Name
);
return domain;
}
#endif
}
public partial class NamespaceDomain {
#if UNITY_2017_1_OR_NEWER
public IFuture<Gs2.Gs2Lottery.Model.Namespace> ModelFuture()
{
IEnumerator Impl(IFuture<Gs2.Gs2Lottery.Model.Namespace> self)
{
var (value, find) = (null as Gs2.Gs2Lottery.Model.Namespace).GetCache(
this._gs2.Cache,
this.NamespaceName
);
if (find) {
self.OnComplete(value);
yield break;
}
var future = (null as Gs2.Gs2Lottery.Model.Namespace).FetchFuture(
this._gs2.Cache,
this.NamespaceName,
() => this.GetFuture(
new GetNamespaceRequest()
)
);
yield return future;
if (future.Error != null) {
self.OnError(future.Error);
yield break;
}
self.OnComplete(future.Result);
}
return new Gs2InlineFuture<Gs2.Gs2Lottery.Model.Namespace>(Impl);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if UNITY_2017_1_OR_NEWER
public async UniTask<Gs2.Gs2Lottery.Model.Namespace> ModelAsync()
#else
public async Task<Gs2.Gs2Lottery.Model.Namespace> ModelAsync()
#endif
{
using (await this._gs2.Cache.GetLockObject<Gs2.Gs2Lottery.Model.Namespace>(
(null as Gs2.Gs2Lottery.Model.Namespace).CacheParentKey(
),
(null as Gs2.Gs2Lottery.Model.Namespace).CacheKey(
this.NamespaceName
)
).LockAsync()) {
var (value, find) = (null as Gs2.Gs2Lottery.Model.Namespace).GetCache(
this._gs2.Cache,
this.NamespaceName
);
if (find) {
return value;
}
return await (null as Gs2.Gs2Lottery.Model.Namespace).FetchAsync(
this._gs2.Cache,
this.NamespaceName,
() => this.GetAsync(
new GetNamespaceRequest()
)
);
}
}
#endif
#if UNITY_2017_1_OR_NEWER
#if GS2_ENABLE_UNITASK
[Obsolete("The name has been changed to ModelAsync.")]
public async UniTask<Gs2.Gs2Lottery.Model.Namespace> Model()
{
return await ModelAsync();
}
#else
[Obsolete("The name has been changed to ModelFuture.")]
public IFuture<Gs2.Gs2Lottery.Model.Namespace> Model()
{
return ModelFuture();
}
#endif
#else
[Obsolete("The name has been changed to ModelAsync.")]
public async Task<Gs2.Gs2Lottery.Model.Namespace> Model()
{
return await ModelAsync();
}
#endif
public void Invalidate()
{
(null as Gs2.Gs2Lottery.Model.Namespace).DeleteCache(
this._gs2.Cache,
this.NamespaceName
);
}
public ulong Subscribe(Action<Gs2.Gs2Lottery.Model.Namespace> callback)
{
return this._gs2.Cache.Subscribe(
(null as Gs2.Gs2Lottery.Model.Namespace).CacheParentKey(
),
(null as Gs2.Gs2Lottery.Model.Namespace).CacheKey(
this.NamespaceName
),
callback,
() =>
{
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if GS2_ENABLE_UNITASK
async UniTask Impl() {
#else
async Task Impl() {
#endif
try {
await ModelAsync();
}
catch (System.Exception) {
// ignored
}
}
#if GS2_ENABLE_UNITASK
Impl().Forget();
#else
Impl();
#endif
#endif
}
);
}
public void Unsubscribe(ulong callbackId)
{
this._gs2.Cache.Unsubscribe<Gs2.Gs2Lottery.Model.Namespace>(
(null as Gs2.Gs2Lottery.Model.Namespace).CacheParentKey(
),
(null as Gs2.Gs2Lottery.Model.Namespace).CacheKey(
this.NamespaceName
),
callbackId
);
}
#if UNITY_2017_1_OR_NEWER
public Gs2Future<ulong> SubscribeWithInitialCallFuture(Action<Gs2.Gs2Lottery.Model.Namespace> callback)
{
IEnumerator Impl(IFuture<ulong> self)
{
var future = ModelFuture();
yield return future;
if (future.Error != null) {
self.OnError(future.Error);
yield break;
}
var item = future.Result;
var callbackId = Subscribe(callback);
callback.Invoke(item);
self.OnComplete(callbackId);
}
return new Gs2InlineFuture<ulong>(Impl);
}
#endif
#if !UNITY_2017_1_OR_NEWER || GS2_ENABLE_UNITASK
#if UNITY_2017_1_OR_NEWER
public async UniTask<ulong> SubscribeWithInitialCallAsync(Action<Gs2.Gs2Lottery.Model.Namespace> callback)
#else
public async Task<ulong> SubscribeWithInitialCallAsync(Action<Gs2.Gs2Lottery.Model.Namespace> callback)
#endif
{
var item = await ModelAsync();
var callbackId = Subscribe(callback);
callback.Invoke(item);
return callbackId;
}
#endif
}
}