Files
SVSimServer/SVSim.BattleEngine/Engine/NetworkBattleSender.cs
gamer147 0d9d8acae0 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.
2026-06-05 16:57:20 -04:00

471 lines
16 KiB
C#

using System;
using System.Collections;
using System.Collections.Generic;
using Cute;
using UnityEngine;
using Wizard;
public class NetworkBattleSender
{
public class EmitData
{
public string Uri { get; private set; }
public Dictionary<string, object> Data { get; private set; }
public int SeqNumber { get; private set; }
public EmitData(string uri, Dictionary<string, object> data, int seqNumber)
{
Uri = uri;
Data = data;
SeqNumber = seqNumber;
}
}
public enum JUDGE_RESULT_STATUS
{
BattleFinishToJudge = 100,
RecoveryBattleFinishToJudge = 110,
RetrySend = 200,
FailedToRetryJudgeResult = 201,
OppoDisconnectVictory = 300,
DisconnectLose = 301,
ServerSendDisconnectCheck = 302,
OpponentNotTurnStartVictory = 400,
TurnStartLose = 401,
OpponentNotTurnEndVictory = 500,
TurnEndLose = 501,
OppoNotMulliganVictory = 600,
MulliganLose = 601,
BattleStopToJudgeResult = 700,
ReceiveRetire = 800,
ReplayRetireDiff = 801,
ReceiveConsistencyLose = 900,
Invalid = 901,
WatchJudgeResult = 1000,
RecoveryError = 1100,
SwapTimeoutError = 1200,
Debug = 9999
}
public enum SELECT_SKILL_OPERATION
{
StartSelect,
SelectCard,
CancelSelect,
StartChoiceSelect,
SelectChoiceCard,
CancelChoiceSelect,
CompleteChoiceSelect,
CompleteSelect,
StartFusionSelect,
SelectFusionIngredient,
CompleteFusionSelect
}
public enum SELECT_OBJECT_TARGET_TYPE
{
Deselect,
Select
}
public enum SLIDE_OBJECT_TYPE
{
Cancel,
Attack,
Evolve
}
public enum HAND_URI_TYPE
{
TOUCH_URI = 1,
SELECT_SKILL_URI = 2,
SELECT_OBJECT_URI = 3,
TURN_END_READY_URI = 4,
SLIDE_OBJECT_URI = 5,
HAND_NODE_ERROR = 99
}
private NetworkBattleManagerBase _battleMgr;
private NetworkConsistency _networkConsistency;
private SendCardDataMaker _sendCardDataMaker;
private List<EmitData> _alreadyEmitList = new List<EmitData>();
public const float RETRY_INTERVAL = 0.5f;
private bool _isEmitStop_OutsideJudgeResult;
public static string PlayActionLogMsg = "";
private int _lastTouchIndex;
private BattleCardBase _lastSelectedCard;
private BattleCardBase _selectedSlideCard;
private List<object> _emitHandParameterList = new List<object>();
private DateTime _oldSlideCurrentLocalTime;
private DateTime _oldSelectCurrentLocalTime;
public NetworkBattleSender(NetworkBattleManagerBase battlemgr, RegisterActionManager registerList, List<RegisterUnapproved> unapprovedList, NetworkConsistency consistency)
{
_battleMgr = battlemgr;
_networkConsistency = consistency;
_sendCardDataMaker = new SendCardDataMaker(battlemgr, registerList, unapprovedList);
}
public void SendDeal()
{
if (!_battleMgr.IsRecovery)
{
EmitMsg(NetworkBattleDefine.NetworkBattleURI.Deal);
}
}
public void SendSwapInfo(List<int> swapIndexList)
{
if (!_battleMgr.IsRecovery)
{
Dictionary<string, object> dictionary = new Dictionary<string, object>();
dictionary.Add("idxList", swapIndexList);
EmitMsg(NetworkBattleDefine.NetworkBattleURI.Swap, dictionary);
}
}
public void SendTurnStart()
{
Dictionary<string, object> dictionary = _sendCardDataMaker.MakePlayActionsSendCardData(null, null, null, isEvol: false, null, isTurnStart: true);
dictionary.Add("actionSeq", ToolboxGame.RealTimeNetworkAgent.GetTurnSequence());
EmitMsg(NetworkBattleDefine.NetworkBattleURI.TurnStart, dictionary);
}
public void SendPlayCard(BattleCardBase playCard, List<BattleCardBase> targetCardList, List<NetworkBattleManagerBase.ValidateSkillData> validateSkillIndexList, SendKeyActionDataManager sendKeyActionDataManager, List<int> selectTypeSkillIndexList)
{
if (playCard == null)
{
LocalLog.AccumulateLastTraceLog("SendPlayCard Err playCard Null");
}
Dictionary<string, object> dictionary = _sendCardDataMaker.MakePlayActionsSendCardData(playCard, targetCardList, validateSkillIndexList, isEvol: false, sendKeyActionDataManager, isTurnStart: false, selectTypeSkillIndexList);
if (targetCardList != null && targetCardList.Count >= 1)
{
dictionary[NetworkBattleDefine.NetworkParameterNames[NetworkBattleDefine.NetworkParameter.type]] = 31;
}
else
{
dictionary[NetworkBattleDefine.NetworkParameterNames[NetworkBattleDefine.NetworkParameter.type]] = 30;
}
EmitMsg(NetworkBattleDefine.NetworkBattleURI.PlayActions, dictionary);
}
public void SendTurnEndAction()
{
Dictionary<string, object> dataList = _sendCardDataMaker.MakePlayActionsSendCardData();
EmitMsg(NetworkBattleDefine.NetworkBattleURI.TurnEndActions, dataList);
}
public void SendTurnEnd(bool isNextTurnTimeDecrement, bool isNowTurnTimeDecrement, bool final)
{
if (final || ToolboxGame.RealTimeNetworkAgent.GetTurnState())
{
Dictionary<string, object> dictionary = new Dictionary<string, object>();
_networkConsistency.SetupConsistency();
dictionary.Add(NetworkBattleSenderDefine.SendCommonParameter.battleCode.ToString(), _networkConsistency.GetConsistency());
dictionary.Add("type", (isNextTurnTimeDecrement ? 1 : 0) + (isNowTurnTimeDecrement ? 10 : 0));
List<int> list = new List<int>();
list.Add(_battleMgr.GetBattlePlayer(isPlayer: true).CemeteryList.Count);
list.Add(_battleMgr.GetBattlePlayer(isPlayer: false).CemeteryList.Count);
dictionary.Add("actionSeq", ToolboxGame.RealTimeNetworkAgent.GetTurnSequence());
dictionary.Add("cemetery", list);
if (final)
{
EmitMsg(NetworkBattleDefine.NetworkBattleURI.TurnEndFinal, dictionary);
SetEmitStopOutsideJudgeResult();
}
else
{
EmitMsg(NetworkBattleDefine.NetworkBattleURI.TurnEnd, dictionary);
}
}
}
public void SendTurnEndFinish()
{
SendTurnEnd(isNextTurnTimeDecrement: false, isNowTurnTimeDecrement: false, final: true);
}
public void SendRecoveryEnd()
{
EmitMsg(NetworkBattleDefine.NetworkBattleURI.RecoveryEnd);
}
public void SendJudge()
{
Dictionary<string, object> dictionary = new Dictionary<string, object>();
_networkConsistency.SetupConsistency();
dictionary.Add(NetworkBattleSenderDefine.SendCommonParameter.battleCode.ToString(), _networkConsistency.GetConsistency());
EmitMsg(NetworkBattleDefine.NetworkBattleURI.Judge, dictionary);
}
public void SendChatStamp(string stamp)
{
Dictionary<string, object> dictionary = new Dictionary<string, object>();
dictionary[NetworkBattleDefine.NetworkParameterNames[NetworkBattleDefine.NetworkParameter.stamp]] = stamp;
ToolboxGame.RealTimeNetworkAgent.EmitMsgPack(NetworkBattleDefine.NetworkBattleURI.ChatStamp, dictionary, null, isGetableAck: false);
}
public void SendTouch(int idx, bool isSelf)
{
if (_lastTouchIndex != idx)
{
_lastTouchIndex = idx;
_emitHandParameterList.Clear();
_emitHandParameterList.Add(_lastTouchIndex);
_emitHandParameterList.Add(isSelf ? 1 : 0);
ToolboxGame.RealTimeNetworkAgent.EmitHandData(_emitHandParameterList, HAND_URI_TYPE.TOUCH_URI);
}
}
public void SendSelectSkill(SELECT_SKILL_OPERATION selectSkillOperation, bool isEvolveTargetSelect, string operationNum, List<int> activeSelectSkillIndexList, bool isBurialRite, bool isChoiceBrave)
{
bool flag = selectSkillOperation != SELECT_SKILL_OPERATION.SelectChoiceCard;
if (operationNum.IsNotNullOrEmpty() && !flag)
{
DateTime now = DateTime.Now;
TimeSpan elapsedTimeByTimeSpan = TimeUtil.GetElapsedTimeByTimeSpan(now, _oldSelectCurrentLocalTime);
float num = (float)elapsedTimeByTimeSpan.Milliseconds / 1000f;
if (elapsedTimeByTimeSpan.Seconds == 0 && num < 0.5f)
{
return;
}
_oldSelectCurrentLocalTime = now;
}
List<object> list = new List<object>();
list.Add((int)selectSkillOperation);
list.Add(isEvolveTargetSelect);
list.Add(isBurialRite);
if (!string.IsNullOrEmpty(operationNum))
{
list.Add(operationNum);
}
if (isChoiceBrave)
{
if (string.IsNullOrEmpty(operationNum))
{
list.Add("0");
}
list.Add("1");
}
if (activeSelectSkillIndexList.Count > 0)
{
if (!isChoiceBrave)
{
if (string.IsNullOrEmpty(operationNum))
{
list.Add("0");
}
list.Add("0");
}
list.Add(activeSelectSkillIndexList);
}
ToolboxGame.RealTimeNetworkAgent.EmitHandData(list, HAND_URI_TYPE.SELECT_SKILL_URI, flag);
}
public void SendSelectObject(BattleCardBase selectedCard)
{
if (selectedCard != _lastSelectedCard)
{
_lastSelectedCard = selectedCard;
string empty = string.Empty;
if (selectedCard == null)
{
empty = "0";
}
else
{
string text = (selectedCard.IsPlayer ? "1" : "0");
string text2 = selectedCard.Index.ToString();
empty = "1" + text + text2;
}
_emitHandParameterList.Clear();
_emitHandParameterList.Add(empty);
ToolboxGame.RealTimeNetworkAgent.EmitHandData(_emitHandParameterList, HAND_URI_TYPE.SELECT_OBJECT_URI);
}
}
public void SendTurnEndReady(bool isShortenedTurn)
{
_emitHandParameterList.Clear();
_emitHandParameterList.Add(isShortenedTurn);
ToolboxGame.RealTimeNetworkAgent.EmitHandData(_emitHandParameterList, HAND_URI_TYPE.TURN_END_READY_URI);
}
public void SendSlideObject(SLIDE_OBJECT_TYPE slideObjectType, BattleCardBase selectedCard, BattleCardBase attackingCard)
{
if (_selectedSlideCard == selectedCard)
{
return;
}
if (slideObjectType != SLIDE_OBJECT_TYPE.Cancel)
{
DateTime now = DateTime.Now;
TimeSpan elapsedTimeByTimeSpan = TimeUtil.GetElapsedTimeByTimeSpan(now, _oldSlideCurrentLocalTime);
float num = (float)elapsedTimeByTimeSpan.Milliseconds / 1000f;
if (elapsedTimeByTimeSpan.Seconds == 0 && num < 0.4f)
{
return;
}
_oldSlideCurrentLocalTime = now;
}
_selectedSlideCard = selectedCard;
string item = string.Empty;
string item2 = string.Empty;
switch (slideObjectType)
{
case SLIDE_OBJECT_TYPE.Cancel:
item = "0";
break;
case SLIDE_OBJECT_TYPE.Attack:
item = "1" + attackingCard.Index;
item2 = selectedCard.Index.ToString();
break;
case SLIDE_OBJECT_TYPE.Evolve:
item = "2";
item2 = selectedCard.Index.ToString();
break;
}
_emitHandParameterList.Clear();
_emitHandParameterList.Add(item);
_emitHandParameterList.Add(item2);
ToolboxGame.RealTimeNetworkAgent.EmitHandData(_emitHandParameterList, HAND_URI_TYPE.SLIDE_OBJECT_URI);
}
public void ResetSelectedSlideCard()
{
_selectedSlideCard = null;
}
public void EmitRetry(NetworkBattleDefine.NetworkBattleURI uri)
{
BattleCoroutine.GetInstance().StartCoroutine(EmitRetryWait(uri));
}
private IEnumerator EmitRetryWait(NetworkBattleDefine.NetworkBattleURI uri)
{
long oldTimer = TimeUtil.GetAbsoluteTime().Ticks;
while ((float)NetworkUtility.GetTimeSpanSecond(oldTimer) < 0.5f)
{
yield return null;
}
EmitData emitData = _alreadyEmitList.Find((EmitData x) => x.Uri == uri.ToString());
_alreadyEmitList.Remove(emitData);
LocalLog.AccumulateLastTraceLog("EmitRetryWait " + emitData.Uri);
EmitMsg((NetworkBattleDefine.NetworkBattleURI)Enum.Parse(typeof(NetworkBattleDefine.NetworkBattleURI), emitData.Uri), emitData.Data);
}
public void SendAtkData(BattleCardBase attackCard, BattleCardBase targetCard)
{
List<BattleCardBase> list = new List<BattleCardBase>();
list.Add(targetCard);
Dictionary<string, object> dictionary = _sendCardDataMaker.MakePlayActionsSendCardData(attackCard, list);
if (dictionary.Count >= 1)
{
dictionary[NetworkBattleDefine.NetworkParameterNames[NetworkBattleDefine.NetworkParameter.type]] = 10;
EmitMsg(NetworkBattleDefine.NetworkBattleURI.PlayActions, dictionary);
}
}
public void SendEvolData(BattleCardBase evolCard, List<BattleCardBase> targetCardList, List<NetworkBattleManagerBase.ValidateSkillData> validateSkillIndexList, SendKeyActionDataManager sendKeyActionDataManager, List<int> selectTypeSkillIndexList)
{
Dictionary<string, object> dictionary = _sendCardDataMaker.MakePlayActionsSendCardData(evolCard, targetCardList, validateSkillIndexList, isEvol: true, sendKeyActionDataManager, isTurnStart: false, selectTypeSkillIndexList);
if (targetCardList != null && targetCardList.Count >= 1)
{
dictionary[NetworkBattleDefine.NetworkParameterNames[NetworkBattleDefine.NetworkParameter.type]] = 21;
}
else
{
dictionary[NetworkBattleDefine.NetworkParameterNames[NetworkBattleDefine.NetworkParameter.type]] = 20;
}
EmitMsg(NetworkBattleDefine.NetworkBattleURI.PlayActions, dictionary);
}
public void SendRetire()
{
EmitMsg(NetworkBattleDefine.NetworkBattleURI.Retire);
SetEmitStopOutsideJudgeResult();
}
public void SendEcho(int idx, NetworkBattleDefine.PlayActionType actionType, SendKeyActionDataManager sendKeyActionDataManager, bool isNotActiveSeq = false, bool isTurnStart = false)
{
Dictionary<string, object> dictionary = _sendCardDataMaker.MakeEchoData(idx, actionType, sendKeyActionDataManager);
if (dictionary.Count >= 1 || isTurnStart)
{
EmitMsg(NetworkBattleDefine.NetworkBattleURI.Echo, dictionary, isDisconnectIgnoring: false, isGetableAck: true, isNotActiveSeq);
}
else
{
LocalLog.AccumulateLastTraceLog("NotEchoData isVirtual" + BattleManagerBase.GetIns().IsVirtualBattle + " " + StackTraceUtility.ExtractStackTrace());
}
}
public void SendJudgeResult(JUDGE_RESULT_STATUS judgeResultStatus)
{
Dictionary<string, object> dictionary = new Dictionary<string, object>();
dictionary[NetworkBattleDefine.NetworkParameter.log.ToString()] = (int)judgeResultStatus;
EmitMsg(NetworkBattleDefine.NetworkBattleURI.JudgeResult, dictionary, isDisconnectIgnoring: true, isGetableAck: false);
}
public void SetEmitStopOutsideJudgeResult()
{
_isEmitStop_OutsideJudgeResult = true;
}
private bool EmitMsg(NetworkBattleDefine.NetworkBattleURI uri, Dictionary<string, object> dataList = null, bool isDisconnectIgnoring = false, bool isGetableAck = true, bool isNotActiveSeq = false)
{
if (_battleMgr.IsNetworkBattleEnd)
{
LocalLog.AccumulateLastTraceLog("networkbattleEnd:" + uri);
return false;
}
if (!isDisconnectIgnoring && _battleMgr.disconnectToLoseChecker.IsSelfDisConnectOnTimeout())
{
LocalLog.AccumulateLastTraceLog("EmitMsgDisConnect:" + uri);
return false;
}
if (_isEmitStop_OutsideJudgeResult && uri != NetworkBattleDefine.NetworkBattleURI.JudgeResult)
{
LocalLog.AccumulateLastTraceLog("EmitStop Outside JudgeResult:" + uri);
return false;
}
if (uri == NetworkBattleDefine.NetworkBattleURI.PlayActions && !_battleMgr.GetBattlePlayer(isPlayer: true).IsSelfTurn)
{
LocalLog.AccumulateTraceLog("588157NotMyturnPlay" + PlayActionLogMsg);
return false;
}
Dictionary<string, object> dictionary = new Dictionary<string, object>();
if (dataList != null)
{
foreach (KeyValuePair<string, object> data in dataList)
{
dictionary.Add(data.Key, data.Value);
}
}
_alreadyEmitList.Add(new EmitData(uri.ToString(), dictionary, ToolboxGame.RealTimeNetworkAgent.LastEmitSeqNumber));
ToolboxGame.RealTimeNetworkAgent.EmitMsgPack(uri, dataList, null, isGetableAck, -1, isStockData: true, isNotActiveSeq);
_battleMgr.SendIntervalTriggerMain.SendDataCheck(_battleMgr, uri);
return true;
}
public void SendFusionData(BattleCardBase fusionCard, List<BattleCardBase> ingredientCards, SendKeyActionDataManager sendKeyActionDataManager, List<int> selectTypeSkillIndexList)
{
Dictionary<string, object> dictionary = _sendCardDataMaker.MakePlayActionsSendCardData(fusionCard, ingredientCards, null, isEvol: false, sendKeyActionDataManager, isTurnStart: false, selectTypeSkillIndexList);
dictionary[NetworkBattleDefine.NetworkParameter.type.ToString()] = 40;
EmitMsg(NetworkBattleDefine.NetworkBattleURI.PlayActions, dictionary);
}
}