feat(battle-engine): M1 auto-copy closure (782 battle-logic files)
Compile-driven bulk-copy loop (tools/engine-port/m1_copy_loop.py) pulled the precise reference closure of the battle-core roots, stopping at the classify god-object/View-VFX-UI boundary. 782 files; no re-explosion (M0 had estimated ~order 1000). Residual frontier = 52 shim-classified + 80 external (Unity/BCL) types to author next.
This commit is contained in:
gamer147
406
SVSim.BattleEngine/Engine/Cute/NetworkManager.cs
Normal file
406
SVSim.BattleEngine/Engine/Cute/NetworkManager.cs
Normal file
@@ -0,0 +1,406 @@
|
||||
using System;
|
||||
using System.Collections;
|
||||
using System.Collections.Generic;
|
||||
using LitJson;
|
||||
using MessagePack;
|
||||
using UnityEngine;
|
||||
using UnityEngine.Networking;
|
||||
using Wizard;
|
||||
using Wizard.Battle.Phase;
|
||||
using Wizard.Bingo;
|
||||
using Wizard.Scripts.Network.Data.TaskData.BuildDeckPurchase;
|
||||
using Wizard.Scripts.Network.Data.TaskData.ItemPurchase;
|
||||
using Wizard.Scripts.Network.Data.TaskData.SkinPurchase;
|
||||
using Wizard.Scripts.Network.Data.TaskData.SpotCardExchange;
|
||||
|
||||
namespace Cute;
|
||||
|
||||
public class NetworkManager : MonoBehaviour, IManager
|
||||
{
|
||||
public const float TimeOut = 30f;
|
||||
|
||||
public const float TimeOutShort = 2f;
|
||||
|
||||
protected NetworkTask lastRequestTask;
|
||||
|
||||
public bool isConnect;
|
||||
|
||||
public bool isTimeOut;
|
||||
|
||||
public bool isError;
|
||||
|
||||
private bool isEncrypt = true;
|
||||
|
||||
private bool isUseJson;
|
||||
|
||||
private bool _showLoadingIcon = true;
|
||||
|
||||
private IEnumerator connectCoroutine;
|
||||
|
||||
[SerializeField]
|
||||
public Certification _certification;
|
||||
|
||||
public INetworkUI NetworkUI { get; set; }
|
||||
|
||||
private void Start()
|
||||
{
|
||||
Toolbox.NetworkManager = this;
|
||||
}
|
||||
|
||||
public bool IsReachability()
|
||||
{
|
||||
if (Application.internetReachability != NetworkReachability.NotReachable)
|
||||
{
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
public IEnumerator Connect(NetworkTask task, Action<NetworkTask.ResultCode> callbackOnSuccess = null, Action<NetworkTask.ResultCode> callbackOnFailure = null, Action<int> callbackOnResultCodeError = null, bool encrypt = true, bool useJson = false, bool showLoadingIcon = true, bool showErrorDialog = true)
|
||||
{
|
||||
while (isConnect)
|
||||
{
|
||||
yield return 0;
|
||||
}
|
||||
isEncrypt = encrypt;
|
||||
isUseJson = useJson;
|
||||
_showLoadingIcon = showLoadingIcon;
|
||||
if (true)
|
||||
{
|
||||
if (IsBattle())
|
||||
{
|
||||
LocalLog.AccumulateLastTraceLog("taskStart " + task);
|
||||
}
|
||||
lastRequestTask = task;
|
||||
lastRequestTask.Initialize();
|
||||
lastRequestTask.CallbackOnSuccess = callbackOnSuccess;
|
||||
lastRequestTask.CallbackOnFailure = callbackOnFailure;
|
||||
lastRequestTask.CallbackOnResultCodeError = callbackOnResultCodeError;
|
||||
lastRequestTask.PrepareHeaders();
|
||||
lastRequestTask.PreparePostData(isEncrypt, isUseJson);
|
||||
connectCoroutine = Connect(showErrorDialog);
|
||||
yield return StartCoroutine(connectCoroutine);
|
||||
}
|
||||
}
|
||||
|
||||
private IEnumerator Connect(bool showErrorDialog)
|
||||
{
|
||||
while (isConnect)
|
||||
{
|
||||
yield return 0;
|
||||
}
|
||||
isConnect = true;
|
||||
isTimeOut = false;
|
||||
isError = false;
|
||||
if (NetworkUI != null && _showLoadingIcon)
|
||||
{
|
||||
NetworkUI.StartLoading();
|
||||
}
|
||||
bool isLogTraceCheckUri = false;
|
||||
if (lastRequestTask is DoMatchingBase || lastRequestTask is FinishTaskBase)
|
||||
{
|
||||
isLogTraceCheckUri = true;
|
||||
}
|
||||
string url = lastRequestTask.Url;
|
||||
_ = lastRequestTask;
|
||||
if (isLogTraceCheckUri)
|
||||
{
|
||||
LogTraceCheck("1");
|
||||
}
|
||||
using UnityWebRequest unityWebRequest = GetUnityWebRequestInstance(url);
|
||||
yield return unityWebRequest.SendWebRequest();
|
||||
if (isLogTraceCheckUri)
|
||||
{
|
||||
LogTraceCheck("2");
|
||||
}
|
||||
float endTime = Time.realtimeSinceStartup + 30f;
|
||||
if (lastRequestTask.GetType().Equals(typeof(CheckSpecialTitleTask)))
|
||||
{
|
||||
endTime = Time.realtimeSinceStartup + 2f;
|
||||
}
|
||||
while (!unityWebRequest.isDone && Time.realtimeSinceStartup < endTime)
|
||||
{
|
||||
yield return 0;
|
||||
}
|
||||
if (isLogTraceCheckUri)
|
||||
{
|
||||
LogTraceCheck("3");
|
||||
}
|
||||
if (NetworkUI != null)
|
||||
{
|
||||
NetworkUI.StopLoading();
|
||||
}
|
||||
if (!unityWebRequest.isDone)
|
||||
{
|
||||
isTimeOut = true;
|
||||
LocalLog.AccumulateTraceLog("Connect is TimeOut");
|
||||
disposeUnityWebRequest(unityWebRequest);
|
||||
if (!lastRequestTask.isSkipCommonTimeOutPopUp())
|
||||
{
|
||||
if (lastRequestTask.GetType().Equals(typeof(PackOpenTask)) || lastRequestTask.GetType().Equals(typeof(BuildDeckBuyTask)) || lastRequestTask.GetType().Equals(typeof(SleeveBuyTask)) || lastRequestTask.GetType().Equals(typeof(SkinBuyMultiRewardTask)) || lastRequestTask.GetType().Equals(typeof(SkinBuyMultiTask)) || lastRequestTask.GetType().Equals(typeof(SkinBuySingleTask)) || lastRequestTask.GetType().Equals(typeof(ItemPurchaseBuyTask)) || lastRequestTask.GetType().Equals(typeof(SpotCardExchangeTask)) || lastRequestTask.GetType().Equals(typeof(CardCreateTask)) || lastRequestTask.GetType().Equals(typeof(CardDestructTask)) || lastRequestTask.GetType().Equals(typeof(StoryFinishTask)) || lastRequestTask.GetType().Equals(typeof(PracticeFinishTask)) || lastRequestTask.GetType().Equals(typeof(BingoDrawTask)) || lastRequestTask.GetType().Equals(typeof(MypageTreasureBoxCpOpenTask)) || lastRequestTask.GetType().Equals(typeof(MypageReceiveSpecialTreasureTask)) || lastRequestTask.GetType().Equals(typeof(FreeCardPackCampaignFinishTask)))
|
||||
{
|
||||
NetworkUI.OpenGoToTitleErrorPopUp(Data.SystemText.Get("ErrorHeader_0012"), Data.SystemText.Get("Error_0012"), "");
|
||||
}
|
||||
else
|
||||
{
|
||||
NetworkUI.OpenTimeOutErrorPopUp();
|
||||
}
|
||||
}
|
||||
if (lastRequestTask.CallbackOnFailure != null)
|
||||
{
|
||||
if (lastRequestTask.GetType().Equals(typeof(PaymentPCFinishTask)))
|
||||
{
|
||||
NetworkUI.OpenGoToTitleErrorPopUp(Data.SystemText.Get("ErrorHeader_0012"), Data.SystemText.Get("Error_0012"), "");
|
||||
}
|
||||
else
|
||||
{
|
||||
lastRequestTask.CallbackOnFailure(NetworkTask.ResultCode.TimeOut);
|
||||
}
|
||||
}
|
||||
Toolbox.DeviceManager.ClearIpAddress();
|
||||
}
|
||||
else if (!string.IsNullOrEmpty(unityWebRequest.error))
|
||||
{
|
||||
LocalLog.AccumulateTraceLog("Connect is Error!" + unityWebRequest.error + " responseCode:" + unityWebRequest.responseCode);
|
||||
isError = true;
|
||||
if (showErrorDialog && !lastRequestTask.isSkipCommonHttpStatusErrorPopUp())
|
||||
{
|
||||
if (lastRequestTask.GetType().Equals(typeof(PackOpenTask)) || lastRequestTask.GetType().Equals(typeof(PaymentPCFinishTask)))
|
||||
{
|
||||
NetworkUI.OpenGoToTitleErrorPopUp(Data.SystemText.Get("ErrorHeader_0012"), Data.SystemText.Get("Error_0012"), "");
|
||||
}
|
||||
else
|
||||
{
|
||||
NetworkUI.OpenHttpStatusErrorPopUp();
|
||||
}
|
||||
}
|
||||
disposeUnityWebRequest(unityWebRequest);
|
||||
if (lastRequestTask.CallbackOnFailure != null)
|
||||
{
|
||||
lastRequestTask.CallbackOnFailure(NetworkTask.ResultCode.Error);
|
||||
}
|
||||
Toolbox.DeviceManager.ClearIpAddress();
|
||||
}
|
||||
else if (unityWebRequest.isDone)
|
||||
{
|
||||
if (lastRequestTask.CallbackOnUnityWebRequestDone != null)
|
||||
{
|
||||
lastRequestTask.CallbackOnUnityWebRequestDone(unityWebRequest);
|
||||
}
|
||||
else if (unityWebRequest.downloadHandler.text != null && unityWebRequest.downloadHandler.text != "")
|
||||
{
|
||||
try
|
||||
{
|
||||
byte[] bytes = ((!isEncrypt) ? Convert.FromBase64String(unityWebRequest.downloadHandler.text) : CryptAES.decrypt(unityWebRequest.downloadHandler.text));
|
||||
string json = (isUseJson ? MessagePackSerializer.ToJson(bytes) : MessagePackSerializer.ToJson(bytes));
|
||||
lastRequestTask.SetResponseData(JsonMapper.ToObject(json));
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
string text = unityWebRequest.downloadHandler.text;
|
||||
disposeUnityWebRequest(unityWebRequest);
|
||||
if (!lastRequestTask.GetType().Equals(typeof(CheckSpecialTitleTask)))
|
||||
{
|
||||
if (!isEncrypt)
|
||||
{
|
||||
LocalLog.AccumulateTraceLog(ex.ToString());
|
||||
throw ex;
|
||||
}
|
||||
Debug.LogError(text);
|
||||
Debug.LogError(ex.Message);
|
||||
Debug.LogError(ex.StackTrace);
|
||||
if (text.Contains("php"))
|
||||
{
|
||||
if (text.Length > 1800)
|
||||
{
|
||||
throw new Exception(text.Substring(1, 1800));
|
||||
}
|
||||
throw new Exception(text);
|
||||
}
|
||||
HandleDeserializeException(ex);
|
||||
}
|
||||
}
|
||||
try
|
||||
{
|
||||
if (lastRequestTask != null)
|
||||
{
|
||||
if (lastRequestTask.GetType().Equals(typeof(CheckSpecialTitleTask)))
|
||||
{
|
||||
((CheckSpecialTitleTask)lastRequestTask).ParseTitleCheckData();
|
||||
}
|
||||
else
|
||||
{
|
||||
NetworkTask.ERROR_CODE_STATUS num = lastRequestTask.CheckResultCodeToPopupCreate_ReturnStatus();
|
||||
if (num == NetworkTask.ERROR_CODE_STATUS.ERROR)
|
||||
{
|
||||
isError = true;
|
||||
}
|
||||
if (num == NetworkTask.ERROR_CODE_STATUS.ERROR_TO_MAINTENANCE_POPUP && lastRequestTask.CallbackOnFailure != null)
|
||||
{
|
||||
lastRequestTask.CallbackOnFailure(NetworkTask.ResultCode.Maintenance);
|
||||
}
|
||||
if (num == NetworkTask.ERROR_CODE_STATUS.ERROR && lastRequestTask.CallbackOnFailure != null)
|
||||
{
|
||||
lastRequestTask.CallbackOnFailure(NetworkTask.ResultCode.Title);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (Exception ex2)
|
||||
{
|
||||
disposeUnityWebRequest(unityWebRequest);
|
||||
if (!lastRequestTask.GetType().Equals(typeof(CheckSpecialTitleTask)))
|
||||
{
|
||||
LocalLog.AccumulateTraceLog("NetworkManager Connect Error 2：" + ex2);
|
||||
throw ex2;
|
||||
}
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
LocalLog.AccumulateTraceLog("NetworkManager Connect Error 3");
|
||||
}
|
||||
}
|
||||
ClearLastRequestTask();
|
||||
disposeUnityWebRequest(unityWebRequest);
|
||||
isConnect = false;
|
||||
}
|
||||
|
||||
private void LogTraceCheck(string logMsg)
|
||||
{
|
||||
LocalLog.AccumulateLastTraceLog("NetworkTrace msg " + logMsg);
|
||||
LocalLog.SubmitAccumulateLastTraceLog();
|
||||
}
|
||||
|
||||
private bool IsBattle()
|
||||
{
|
||||
if (ToolboxGame.RealTimeNetworkAgent != null && BattleManagerBase.GetIns() != null && BattleManagerBase.GetIns().GetCurrentPhase() is MainPhase)
|
||||
{
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
private UnityWebRequest GetUnityWebRequestInstance(string serverUrl)
|
||||
{
|
||||
try
|
||||
{
|
||||
UnityWebRequest unityWebRequest = new UnityWebRequest(serverUrl, "POST");
|
||||
unityWebRequest.uploadHandler = new UploadHandlerRaw(lastRequestTask.Body);
|
||||
unityWebRequest.downloadHandler = new DownloadHandlerBuffer();
|
||||
foreach (KeyValuePair<string, string> item in lastRequestTask.Header)
|
||||
{
|
||||
unityWebRequest.SetRequestHeader(item.Key, item.Value);
|
||||
}
|
||||
return unityWebRequest;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
string text = "";
|
||||
foreach (KeyValuePair<string, string> item2 in lastRequestTask.Header)
|
||||
{
|
||||
text += string.Format("header==={0} : {1}" + Environment.NewLine, item2.Key, item2.Value);
|
||||
}
|
||||
Debug.LogError(ex?.ToString() + "：" + text);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
private void HandleDeserializeException(Exception e)
|
||||
{
|
||||
SoftwareReset.exec();
|
||||
throw new Exception("復号化に失敗しました。" + e);
|
||||
}
|
||||
|
||||
public void ClearLastRequestTask()
|
||||
{
|
||||
if ((NetworkUI != null && !NetworkUI.IsKeepLastRequest()) || lastRequestTask.isServerResultCodeOK())
|
||||
{
|
||||
if (IsBattle())
|
||||
{
|
||||
LocalLog.AccumulateLastTraceLog("ClearLastRequestTask " + lastRequestTask);
|
||||
}
|
||||
lastRequestTask = null;
|
||||
}
|
||||
}
|
||||
|
||||
public IEnumerator Retry()
|
||||
{
|
||||
if (lastRequestTask == null)
|
||||
{
|
||||
NetworkUI.OpenRetryFailErrorPopup();
|
||||
yield break;
|
||||
}
|
||||
if (connectCoroutine != null)
|
||||
{
|
||||
StopConnectCoroutine();
|
||||
}
|
||||
connectCoroutine = Connect(showErrorDialog: true);
|
||||
yield return StartCoroutine(connectCoroutine);
|
||||
}
|
||||
|
||||
public void Certification()
|
||||
{
|
||||
_certification.GenerateUdid();
|
||||
}
|
||||
|
||||
public void ReturnToTitle()
|
||||
{
|
||||
NetworkUI.SetKeepLastRequest(flag: false);
|
||||
ClearLastRequestTask();
|
||||
NetworkUI.SoftwareRest();
|
||||
}
|
||||
|
||||
public void GoToMypage()
|
||||
{
|
||||
NetworkUI.SetKeepLastRequest(flag: false);
|
||||
ClearLastRequestTask();
|
||||
NetworkUI.GoToMypage();
|
||||
}
|
||||
|
||||
public void GoToStore()
|
||||
{
|
||||
lastRequestTask.GotoStore();
|
||||
NetworkUI.SetKeepLastRequest(flag: false);
|
||||
ClearLastRequestTask();
|
||||
NetworkUI.SoftwareRest();
|
||||
}
|
||||
|
||||
public void QuitApplication()
|
||||
{
|
||||
NetworkUI.SetKeepLastRequest(flag: false);
|
||||
ClearLastRequestTask();
|
||||
if (Toolbox.mute != null)
|
||||
{
|
||||
Toolbox.mute.Close();
|
||||
Toolbox.mute = null;
|
||||
}
|
||||
Application.Quit();
|
||||
}
|
||||
|
||||
private void disposeUnityWebRequest(UnityWebRequest unityWebRequest)
|
||||
{
|
||||
unityWebRequest.Dispose();
|
||||
}
|
||||
|
||||
public void StopConnectCoroutine()
|
||||
{
|
||||
if (connectCoroutine != null)
|
||||
{
|
||||
if (RealTimeNetworkAgent.IsNormalNetworkBattle())
|
||||
{
|
||||
LocalLog.AccumulateLastTraceLog("NetworkManager_StopConnectCoroutine " + StackTraceUtility.ExtractStackTrace());
|
||||
}
|
||||
StopCoroutine(connectCoroutine);
|
||||
isConnect = false;
|
||||
}
|
||||
}
|
||||
|
||||
private void OnDestroy()
|
||||
{
|
||||
if (RealTimeNetworkAgent.IsNormalNetworkBattle())
|
||||
{
|
||||
LocalLog.AccumulateLastTraceLog("NetworkManager_Destroy");
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user