54 lines
1.9 KiB
C#
54 lines
1.9 KiB
C#
using System.Collections.Generic;
|
|
using NitroxModel.DataStructures.GameLogic;
|
|
using NitroxModel.DataStructures.GameLogic.Entities;
|
|
using NitroxModel.DataStructures.GameLogic.Entities.Bases;
|
|
using NitroxModel.Packets;
|
|
using NitroxServer.Communication.Packets.Processors.Abstract;
|
|
using NitroxServer.GameLogic.Entities;
|
|
|
|
namespace NitroxServer.Communication.Packets.Processors;
|
|
|
|
public class BuildingResyncRequestProcessor : AuthenticatedPacketProcessor<BuildingResyncRequest>
|
|
{
|
|
private readonly EntityRegistry entityRegistry;
|
|
private readonly WorldEntityManager worldEntityManager;
|
|
|
|
public BuildingResyncRequestProcessor(EntityRegistry entityRegistry, WorldEntityManager worldEntityManager)
|
|
{
|
|
this.entityRegistry = entityRegistry;
|
|
this.worldEntityManager = worldEntityManager;
|
|
}
|
|
|
|
public override void Process(BuildingResyncRequest packet, Player player)
|
|
{
|
|
Dictionary<BuildEntity, int> buildEntities = new();
|
|
Dictionary<ModuleEntity, int> moduleEntities = new();
|
|
void AddEntityToResync(Entity entity)
|
|
{
|
|
switch (entity)
|
|
{
|
|
case BuildEntity buildEntity:
|
|
buildEntities.Add(buildEntity, buildEntity.OperationId);
|
|
break;
|
|
case ModuleEntity moduleEntity:
|
|
moduleEntities.Add(moduleEntity, -1);
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (packet.ResyncEverything)
|
|
{
|
|
foreach (GlobalRootEntity globalRootEntity in worldEntityManager.GetGlobalRootEntities(true))
|
|
{
|
|
AddEntityToResync(globalRootEntity);
|
|
}
|
|
}
|
|
else if (packet.EntityId != null && entityRegistry.TryGetEntityById(packet.EntityId, out Entity entity))
|
|
{
|
|
AddEntityToResync(entity);
|
|
}
|
|
|
|
player.SendPacket(new BuildingResync(buildEntities, moduleEntities));
|
|
}
|
|
}
|