-
Notifications
You must be signed in to change notification settings - Fork 55
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
9 changed files
with
242 additions
and
19 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,211 @@ | ||
| // © 2024 Lacyway All Rights Reserved | ||
|
|
||
| using BepInEx.Logging; | ||
| using Comfort.Common; | ||
| using EFT; | ||
| using EFT.MovingPlatforms; | ||
| using Fika.Core.Coop.GameMode; | ||
| using Fika.Core.Coop.Players; | ||
| using Fika.Core.Networking; | ||
| using Fika.Core.Networking.Packets; | ||
| using HarmonyLib; | ||
| using LiteNetLib; | ||
| using LiteNetLib.Utils; | ||
| using System; | ||
| using System.Collections; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
| using UnityEngine; | ||
|
|
||
| namespace Fika.Core.Coop.PacketHandlers | ||
| { | ||
| public class DedicatedPacketSender : MonoBehaviour, IPacketSender | ||
| { | ||
| private CoopPlayer player; | ||
|
|
||
| public bool Enabled { get; set; } = true; | ||
| public FikaServer Server { get; set; } = Singleton<FikaServer>.Instance; | ||
| public FikaClient Client { get; set; } | ||
| public NetDataWriter Writer { get; set; } = new(); | ||
| public Queue<WeaponPacket> FirearmPackets { get; set; } = new(50); | ||
| public Queue<DamagePacket> DamagePackets { get; set; } = new(50); | ||
| public Queue<ArmorDamagePacket> ArmorDamagePackets { get; set; } = new(50); | ||
| public Queue<InventoryPacket> InventoryPackets { get; set; } = new(50); | ||
| public Queue<CommonPlayerPacket> CommonPlayerPackets { get; set; } = new(50); | ||
| public Queue<HealthSyncPacket> HealthSyncPackets { get; set; } = new(50); | ||
|
|
||
| private ManualLogSource logger; | ||
|
|
||
| protected void Awake() | ||
| { | ||
| logger = BepInEx.Logging.Logger.CreateLogSource("ServerPacketSender"); | ||
| player = GetComponent<CoopPlayer>(); | ||
| enabled = false; | ||
| } | ||
|
|
||
| public void Init() | ||
| { | ||
| enabled = true; | ||
| StartCoroutine(SendTrainTime()); | ||
| } | ||
|
|
||
| public void SendQuestPacket(ref QuestConditionPacket packet) | ||
| { | ||
| Writer.Reset(); | ||
| Server.SendDataToAll(Writer, ref packet, DeliveryMethod.ReliableUnordered); | ||
| } | ||
|
|
||
| public void SendQuestItemPacket(ref QuestItemPacket packet) | ||
| { | ||
| Writer.Reset(); | ||
| Server.SendDataToAll(Writer, ref packet, DeliveryMethod.ReliableUnordered); | ||
| } | ||
|
|
||
| protected void Update() | ||
| { | ||
| int firearmPackets = FirearmPackets.Count; | ||
| if (firearmPackets > 0) | ||
| { | ||
| for (int i = 0; i < firearmPackets; i++) | ||
| { | ||
| WeaponPacket firearmPacket = FirearmPackets.Dequeue(); | ||
| firearmPacket.NetId = player.NetId; | ||
|
|
||
| Writer.Reset(); | ||
| Server.SendDataToAll(Writer, ref firearmPacket, DeliveryMethod.ReliableOrdered); | ||
| } | ||
| } | ||
| int damagePackets = DamagePackets.Count; | ||
| if (damagePackets > 0) | ||
| { | ||
| for (int i = 0; i < damagePackets; i++) | ||
| { | ||
| DamagePacket damagePacket = DamagePackets.Dequeue(); | ||
| damagePacket.NetId = player.NetId; | ||
|
|
||
| Writer.Reset(); | ||
| Server.SendDataToAll(Writer, ref damagePacket, DeliveryMethod.ReliableOrdered); | ||
| } | ||
| } | ||
| int armorDamagePackets = ArmorDamagePackets.Count; | ||
| if (armorDamagePackets > 0) | ||
| { | ||
| for (int i = 0; i < armorDamagePackets; i++) | ||
| { | ||
| ArmorDamagePacket armorDamagePacket = ArmorDamagePackets.Dequeue(); | ||
| armorDamagePacket.NetId = player.NetId; | ||
|
|
||
| Writer.Reset(); | ||
| Server.SendDataToAll(Writer, ref armorDamagePacket, DeliveryMethod.ReliableOrdered); | ||
| } | ||
| } | ||
| int inventoryPackets = InventoryPackets.Count; | ||
| if (inventoryPackets > 0) | ||
| { | ||
| for (int i = 0; i < inventoryPackets; i++) | ||
| { | ||
| InventoryPacket inventoryPacket = InventoryPackets.Dequeue(); | ||
| inventoryPacket.NetId = player.NetId; | ||
|
|
||
| Writer.Reset(); | ||
| Server.SendDataToAll(Writer, ref inventoryPacket, DeliveryMethod.ReliableOrdered); | ||
| } | ||
| } | ||
| int commonPlayerPackets = CommonPlayerPackets.Count; | ||
| if (commonPlayerPackets > 0) | ||
| { | ||
| for (int i = 0; i < commonPlayerPackets; i++) | ||
| { | ||
| CommonPlayerPacket commonPlayerPacket = CommonPlayerPackets.Dequeue(); | ||
| commonPlayerPacket.NetId = player.NetId; | ||
|
|
||
| Writer.Reset(); | ||
| Server.SendDataToAll(Writer, ref commonPlayerPacket, DeliveryMethod.ReliableOrdered); | ||
| } | ||
| } | ||
| int healthSyncPackets = HealthSyncPackets.Count; | ||
| if (healthSyncPackets > 0) | ||
| { | ||
| for (int i = 0; i < healthSyncPackets; i++) | ||
| { | ||
| HealthSyncPacket healthSyncPacket = HealthSyncPackets.Dequeue(); | ||
| healthSyncPacket.NetId = player.NetId; | ||
|
|
||
| Writer.Reset(); | ||
| Server.SendDataToAll(Writer, ref healthSyncPacket, DeliveryMethod.ReliableOrdered); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private IEnumerator SendTrainTime() | ||
| { | ||
| while (!Singleton<GameWorld>.Instantiated) | ||
| { | ||
| yield return null; | ||
| } | ||
|
|
||
| while (string.IsNullOrEmpty(Singleton<GameWorld>.Instance.MainPlayer.Location)) | ||
| { | ||
| yield return null; | ||
| } | ||
|
|
||
| string location = Singleton<GameWorld>.Instance.MainPlayer.Location; | ||
|
|
||
| if (location.Contains("RezervBase") || location.Contains("Lighthouse")) | ||
| { | ||
| CoopGame coopGame = (CoopGame)Singleton<IFikaGame>.Instance; | ||
|
|
||
| while (coopGame.Status != GameStatus.Started) | ||
| { | ||
| yield return null; | ||
| } | ||
|
|
||
| // Trains take around 20 minutes to come in by default so we can safely wait 20 seconds to make sure everyone is loaded in | ||
| yield return new WaitForSeconds(20); | ||
|
|
||
| Locomotive locomotive = FindObjectOfType<Locomotive>(); | ||
| if (locomotive != null) | ||
| { | ||
| long time = Traverse.Create(locomotive).Field<DateTime>("_depart").Value.Ticks; | ||
|
|
||
| GenericPacket packet = new() | ||
| { | ||
| NetId = player.NetId, | ||
| PacketType = EPackageType.TrainSync, | ||
| DepartureTime = time | ||
| }; | ||
|
|
||
| Writer.Reset(); | ||
| Server.SendDataToAll(Writer, ref packet, DeliveryMethod.ReliableOrdered); | ||
| } | ||
| else | ||
| { | ||
| logger.LogError("SendTrainTime: Could not find locomotive!"); | ||
| } | ||
| } | ||
| else | ||
| { | ||
| yield break; | ||
| } | ||
| } | ||
|
|
||
| public void DestroyThis() | ||
| { | ||
| Writer = null; | ||
| FirearmPackets.Clear(); | ||
| DamagePackets.Clear(); | ||
| InventoryPackets.Clear(); | ||
| CommonPlayerPackets.Clear(); | ||
| HealthSyncPackets.Clear(); | ||
| if (Server != null) | ||
| { | ||
| Server = null; | ||
| } | ||
| if (Client != null) | ||
| { | ||
| Client = null; | ||
| } | ||
| Destroy(this); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters