This commit is contained in:
2025-10-24 20:18:24 +02:00
parent db45509eaa
commit 4229355a32
5 changed files with 265 additions and 13 deletions

View File

@@ -109,6 +109,8 @@ namespace MegaKoop.Game.Networking
Debug.Log($"[NetworkIdRegistry] Unregistered Network ID {networkId}");
}
SteamCharacterStateCache.RemoveState(networkId);
// Also remove from Steam ID mapping if present
ulong steamIdToRemove = 0;
foreach (var kvp in instance.steamIdToNetworkId)

View File

@@ -211,6 +211,7 @@ namespace MegaKoop.Game.Networking
var unityController = GetComponent<CharacterController>();
Vector3 velocity = unityController != null ? unityController.velocity : Vector3.zero;
SteamCharacterStateCache.ReportLocalState(identity.NetworkId, rootTransform.position, rootTransform.rotation, velocity);
var message = new CharacterTransformMessage(identity.NetworkId, rootTransform.position, rootTransform.rotation, velocity);
byte[] payload = CharacterTransformMessage.Serialize(message);
networkManager.SendToAll(NetworkMessageType.CharacterTransform, payload, EP2PSend.k_EP2PSendUnreliableNoDelay);

View File

@@ -0,0 +1,176 @@
using System.Collections.Generic;
using Steamworks;
using UnityEngine;
namespace MegaKoop.Game.Networking
{
/// <summary>
/// Lightweight cache of the latest character transform messages so systems (AI, prediction) can query peer positions.
/// </summary>
[DefaultExecutionOrder(-900)]
public class SteamCharacterStateCache : MonoBehaviour
{
public readonly struct CharacterState
{
public readonly int NetworkId;
public readonly Vector3 Position;
public readonly Quaternion Rotation;
public readonly Vector3 Velocity;
public readonly float LastUpdateTime;
public readonly ulong SourceSteamId;
public CharacterState(int networkId, Vector3 position, Quaternion rotation, Vector3 velocity, float timestamp, ulong steamId)
{
NetworkId = networkId;
Position = position;
Rotation = rotation;
Velocity = velocity;
LastUpdateTime = timestamp;
SourceSteamId = steamId;
}
}
private static SteamCharacterStateCache instance;
private readonly Dictionary<int, CharacterState> states = new();
private SteamCoopNetworkManager networkManager;
private bool isRegistered;
public static SteamCharacterStateCache Instance
{
get
{
if (instance == null)
{
var go = new GameObject("SteamCharacterStateCache");
instance = go.AddComponent<SteamCharacterStateCache>();
DontDestroyOnLoad(go);
}
return instance;
}
}
private void Awake()
{
if (instance != null && instance != this)
{
Destroy(gameObject);
return;
}
instance = this;
DontDestroyOnLoad(gameObject);
}
private void OnEnable()
{
EnsureSubscription();
}
private void Update()
{
EnsureSubscription();
}
private void OnDisable()
{
Unsubscribe();
}
private void EnsureSubscription()
{
var current = SteamCoopNetworkManager.Instance;
if (current == networkManager)
{
if (networkManager != null && !isRegistered)
{
networkManager.RegisterHandler(NetworkMessageType.CharacterTransform, HandleCharacterTransformMessage);
isRegistered = true;
}
return;
}
Unsubscribe();
networkManager = current;
if (networkManager != null)
{
networkManager.RegisterHandler(NetworkMessageType.CharacterTransform, HandleCharacterTransformMessage);
isRegistered = true;
}
}
private void Unsubscribe()
{
if (networkManager != null && isRegistered)
{
networkManager.UnregisterHandler(NetworkMessageType.CharacterTransform, HandleCharacterTransformMessage);
isRegistered = false;
}
}
private void HandleCharacterTransformMessage(NetworkMessage message)
{
CharacterTransformMessage transformMessage = CharacterTransformMessage.Deserialize(message.Payload);
StoreState(transformMessage.NetworkId, transformMessage.Position, transformMessage.Rotation, transformMessage.Velocity, message.Sender);
}
private void StoreState(int networkId, Vector3 position, Quaternion rotation, Vector3 velocity, ulong steamId)
{
if (networkId == 0)
{
return;
}
states[networkId] = new CharacterState(networkId, position, rotation, velocity, Time.time, steamId);
}
private static ulong GetLocalSteamId()
{
#if STEAMWORKSNET
if (MegaKoop.Steam.SteamManager.Initialized)
{
return SteamUser.GetSteamID().m_SteamID;
}
#else
if (SteamBootstrap.IsInitialized)
{
return SteamUser.GetSteamID().m_SteamID;
}
#endif
return 0UL;
}
public static bool TryGetState(int networkId, out CharacterState state)
{
if (Instance.states.TryGetValue(networkId, out state))
{
return true;
}
state = default;
return false;
}
public static void ReportLocalState(int networkId, Vector3 position, Quaternion rotation, Vector3 velocity)
{
if (networkId == 0)
{
return;
}
Instance.StoreState(networkId, position, rotation, velocity, GetLocalSteamId());
}
public static void RemoveState(int networkId)
{
if (networkId == 0)
{
return;
}
Instance.states.Remove(networkId);
}
}
}

View File

@@ -152,9 +152,10 @@ namespace MegaKoop.Game.Networking
}
else if (trackedRigidbody != null)
{
velocity = trackedRigidbody.linearVelocity;
velocity = trackedRigidbody.velocity;
}
SteamCharacterStateCache.ReportLocalState(identity.NetworkId, targetTransform.position, targetTransform.rotation, velocity);
var message = new CharacterTransformMessage(identity.NetworkId, targetTransform.position, targetTransform.rotation, velocity);
byte[] payload = CharacterTransformMessage.Serialize(message);
networkManager.SendToAll(NetworkMessageType.CharacterTransform, payload, EP2PSend.k_EP2PSendUnreliableNoDelay);