mirror/quantum-space-buddies
1
0
Fork 0
mirror of https://github.com/misternebula/quantum-space-buddies.git synced 2025-01-29 09:32:38 +00:00
Code Issues Projects Releases Wiki Activity

Fix syncing state, current user of probe launcher

Browse Source
This commit is contained in:
Nick 2022-08-27 02:28:10 -04:00
parent 3f636494c4
commit 399073c675
3 changed files with 31 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
QSB/StationaryProbeLauncherSync/Messages/StationaryProbeLauncherMessage.cs
View File

@ -3,9 +3,9 @@ using QSB.StationaryProbeLauncherSync.WorldObjects;
namespace QSB.StationaryProbeLauncherSync.Messages;
public class StationaryProbeLauncherMessage : QSBWorldObjectMessage<QSBStationaryProbeLauncher, bool>
public class StationaryProbeLauncherMessage : QSBWorldObjectMessage<QSBStationaryProbeLauncher, (bool, uint)>
{
public StationaryProbeLauncherMessage(bool inUse) : base(inUse) { }
public StationaryProbeLauncherMessage(bool inUse, uint userID) : base((inUse, userID)) { }
public override void OnReceiveRemote() => WorldObject.OnRemoteUseStateChanged(Data, From);
public override void OnReceiveRemote() => WorldObject.OnRemoteUseStateChanged(Data.Item1, Data.Item2);
}

8
QSB/StationaryProbeLauncherSync/Patches/StationaryProbeLauncherPatches.cs
View File

@ -1,6 +1,7 @@
using HarmonyLib;
using QSB.Messaging;
using QSB.Patches;
using QSB.Player;
using QSB.StationaryProbeLauncherSync.Messages;
using QSB.StationaryProbeLauncherSync.WorldObjects;
using QSB.WorldSync;
@ -14,9 +15,6 @@ public class StationaryProbeLauncherPatches : QSBPatch
[HarmonyPostfix]
[HarmonyPatch(typeof(StationaryProbeLauncher), nameof(StationaryProbeLauncher.FinishExitSequence))]
public static void StationaryProbeLauncher_FinishExitSequence(StationaryProbeLauncher __instance)
{
var qsbStationaryProbe = __instance.GetWorldObject<QSBStationaryProbeLauncher>();
qsbStationaryProbe.SendMessage(new StationaryProbeLauncherMessage(false));
}
public static void StationaryProbeLauncher_FinishExitSequence(StationaryProbeLauncher __instance) =>
__instance.GetWorldObject<QSBStationaryProbeLauncher>().OnLocalUseStateChanged(false);
}

44
QSB/StationaryProbeLauncherSync/WorldObjects/QSBStationaryProbeLauncher.cs
View File

@ -13,6 +13,8 @@ namespace QSB.StationaryProbeLauncherSync.WorldObjects;
public class QSBStationaryProbeLauncher : QSBProbeLauncher, ILinkedWorldObject<StationaryProbeLauncherVariableSync>
{
private uint _currentUser = uint.MaxValue;
public StationaryProbeLauncherVariableSync NetworkBehaviour { get; private set; }
public void SetNetworkBehaviour(NetworkBehaviour networkBehaviour) => NetworkBehaviour = (StationaryProbeLauncherVariableSync)networkBehaviour;
@ -21,8 +23,8 @@ public class QSBStationaryProbeLauncher : QSBProbeLauncher, ILinkedWorldObject<S
public override async UniTask Init(CancellationToken ct)
{
// This is implemented by inheriting LinkedWorldObject normally, however I want to inherit from QSBProbeLauncher
// Else we'd have to redo the sync for the effects
// This is implemented by inheriting LinkedWorldObject normally,
// However I want to inherit from QSBProbeLauncher or else we'd have to redo the sync for the VFX/SFX
if (QSBCore.IsHost)
{
this.SpawnLinked(QSBNetworkManager.singleton.StationaryProbeLauncherPrefab, false);
@ -52,39 +54,43 @@ public class QSBStationaryProbeLauncher : QSBProbeLauncher, ILinkedWorldObject<S
_stationaryProbeLauncher._interactVolume.OnPressInteract -= OnPressInteract;
}
private void OnPressInteract()
{
// Whoever is using it needs authority to be able to rotate it
// If this is a client they'll get authority from the host when the message is received otherwise give now
if (QSBCore.IsHost)
{
NetworkBehaviour.netIdentity.SetAuthority(QSBPlayerManager.LocalPlayerId);
}
_isInUse = true;
this.SendMessage(new StationaryProbeLauncherMessage(_isInUse));
}
private void OnPressInteract() => OnLocalUseStateChanged(true);
public override void SendInitialState(uint to)
{
base.SendInitialState(to);
// even tho from is always host here, it's okay because it won't set authority
// (since OnRemoteUseStateChanged is only called from OnReceiveRemote)
this.SendMessage(new StationaryProbeLauncherMessage(_isInUse) { To = to });
this.SendMessage(new StationaryProbeLauncherMessage(_isInUse, _currentUser) { To = to });
}
public void OnRemoteUseStateChanged(bool isInUse, uint user)
{
_isInUse = isInUse;
_currentUser = isInUse ? user : uint.MaxValue;
// Whoever is using it needs authority to be able to rotate it
if (QSBCore.IsHost)
{
NetworkBehaviour.netIdentity.SetAuthority(isInUse ? user : uint.MaxValue);
NetworkBehaviour.netIdentity.SetAuthority(_currentUser);
}
UpdateUse();
}
public void OnLocalUseStateChanged(bool isInUse)
{
_isInUse = isInUse;
UpdateUse();
_currentUser = isInUse ? QSBPlayerManager.LocalPlayerId : uint.MaxValue;
// Whoever is using it needs authority to be able to rotate it
if (QSBCore.IsHost)
{
NetworkBehaviour.netIdentity.SetAuthority(_currentUser);
}
this.SendMessage(new StationaryProbeLauncherMessage(isInUse, _currentUser));
}
private void UpdateUse()