mirror of
https://github.com/misternebula/quantum-space-buddies.git
synced 2025-01-26 18:35:34 +00:00
378 lines
15 KiB
C#
378 lines
15 KiB
C#
using QSB.Utility;
|
|
using System.Collections;
|
|
using UnityEngine;
|
|
using UnityEngine.Networking;
|
|
using Object = UnityEngine.Object;
|
|
|
|
namespace QSB.Animation
|
|
{
|
|
[RequireComponent(typeof(NetworkIdentity))]
|
|
[RequireComponent(typeof(Animator))]
|
|
class QSBNetworkAnimator : NetworkBehaviour
|
|
{
|
|
private static QSBAnimationMessage s_AnimationMessage = new QSBAnimationMessage();
|
|
private static QSBAnimationParametersMessage s_AnimationParametersMessage = new QSBAnimationParametersMessage();
|
|
private static QSBAnimationTriggerMessage s_AnimationTriggerMessage = new QSBAnimationTriggerMessage();
|
|
private Animator m_Animator;
|
|
private uint m_ParameterSendBits;
|
|
private int m_AnimationHash;
|
|
private int m_TransitionHash;
|
|
private NetworkWriter m_ParameterWriter;
|
|
private float m_SendTimer;
|
|
|
|
public Animator animator
|
|
{
|
|
get
|
|
{
|
|
return m_Animator;
|
|
}
|
|
set
|
|
{
|
|
DebugLog.DebugWrite("SETTING ANIMATOR");
|
|
m_Animator = value;
|
|
ResetParameterOptions();
|
|
}
|
|
}
|
|
|
|
public void SetParameterAutoSend(int index, bool value)
|
|
{
|
|
if (value)
|
|
m_ParameterSendBits |= (uint)(1 << index);
|
|
else
|
|
m_ParameterSendBits &= (uint)~(1 << index);
|
|
}
|
|
|
|
public bool GetParameterAutoSend(int index)
|
|
{
|
|
return ((int)m_ParameterSendBits & 1 << index) != 0;
|
|
}
|
|
|
|
internal void ResetParameterOptions()
|
|
{
|
|
DebugLog.DebugWrite("Reset parameter options");
|
|
m_ParameterSendBits = 0U;
|
|
}
|
|
|
|
public override void OnStartAuthority()
|
|
{
|
|
m_ParameterWriter = new NetworkWriter();
|
|
}
|
|
|
|
private void FixedUpdate()
|
|
{
|
|
if (m_ParameterWriter == null)
|
|
{
|
|
return;
|
|
}
|
|
CheckSendRate();
|
|
if (!CheckAnimStateChanged(out var stateHash, out var normalizedTime))
|
|
{
|
|
return;
|
|
}
|
|
var animationMessage = new QSBAnimationMessage
|
|
{
|
|
netId = netId,
|
|
stateHash = stateHash,
|
|
normalizedTime = normalizedTime
|
|
};
|
|
m_ParameterWriter.SeekZero();
|
|
WriteParameters(m_ParameterWriter, false);
|
|
animationMessage.parameters = m_ParameterWriter.ToArray();
|
|
if (hasAuthority || ClientScene.readyConnection != null)
|
|
{
|
|
ClientScene.readyConnection.Send(40, animationMessage);
|
|
}
|
|
else
|
|
{
|
|
if (!isServer || localPlayerAuthority)
|
|
return;
|
|
NetworkServer.SendToReady(gameObject, 40, animationMessage);
|
|
}
|
|
}
|
|
|
|
private bool CheckAnimStateChanged(out int stateHash, out float normalizedTime)
|
|
{
|
|
stateHash = 0;
|
|
normalizedTime = 0.0f;
|
|
if (m_Animator.IsInTransition(0))
|
|
{
|
|
var animatorTransitionInfo = m_Animator.GetAnimatorTransitionInfo(0);
|
|
if (animatorTransitionInfo.fullPathHash == m_TransitionHash)
|
|
{
|
|
return false;
|
|
}
|
|
m_TransitionHash = animatorTransitionInfo.fullPathHash;
|
|
m_AnimationHash = 0;
|
|
return true;
|
|
}
|
|
var animatorStateInfo = m_Animator.GetCurrentAnimatorStateInfo(0);
|
|
if (animatorStateInfo.fullPathHash == m_AnimationHash)
|
|
{
|
|
return false;
|
|
}
|
|
if (m_AnimationHash != 0)
|
|
{
|
|
stateHash = animatorStateInfo.fullPathHash;
|
|
normalizedTime = animatorStateInfo.normalizedTime;
|
|
}
|
|
m_TransitionHash = 0;
|
|
m_AnimationHash = animatorStateInfo.fullPathHash;
|
|
return true;
|
|
}
|
|
|
|
private void CheckSendRate()
|
|
{
|
|
if (GetNetworkSendInterval() == 0.0 || m_SendTimer >= Time.time)
|
|
{
|
|
return;
|
|
}
|
|
m_SendTimer = Time.time + GetNetworkSendInterval();
|
|
var parametersMessage = new QSBAnimationParametersMessage
|
|
{
|
|
netId = netId
|
|
};
|
|
m_ParameterWriter.SeekZero();
|
|
WriteParameters(m_ParameterWriter, true);
|
|
parametersMessage.parameters = m_ParameterWriter.ToArray();
|
|
if (hasAuthority && ClientScene.readyConnection != null)
|
|
{
|
|
ClientScene.readyConnection.Send(41, parametersMessage);
|
|
}
|
|
else
|
|
{
|
|
if (!isServer || localPlayerAuthority)
|
|
return;
|
|
NetworkServer.SendToReady(gameObject, 41, parametersMessage);
|
|
}
|
|
}
|
|
|
|
internal void HandleAnimMsg(QSBAnimationMessage msg, NetworkReader reader)
|
|
{
|
|
if (hasAuthority)
|
|
{
|
|
return;
|
|
}
|
|
if (msg.stateHash != 0)
|
|
{
|
|
m_Animator.Play(msg.stateHash, 0, msg.normalizedTime);
|
|
}
|
|
ReadParameters(reader, false);
|
|
}
|
|
|
|
internal void HandleAnimParamsMsg(QSBAnimationParametersMessage msg, NetworkReader reader)
|
|
{
|
|
if (hasAuthority)
|
|
{
|
|
return;
|
|
}
|
|
ReadParameters(reader, true);
|
|
}
|
|
|
|
internal void HandleAnimTriggerMsg(int hash)
|
|
{
|
|
m_Animator.SetTrigger(hash);
|
|
}
|
|
|
|
private void WriteParameters(NetworkWriter writer, bool autoSend)
|
|
{
|
|
for (int index = 0; index < m_Animator.parameters.Length; ++index)
|
|
{
|
|
if (!autoSend || GetParameterAutoSend(index))
|
|
{
|
|
var parameter = m_Animator.parameters[index];
|
|
switch (parameter.type)
|
|
{
|
|
case AnimatorControllerParameterType.Int:
|
|
writer.WritePackedUInt32((uint)m_Animator.GetInteger(parameter.nameHash));
|
|
break;
|
|
case AnimatorControllerParameterType.Float:
|
|
writer.Write(m_Animator.GetFloat(parameter.nameHash));
|
|
break;
|
|
case AnimatorControllerParameterType.Bool:
|
|
writer.Write(m_Animator.GetBool(parameter.nameHash));
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
private void ReadParameters(NetworkReader reader, bool autoSend)
|
|
{
|
|
for (int index = 0; index < m_Animator.parameters.Length; ++index)
|
|
{
|
|
if (!autoSend || GetParameterAutoSend(index))
|
|
{
|
|
var parameter = m_Animator.parameters[index];
|
|
if (reader.Length == reader.Position)
|
|
{
|
|
return;
|
|
}
|
|
switch (parameter.type)
|
|
{
|
|
case AnimatorControllerParameterType.Int:
|
|
var num = (int)reader.ReadPackedUInt32();
|
|
m_Animator.SetInteger(parameter.nameHash, num);
|
|
break;
|
|
case AnimatorControllerParameterType.Float:
|
|
var single = reader.ReadSingle();
|
|
m_Animator.SetFloat(parameter.nameHash, single);
|
|
break;
|
|
case AnimatorControllerParameterType.Bool:
|
|
var flag = reader.ReadBoolean();
|
|
m_Animator.SetBool(parameter.nameHash, flag);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
public override bool OnSerialize(NetworkWriter writer, bool forceAll)
|
|
{
|
|
if (!forceAll)
|
|
{
|
|
return false;
|
|
}
|
|
if (m_Animator.IsInTransition(0))
|
|
{
|
|
var animatorStateInfo = m_Animator.GetNextAnimatorStateInfo(0);
|
|
writer.Write(animatorStateInfo.fullPathHash);
|
|
writer.Write(animatorStateInfo.normalizedTime);
|
|
}
|
|
else
|
|
{
|
|
var animatorStateInfo = m_Animator.GetCurrentAnimatorStateInfo(0);
|
|
writer.Write(animatorStateInfo.fullPathHash);
|
|
writer.Write(animatorStateInfo.normalizedTime);
|
|
}
|
|
WriteParameters(writer, false);
|
|
return true;
|
|
}
|
|
|
|
public override void OnDeserialize(NetworkReader reader, bool initialState)
|
|
{
|
|
if (!initialState)
|
|
{
|
|
return;
|
|
}
|
|
var stateNameHash = reader.ReadInt32();
|
|
var normalizedTime = reader.ReadSingle();
|
|
ReadParameters(reader, false);
|
|
m_Animator.Play(stateNameHash, 0, normalizedTime);
|
|
}
|
|
|
|
public void SetTrigger(string triggerName)
|
|
{
|
|
SetTrigger(Animator.StringToHash(triggerName));
|
|
}
|
|
|
|
public void SetTrigger(int hash)
|
|
{
|
|
var animationTriggerMessage = new QSBAnimationTriggerMessage
|
|
{
|
|
netId = netId,
|
|
hash = hash
|
|
};
|
|
if (hasAuthority && localPlayerAuthority)
|
|
{
|
|
if (NetworkClient.allClients.Count <= 0)
|
|
{
|
|
return;
|
|
}
|
|
var readyConnection = ClientScene.readyConnection;
|
|
if (readyConnection == null)
|
|
{
|
|
return;
|
|
}
|
|
readyConnection.Send(42, animationTriggerMessage);
|
|
}
|
|
else
|
|
{
|
|
if (!isServer || localPlayerAuthority)
|
|
{
|
|
return;
|
|
}
|
|
NetworkServer.SendToReady(gameObject, 42, animationTriggerMessage);
|
|
}
|
|
}
|
|
|
|
internal static void OnAnimationServerMessage(NetworkMessage netMsg)
|
|
{
|
|
netMsg.ReadMessage<QSBAnimationMessage>(QSBNetworkAnimator.s_AnimationMessage);
|
|
GameObject localObject = NetworkServer.FindLocalObject(QSBNetworkAnimator.s_AnimationMessage.netId);
|
|
if ((Object)localObject == (Object)null)
|
|
return;
|
|
QSBNetworkAnimator component = localObject.GetComponent<QSBNetworkAnimator>();
|
|
if (!((Object)component != (Object)null))
|
|
return;
|
|
NetworkReader reader = new NetworkReader(QSBNetworkAnimator.s_AnimationMessage.parameters);
|
|
component.HandleAnimMsg(QSBNetworkAnimator.s_AnimationMessage, reader);
|
|
NetworkServer.SendToReady(localObject, (short)40, (MessageBase)QSBNetworkAnimator.s_AnimationMessage);
|
|
}
|
|
|
|
internal static void OnAnimationParametersServerMessage(NetworkMessage netMsg)
|
|
{
|
|
netMsg.ReadMessage<QSBAnimationParametersMessage>(QSBNetworkAnimator.s_AnimationParametersMessage);
|
|
GameObject localObject = NetworkServer.FindLocalObject(QSBNetworkAnimator.s_AnimationParametersMessage.netId);
|
|
if ((Object)localObject == (Object)null)
|
|
return;
|
|
QSBNetworkAnimator component = localObject.GetComponent<QSBNetworkAnimator>();
|
|
if (!((Object)component != (Object)null))
|
|
return;
|
|
NetworkReader reader = new NetworkReader(QSBNetworkAnimator.s_AnimationParametersMessage.parameters);
|
|
component.HandleAnimParamsMsg(QSBNetworkAnimator.s_AnimationParametersMessage, reader);
|
|
NetworkServer.SendToReady(localObject, (short)41, (MessageBase)QSBNetworkAnimator.s_AnimationParametersMessage);
|
|
}
|
|
|
|
internal static void OnAnimationTriggerServerMessage(NetworkMessage netMsg)
|
|
{
|
|
netMsg.ReadMessage<QSBAnimationTriggerMessage>(QSBNetworkAnimator.s_AnimationTriggerMessage);
|
|
GameObject localObject = NetworkServer.FindLocalObject(QSBNetworkAnimator.s_AnimationTriggerMessage.netId);
|
|
if ((Object)localObject == (Object)null)
|
|
return;
|
|
QSBNetworkAnimator component = localObject.GetComponent<QSBNetworkAnimator>();
|
|
if (!((Object)component != (Object)null))
|
|
return;
|
|
component.HandleAnimTriggerMsg(QSBNetworkAnimator.s_AnimationTriggerMessage.hash);
|
|
NetworkServer.SendToReady(localObject, (short)42, (MessageBase)QSBNetworkAnimator.s_AnimationTriggerMessage);
|
|
}
|
|
|
|
internal static void OnAnimationClientMessage(NetworkMessage netMsg)
|
|
{
|
|
netMsg.ReadMessage(s_AnimationMessage);
|
|
GameObject localObject = ClientScene.FindLocalObject(QSBNetworkAnimator.s_AnimationMessage.netId);
|
|
if ((Object)localObject == (Object)null)
|
|
return;
|
|
QSBNetworkAnimator component = localObject.GetComponent<QSBNetworkAnimator>();
|
|
if (!((Object)component != (Object)null))
|
|
return;
|
|
NetworkReader reader = new NetworkReader(QSBNetworkAnimator.s_AnimationMessage.parameters);
|
|
component.HandleAnimMsg(QSBNetworkAnimator.s_AnimationMessage, reader);
|
|
}
|
|
|
|
internal static void OnAnimationParametersClientMessage(NetworkMessage netMsg)
|
|
{
|
|
netMsg.ReadMessage<QSBAnimationParametersMessage>(QSBNetworkAnimator.s_AnimationParametersMessage);
|
|
GameObject localObject = ClientScene.FindLocalObject(QSBNetworkAnimator.s_AnimationParametersMessage.netId);
|
|
if ((Object)localObject == (Object)null)
|
|
return;
|
|
QSBNetworkAnimator component = localObject.GetComponent<QSBNetworkAnimator>();
|
|
if (!((Object)component != (Object)null))
|
|
return;
|
|
NetworkReader reader = new NetworkReader(QSBNetworkAnimator.s_AnimationParametersMessage.parameters);
|
|
component.HandleAnimParamsMsg(QSBNetworkAnimator.s_AnimationParametersMessage, reader);
|
|
}
|
|
|
|
internal static void OnAnimationTriggerClientMessage(NetworkMessage netMsg)
|
|
{
|
|
netMsg.ReadMessage<QSBAnimationTriggerMessage>(QSBNetworkAnimator.s_AnimationTriggerMessage);
|
|
GameObject localObject = ClientScene.FindLocalObject(QSBNetworkAnimator.s_AnimationTriggerMessage.netId);
|
|
if ((Object)localObject == (Object)null)
|
|
return;
|
|
QSBNetworkAnimator component = localObject.GetComponent<QSBNetworkAnimator>();
|
|
if (!((Object)component != (Object)null))
|
|
return;
|
|
component.HandleAnimTriggerMsg(QSBNetworkAnimator.s_AnimationTriggerMessage.hash);
|
|
}
|
|
}
|
|
}
|