Repository URL to install this package:
|
Version:
2022.5.6 ▾
|
/*
* Copyright 2016 Game Server Services, Inc. or its affiliates. All Rights
* Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* or in the "license" file accompanying this file. This file is distributed
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
// 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
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.Request;
using Gs2.Gs2Lottery.Result;
using Gs2.Gs2Auth.Model;
using Gs2.Util.LitJson;
using Gs2.Core;
using Gs2.Core.Domain;
using Gs2.Core.Util;
#if UNITY_2017_1_OR_NEWER
using UnityEngine.Scripting;
using System.Collections;
#if GS2_ENABLE_UNITASK
using Cysharp.Threading;
using Cysharp.Threading.Tasks;
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 LotteryDomain {
private readonly CacheDatabase _cache;
private readonly JobQueueDomain _jobQueueDomain;
private readonly StampSheetConfiguration _stampSheetConfiguration;
private readonly Gs2RestSession _session;
private readonly Gs2LotteryRestClient _client;
private readonly string _namespaceName;
private readonly string _userId;
private readonly String _parentKey;
public string NamespaceName => _namespaceName;
public string UserId => _userId;
public LotteryDomain(
CacheDatabase cache,
JobQueueDomain jobQueueDomain,
StampSheetConfiguration stampSheetConfiguration,
Gs2RestSession session,
string namespaceName,
string userId
) {
this._cache = cache;
this._jobQueueDomain = jobQueueDomain;
this._stampSheetConfiguration = stampSheetConfiguration;
this._session = session;
this._client = new Gs2LotteryRestClient(
session
);
this._namespaceName = namespaceName;
this._userId = userId;
this._parentKey = Gs2.Gs2Lottery.Domain.Model.UserDomain.CreateCacheParentKey(
this._namespaceName != null ? this._namespaceName.ToString() : null,
this._userId != null ? this._userId.ToString() : null,
"Lottery"
);
}
#if UNITY_2017_1_OR_NEWER
#if GS2_ENABLE_UNITASK
public async UniTask<Gs2.Gs2Lottery.Domain.Model.LotteryDomain> DrawAsync(
#else
public IFuture<Gs2.Gs2Lottery.Domain.Model.LotteryDomain> Draw(
#endif
#else
public async Task<Gs2.Gs2Lottery.Domain.Model.LotteryDomain> DrawAsync(
#endif
DrawByUserIdRequest request
) {
#if UNITY_2017_1_OR_NEWER && !GS2_ENABLE_UNITASK
IEnumerator Impl(IFuture<Gs2.Gs2Lottery.Domain.Model.LotteryDomain> self)
{
#endif
request
.WithNamespaceName(this._namespaceName)
.WithUserId(this._userId);
#if UNITY_2017_1_OR_NEWER && !GS2_ENABLE_UNITASK
var future = this._client.DrawByUserIdFuture(
request
);
yield return future;
if (future.Error != null)
{
self.OnError(future.Error);
yield break;
}
var result = future.Result;
var requestModel = request;
var resultModel = result;
var cache = _cache;
#else
var result = await this._client.DrawByUserIdAsync(
request
);
var requestModel = request;
var resultModel = result;
var cache = _cache;
#endif
if (result?.StampSheet != null)
{
Gs2.Core.Domain.StampSheetDomain stampSheet = new Gs2.Core.Domain.StampSheetDomain(
_cache,
_jobQueueDomain,
_session,
result?.StampSheet,
result?.StampSheetEncryptionKeyId,
_stampSheetConfiguration.NamespaceName,
_stampSheetConfiguration.StampTaskEventHandler,
_stampSheetConfiguration.StampSheetEventHandler
);
#if UNITY_2017_1_OR_NEWER && !GS2_ENABLE_UNITASK
yield return stampSheet.Run();
#else
try {
await stampSheet.RunAsync();
} catch (Gs2.Core.Exception.Gs2Exception e) {
throw new Gs2.Core.Exception.TransactionException(stampSheet, e);
}
#endif
}
#if UNITY_2017_1_OR_NEWER && !GS2_ENABLE_UNITASK
self.OnComplete(this);
#else
return this;
#endif
#if UNITY_2017_1_OR_NEWER && !GS2_ENABLE_UNITASK
}
return new Gs2InlineFuture<Gs2.Gs2Lottery.Domain.Model.LotteryDomain>(Impl);
#endif
}
public static string CreateCacheParentKey(
string namespaceName,
string userId,
string childType
)
{
return string.Join(
":",
"lottery",
namespaceName ?? "null",
userId ?? "null",
childType
);
}
public static string CreateCacheKey(
)
{
return "Singleton";
}
}
}