classpublicPriority 3
PlayerSystems
com.hypixel.hytale.server.core.modules.entity.player.PlayerSystems
6
Methods
6
Public Methods
0
Fields
1
Constructors
Constants
HytaleLoggerLOGGER= HytaleLogger.forEnclosingClass()
MessageMESSAGE_SERVER_GENERAL_KILLED_BY_UNKNOWN= Message.translation("server.general.killedByUnknown")
Constructors
public
PlayerSystems()Methods
Public Methods (6)
public
ComponentType<EntityStore, DisplayNameComponent> componentType()@Nonnull@Override
public
Set<Dependency<EntityStore>> getDependencies()@Nonnull@Override
public
Query<EntityStore> getQuery()@Nonnull@Override
public
void onEntityAdd(Holder<EntityStore> holder, AddReason reason, Store<EntityStore> store)@Override
public
void onEntityRemoved(Holder<EntityStore> holder, RemoveReason reason, Store<EntityStore> store)@Override
public
void tick(float dt, int systemIndex, Store<EntityStore> store)@Override
Related Classes
Used By
AddReasonArchetypeArchetypeChunkCommandBufferComponentTypeHolderRefRemoveReasonStoreDependencyOrderSystemDependencyQuerySpatialResourceEntityEventSystemHolderSystemQuerySystemRefChangeSystemRefSystemEntityTickingSystemRunWhenPausedSystemHytaleLoggerTransformVector3dVector3fBuilderToolsSetSoundSetSetActiveSlotSetBlockPlacementOverrideMessageGameplayConfigSpawnConfigWorldParticleEntityEffectControllerComponentPlayerPlayerWorldDataUniqueItemUsagesComponentMovementManagerRespawnPageNameplateInventoryPacketHandlerEntityModuleDisplayNameComponentHeadRotationTransformComponentDeathComponentKillFeedEventTeleportLegacyEntityTrackerSystemsPlayerRefParticleUtilPlayerUtilWorldWorldConfigEntityStore
Source Code
package com.hypixel.hytale.server.core.modules.entity.player;
import com.hypixel.hytale.component.AddReason;
import com.hypixel.hytale.component.Archetype;
import com.hypixel.hytale.component.ArchetypeChunk;
import com.hypixel.hytale.component.CommandBuffer;
import com.hypixel.hytale.component.ComponentType;
import com.hypixel.hytale.component.Holder;
import com.hypixel.hytale.component.Ref;
import com.hypixel.hytale.component.RemoveReason;
import com.hypixel.hytale.component.Store;
import com.hypixel.hytale.component.dependency.Dependency;
import com.hypixel.hytale.component.dependency.Order;
import com.hypixel.hytale.component.dependency.SystemDependency;
import com.hypixel.hytale.component.query.Query;
import com.hypixel.hytale.component.spatial.SpatialResource;
import com.hypixel.hytale.component.system.EntityEventSystem;
import com.hypixel.hytale.component.system.HolderSystem;
import com.hypixel.hytale.component.system.QuerySystem;
import com.hypixel.hytale.component.system.RefChangeSystem;
import com.hypixel.hytale.component.system.RefSystem;
import com.hypixel.hytale.component.system.tick.EntityTickingSystem;
import com.hypixel.hytale.component.system.tick.RunWhenPausedSystem;
import com.hypixel.hytale.logger.HytaleLogger;
import com.hypixel.hytale.math.vector.Transform;
import com.hypixel.hytale.math.vector.Vector3d;
import com.hypixel.hytale.math.vector.Vector3f;
import com.hypixel.hytale.protocol.packets.buildertools.BuilderToolsSetSoundSet;
import com.hypixel.hytale.protocol.packets.inventory.SetActiveSlot;
import com.hypixel.hytale.protocol.packets.player.SetBlockPlacementOverride;
import com.hypixel.hytale.server.core.Message;
import com.hypixel.hytale.server.core.asset.type.gameplay.GameplayConfig;
import com.hypixel.hytale.server.core.asset.type.gameplay.SpawnConfig;
import com.hypixel.hytale.server.core.asset.type.particle.config.WorldParticle;
import com.hypixel.hytale.server.core.entity.Entity;
import com.hypixel.hytale.server.core.entity.effect.EffectControllerComponent;
import com.hypixel.hytale.server.core.entity.entities.Player;
import com.hypixel.hytale.server.core.entity.entities.player.data.PlayerWorldData;
import com.hypixel.hytale.server.core.entity.entities.player.data.UniqueItemUsagesComponent;
import com.hypixel.hytale.server.core.entity.entities.player.movement.MovementManager;
import com.hypixel.hytale.server.core.entity.entities.player.pages.RespawnPage;
import com.hypixel.hytale.server.core.entity.nameplate.Nameplate;
import com.hypixel.hytale.server.core.inventory.Inventory;
import com.hypixel.hytale.server.core.io.PacketHandler;
import com.hypixel.hytale.server.core.modules.entity.EntityModule;
import com.hypixel.hytale.server.core.modules.entity.component.DisplayNameComponent;
import com.hypixel.hytale.server.core.modules.entity.component.HeadRotation;
import com.hypixel.hytale.server.core.modules.entity.component.TransformComponent;
import com.hypixel.hytale.server.core.modules.entity.damage.DeathComponent;
import com.hypixel.hytale.server.core.modules.entity.damage.event.KillFeedEvent;
import com.hypixel.hytale.server.core.modules.entity.teleport.Teleport;
import com.hypixel.hytale.server.core.modules.entity.tracker.LegacyEntityTrackerSystems;
import com.hypixel.hytale.server.core.universe.PlayerRef;
import com.hypixel.hytale.server.core.universe.world.ParticleUtil;
import com.hypixel.hytale.server.core.universe.world.PlayerUtil;
import com.hypixel.hytale.server.core.universe.world.World;
import com.hypixel.hytale.server.core.universe.world.WorldConfig;
import com.hypixel.hytale.server.core.universe.world.storage.EntityStore;
import it.unimi.dsi.fastutil.objects.ObjectList;
import java.util.List;
import java.util.Objects;
import java.util.Set;
import java.util.logging.Level;
import javax.annotation.Nonnull;
public class PlayerSystems {
@Nonnull
public static final HytaleLogger LOGGER = HytaleLogger.forEnclosingClass();
public PlayerSystems() {
}
public static class BlockPausedMovementSystem implements RunWhenPausedSystem<EntityStore>, QuerySystem<EntityStore> {
@Nonnull
private final Query<EntityStore> query = Query.and(
Player.getComponentType(), PlayerInput.getComponentType(), TransformComponent.getComponentType(), HeadRotation.getComponentType()
);
public BlockPausedMovementSystem() {
}
@Override
public void tick(float dt, int systemIndex, @Nonnull Store<EntityStore> store) {
store.forEachChunk(systemIndex, PlayerSystems.BlockPausedMovementSystem::onTick);
}
private static void onTick(@Nonnull ArchetypeChunk<EntityStore> archetypeChunk, @Nonnull CommandBuffer<EntityStore> commandBuffer) {
for (int index = 0; index < archetypeChunk.size(); index++) {
PlayerInput playerInputComponent = archetypeChunk.getComponent(index, PlayerInput.getComponentType());
assert playerInputComponent != null;
boolean shouldTeleport = false;
TransformComponent transformComponent = archetypeChunk.getComponent(index, TransformComponent.getComponentType());
assert transformComponent != null;
HeadRotation headRotationComponent = archetypeChunk.getComponent(index, HeadRotation.getComponentType());
assert headRotationComponent != null;
List<PlayerInput.InputUpdate> movementUpdateQueue = playerInputComponent.getMovementUpdateQueue();
for (PlayerInput.InputUpdate entry : movementUpdateQueue) {
Objects.requireNonNull(entry);
switch (entry) {
case PlayerInput.AbsoluteMovement abs:
shouldTeleport = transformComponent.getPosition().distanceSquaredTo(abs.getX(), abs.getY(), abs.getZ()) > 0.009999999776482582;
break;
case PlayerInput.RelativeMovement rel:
Vector3d position = transformComponent.getPosition();
shouldTeleport = transformComponent.getPosition()
.distanceSquaredTo(position.x + rel.getX(), position.y + rel.getY(), position.z + rel.getZ())
> 0.009999999776482582;
break;
case PlayerInput.SetHead head:
shouldTeleport = headRotationComponent.getRotation()
.distanceSquaredTo(head.direction().pitch, head.direction().yaw, head.direction().roll)
> 0.01F;
break;
}
}
movementUpdateQueue.clear();
if (shouldTeleport) {
Teleport teleport = Teleport.createExact(transformComponent.getPosition(), transformComponent.getRotation(), headRotationComponent.getRotation())
.withoutVelocityReset();
Ref<EntityStore> ref = archetypeChunk.getReferenceTo(index);
commandBuffer.addComponent(ref, Teleport.getComponentType(), teleport);
}
}
}
@Nonnull
@Override
public Query<EntityStore> getQuery() {
return this.query;
}
}
public static class EnsureEffectControllerSystem extends HolderSystem<EntityStore> {
public EnsureEffectControllerSystem() {
}
@Override
public Query<EntityStore> getQuery() {
return PlayerRef.getComponentType();
}
@Override
public void onEntityAdd(@Nonnull Holder<EntityStore> holder, @Nonnull AddReason reason, @Nonnull Store<EntityStore> store) {
holder.ensureComponent(EffectControllerComponent.getComponentType());
}
@Override
public void onEntityRemoved(@Nonnull Holder<EntityStore> holder, @Nonnull RemoveReason reason, @Nonnull Store<EntityStore> store) {
}
}
public static class EnsurePlayerInput extends HolderSystem<EntityStore> {
public EnsurePlayerInput() {
}
@Override
public Query<EntityStore> getQuery() {
return PlayerRef.getComponentType();
}
@Override
public void onEntityAdd(@Nonnull Holder<EntityStore> holder, @Nonnull AddReason reason, @Nonnull Store<EntityStore> store) {
holder.ensureComponent(PlayerInput.getComponentType());
}
@Override
public void onEntityRemoved(@Nonnull Holder<EntityStore> holder, @Nonnull RemoveReason reason, @Nonnull Store<EntityStore> store) {
holder.removeComponent(PlayerInput.getComponentType());
}
}
public static class EnsureUniqueItemUsagesSystem extends HolderSystem<EntityStore> {
public EnsureUniqueItemUsagesSystem() {
}
@Override
public Query<EntityStore> getQuery() {
return Query.and(PlayerRef.getComponentType(), Query.not(UniqueItemUsagesComponent.getComponentType()));
}
@Override
public void onEntityAdd(@Nonnull Holder<EntityStore> holder, @Nonnull AddReason reason, @Nonnull Store<EntityStore> store) {
holder.ensureComponent(UniqueItemUsagesComponent.getComponentType());
}
@Override
public void onEntityRemoved(@Nonnull Holder<EntityStore> holder, @Nonnull RemoveReason reason, @Nonnull Store<EntityStore> store) {
}
}
public static class KillFeedDecedentEventSystem extends EntityEventSystem<EntityStore, KillFeedEvent.DecedentMessage> {
@Nonnull
private final ComponentType<EntityStore, PlayerRef> playerRefComponentType = PlayerRef.getComponentType();
public KillFeedDecedentEventSystem() {
super(KillFeedEvent.DecedentMessage.class);
}
public void handle(
int index,
@Nonnull ArchetypeChunk<EntityStore> archetypeChunk,
@Nonnull Store<EntityStore> store,
@Nonnull CommandBuffer<EntityStore> commandBuffer,
@Nonnull KillFeedEvent.DecedentMessage event
) {
DisplayNameComponent displayNameComponent = archetypeChunk.getComponent(index, DisplayNameComponent.getComponentType());
Message displayName;
if (displayNameComponent != null) {
displayName = displayNameComponent.getDisplayName();
} else {
PlayerRef playerRefComponent = archetypeChunk.getComponent(index, this.playerRefComponentType);
assert playerRefComponent != null;
displayName = Message.raw(playerRefComponent.getUsername());
}
event.setMessage(displayName);
}
@Nonnull
@Override
public Query<EntityStore> getQuery() {
return this.playerRefComponentType;
}
}
public static class KillFeedKillerEventSystem extends EntityEventSystem<EntityStore, KillFeedEvent.KillerMessage> {
@Nonnull
private final ComponentType<EntityStore, PlayerRef> playerRefComponentType = PlayerRef.getComponentType();
public KillFeedKillerEventSystem() {
super(KillFeedEvent.KillerMessage.class);
}
public void handle(
int index,
@Nonnull ArchetypeChunk<EntityStore> archetypeChunk,
@Nonnull Store<EntityStore> store,
@Nonnull CommandBuffer<EntityStore> commandBuffer,
@Nonnull KillFeedEvent.KillerMessage event
) {
DisplayNameComponent displayNameComponent = archetypeChunk.getComponent(index, DisplayNameComponent.getComponentType());
Message displayName;
if (displayNameComponent != null) {
displayName = displayNameComponent.getDisplayName();
} else {
PlayerRef playerRefComponent = archetypeChunk.getComponent(index, this.playerRefComponentType);
assert playerRefComponent != null;
displayName = Message.raw(playerRefComponent.getUsername());
}
event.setMessage(displayName);
}
@Nonnull
@Override
public Query<EntityStore> getQuery() {
return this.playerRefComponentType;
}
}
public static class NameplateRefChangeSystem extends RefChangeSystem<EntityStore, DisplayNameComponent> {
public NameplateRefChangeSystem() {
}
@Nonnull
@Override
public Query<EntityStore> getQuery() {
return Player.getComponentType();
}
@Nonnull
@Override
public ComponentType<EntityStore, DisplayNameComponent> componentType() {
return DisplayNameComponent.getComponentType();
}
public void onComponentAdded(
@Nonnull Ref<EntityStore> ref,
@Nonnull DisplayNameComponent component,
@Nonnull Store<EntityStore> store,
@Nonnull CommandBuffer<EntityStore> commandBuffer
) {
Nameplate nameplateComponent = commandBuffer.ensureAndGetComponent(ref, Nameplate.getComponentType());
nameplateComponent.setText(component.getDisplayName() != null ? component.getDisplayName().getAnsiMessage() : "");
}
public void onComponentSet(
@Nonnull Ref<EntityStore> ref,
DisplayNameComponent oldComponent,
@Nonnull DisplayNameComponent newComponent,
@Nonnull Store<EntityStore> store,
@Nonnull CommandBuffer<EntityStore> commandBuffer
) {
Nameplate nameplateComponent = commandBuffer.ensureAndGetComponent(ref, Nameplate.getComponentType());
nameplateComponent.setText(newComponent.getDisplayName() != null ? newComponent.getDisplayName().getAnsiMessage() : "");
}
public void onComponentRemoved(
@Nonnull Ref<EntityStore> ref,
@Nonnull DisplayNameComponent component,
@Nonnull Store<EntityStore> store,
@Nonnull CommandBuffer<EntityStore> commandBuffer
) {
Nameplate nameplateComponent = commandBuffer.ensureAndGetComponent(ref, Nameplate.getComponentType());
nameplateComponent.setText("");
}
}
public static class NameplateRefSystem extends RefSystem<EntityStore> {
public NameplateRefSystem() {
}
@Nonnull
@Override
public Query<EntityStore> getQuery() {
return Archetype.of(Player.getComponentType(), DisplayNameComponent.getComponentType());
}
@Override
public void onEntityAdded(
@Nonnull Ref<EntityStore> ref, @Nonnull AddReason reason, @Nonnull Store<EntityStore> store, @Nonnull CommandBuffer<EntityStore> commandBuffer
) {
DisplayNameComponent displayNameComponent = commandBuffer.getComponent(ref, DisplayNameComponent.getComponentType());
assert displayNameComponent != null;
if (commandBuffer.getComponent(ref, Nameplate.getComponentType()) == null) {
String displayName = displayNameComponent.getDisplayName() != null ? displayNameComponent.getDisplayName().getAnsiMessage() : "";
Nameplate nameplateComponent = new Nameplate(displayName);
commandBuffer.putComponent(ref, Nameplate.getComponentType(), nameplateComponent);
}
}
@Override
public void onEntityRemove(
@Nonnull Ref<EntityStore> ref, @Nonnull RemoveReason reason, @Nonnull Store<EntityStore> store, @Nonnull CommandBuffer<EntityStore> commandBuffer
) {
}
}
public static class PlayerAddedSystem extends RefSystem<EntityStore> {
@Nonnull
private static final Message MESSAGE_SERVER_GENERAL_KILLED_BY_UNKNOWN = Message.translation("server.general.killedByUnknown");
@Nonnull
private final Set<Dependency<EntityStore>> dependencies = Set.of(new SystemDependency<>(Order.AFTER, PlayerSystems.PlayerSpawnedSystem.class));
@Nonnull
private final Query<EntityStore> query;
public PlayerAddedSystem(@Nonnull ComponentType<EntityStore, MovementManager> movementManagerComponentType) {
this.query = Query.and(Player.getComponentType(), PlayerRef.getComponentType(), movementManagerComponentType);
}
@Nonnull
@Override
public Query<EntityStore> getQuery() {
return this.query;
}
@Nonnull
@Override
public Set<Dependency<EntityStore>> getDependencies() {
return this.dependencies;
}
@Override
public void onEntityAdded(
@Nonnull Ref<EntityStore> ref, @Nonnull AddReason reason, @Nonnull Store<EntityStore> store, @Nonnull CommandBuffer<EntityStore> commandBuffer
) {
World world = commandBuffer.getExternalData().getWorld();
Player playerComponent = commandBuffer.getComponent(ref, Player.getComponentType());
assert playerComponent != null;
PlayerRef playerRefComponent = commandBuffer.getComponent(ref, PlayerRef.getComponentType());
assert playerRefComponent != null;
MovementManager movementManagerComponent = commandBuffer.getComponent(ref, MovementManager.getComponentType());
assert movementManagerComponent != null;
if (commandBuffer.getComponent(ref, DisplayNameComponent.getComponentType()) == null) {
Message displayName = Message.raw(playerRefComponent.getUsername());
commandBuffer.putComponent(ref, DisplayNameComponent.getComponentType(), new DisplayNameComponent(displayName));
}
playerComponent.setLastSpawnTimeNanos(System.nanoTime());
PacketHandler playerConnection = playerRefComponent.getPacketHandler();
Objects.requireNonNull(world, "world");
Objects.requireNonNull(playerComponent.getPlayerConfigData(), "data");
PlayerWorldData perWorldData = playerComponent.getPlayerConfigData().getPerWorldData(world.getName());
Player.initGameMode(ref, commandBuffer);
playerConnection.writeNoCache(new BuilderToolsSetSoundSet(world.getGameplayConfig().getCreativePlaySoundSetIndex()));
playerComponent.sendInventory();
Inventory playerInventory = playerComponent.getInventory();
playerConnection.writeNoCache(new SetActiveSlot(-1, playerInventory.getActiveHotbarSlot()));
playerConnection.writeNoCache(new SetActiveSlot(-5, playerInventory.getActiveUtilitySlot()));
playerConnection.writeNoCache(new SetActiveSlot(-8, playerInventory.getActiveToolsSlot()));
if (playerInventory.containsBrokenItem()) {
playerComponent.sendMessage(Message.translation("server.general.repair.itemBrokenOnRespawn").color("#ff5555"));
}
playerConnection.writeNoCache(new SetBlockPlacementOverride(playerComponent.isOverrideBlockPlacementRestrictions()));
DeathComponent deathComponent = commandBuffer.getComponent(ref, DeathComponent.getComponentType());
if (deathComponent != null) {
Message pendingDeathMessage = deathComponent.getDeathMessage();
if (pendingDeathMessage == null) {
((HytaleLogger.Api)Entity.LOGGER.at(Level.SEVERE).withCause(new Throwable()))
.log("Player wasn't alive but didn't have a pending death message?");
pendingDeathMessage = MESSAGE_SERVER_GENERAL_KILLED_BY_UNKNOWN;
}
RespawnPage respawnPage = new RespawnPage(
playerRefComponent, pendingDeathMessage, deathComponent.displayDataOnDeathScreen(), deathComponent.getDeathItemLoss()
);
playerComponent.getPageManager().openCustomPage(ref, store, respawnPage);
}
TransformComponent transform = commandBuffer.getComponent(ref, TransformComponent.getComponentType());
GameplayConfig gameplayConfig = world.getGameplayConfig();
SpawnConfig spawnConfig = gameplayConfig.getSpawnConfig();
if (transform != null) {
Vector3d position = transform.getPosition();
SpatialResource<Ref<EntityStore>, EntityStore> playerSpatialResource = commandBuffer.getResource(EntityModule.get().getPlayerSpatialResourceType());
ObjectList<Ref<EntityStore>> results = SpatialResource.getThreadLocalReferenceList();
playerSpatialResource.getSpatialStructure().collect(position, 75.0, results);
results.add(ref);
if (playerComponent.isFirstSpawn()) {
WorldParticle[] firstSpawnParticles = spawnConfig.getFirstSpawnParticles();
if (firstSpawnParticles == null) {
firstSpawnParticles = spawnConfig.getSpawnParticles();
}
if (firstSpawnParticles != null) {
ParticleUtil.spawnParticleEffects(firstSpawnParticles, position, null, results, commandBuffer);
}
} else {
WorldParticle[] spawnParticles = spawnConfig.getSpawnParticles();
if (spawnParticles != null) {
ParticleUtil.spawnParticleEffects(spawnParticles, position, null, results, commandBuffer);
}
}
}
playerConnection.tryFlush();
perWorldData.setFirstSpawn(false);
}
@Override
public void onEntityRemove(
@Nonnull Ref<EntityStore> ref, @Nonnull RemoveReason reason, @Nonnull Store<EntityStore> store, @Nonnull CommandBuffer<EntityStore> commandBuffer
) {
}
}
public static class PlayerRemovedSystem extends HolderSystem<EntityStore> {
public PlayerRemovedSystem() {
}
@Override
public Query<EntityStore> getQuery() {
return PlayerRef.getComponentType();
}
@Override
public void onEntityAdd(@Nonnull Holder<EntityStore> holder, @Nonnull AddReason reason, @Nonnull Store<EntityStore> store) {
}
@Override
public void onEntityRemoved(@Nonnull Holder<EntityStore> holder, @Nonnull RemoveReason reason, @Nonnull Store<EntityStore> store) {
World world = store.getExternalData().getWorld();
PlayerRef playerRefComponent = holder.getComponent(PlayerRef.getComponentType());
assert playerRefComponent != null;
Player playerComponent = holder.getComponent(Player.getComponentType());
assert playerComponent != null;
TransformComponent transformComponent = holder.getComponent(TransformComponent.getComponentType());
assert transformComponent != null;
HeadRotation headRotationComponent = holder.getComponent(HeadRotation.getComponentType());
assert headRotationComponent != null;
DisplayNameComponent displayNameComponent = holder.getComponent(DisplayNameComponent.getComponentType());
assert displayNameComponent != null;
Message displayName = displayNameComponent.getDisplayName();
PlayerSystems.LOGGER
.at(Level.INFO)
.log(
"Removing player '%s%s' from world '%s' (%s)",
playerRefComponent.getUsername(),
displayName != null ? " (" + displayName.getAnsiMessage() + ")" : "",
world.getName(),
playerRefComponent.getUuid()
);
playerComponent.getPlayerConfigData()
.getPerWorldData(world.getName())
.setLastPosition(new Transform(transformComponent.getPosition().clone(), headRotationComponent.getRotation().clone()));
playerRefComponent.getPacketHandler().setQueuePackets(false);
playerRefComponent.getPacketHandler().tryFlush();
WorldConfig worldConfig = world.getWorldConfig();
PlayerUtil.broadcastMessageToPlayers(
playerRefComponent.getUuid(),
Message.translation("server.general.playerLeftWorld")
.param("username", playerRefComponent.getUsername())
.param("world", worldConfig.getDisplayName() != null ? worldConfig.getDisplayName() : WorldConfig.formatDisplayName(world.getName())),
store
);
}
}
public static class PlayerSpawnedSystem extends RefSystem<EntityStore> {
public PlayerSpawnedSystem() {
}
@Nonnull
@Override
public Query<EntityStore> getQuery() {
return Player.getComponentType();
}
@Override
public void onEntityAdded(
@Nonnull Ref<EntityStore> ref, @Nonnull AddReason reason, @Nonnull Store<EntityStore> store, @Nonnull CommandBuffer<EntityStore> commandBuffer
) {
LegacyEntityTrackerSystems.sendPlayerSelf(ref, store);
}
@Override
public void onEntityRemove(
@Nonnull Ref<EntityStore> ref, @Nonnull RemoveReason reason, @Nonnull Store<EntityStore> store, @Nonnull CommandBuffer<EntityStore> commandBuffer
) {
}
}
public static class ProcessPlayerInput extends EntityTickingSystem<EntityStore> {
@Nonnull
private final Query<EntityStore> query = Query.and(Player.getComponentType(), PlayerInput.getComponentType(), TransformComponent.getComponentType());
public ProcessPlayerInput() {
}
@Nonnull
@Override
public Query<EntityStore> getQuery() {
return this.query;
}
@Override
public void tick(
float dt,
int index,
@Nonnull ArchetypeChunk<EntityStore> archetypeChunk,
@Nonnull Store<EntityStore> store,
@Nonnull CommandBuffer<EntityStore> commandBuffer
) {
PlayerInput playerInputComponent = archetypeChunk.getComponent(index, PlayerInput.getComponentType());
assert playerInputComponent != null;
List<PlayerInput.InputUpdate> movementUpdateQueue = playerInputComponent.getMovementUpdateQueue();
for (PlayerInput.InputUpdate entry : movementUpdateQueue) {
entry.apply(commandBuffer, archetypeChunk, index);
}
movementUpdateQueue.clear();
}
}
public static class UpdatePlayerRef extends EntityTickingSystem<EntityStore> {
@Nonnull
private final Query<EntityStore> query = Query.and(PlayerRef.getComponentType(), TransformComponent.getComponentType(), HeadRotation.getComponentType());
public UpdatePlayerRef() {
}
@Nonnull
@Override
public Query<EntityStore> getQuery() {
return this.query;
}
@Override
public void tick(
float dt,
int index,
@Nonnull ArchetypeChunk<EntityStore> archetypeChunk,
@Nonnull Store<EntityStore> store,
@Nonnull CommandBuffer<EntityStore> commandBuffer
) {
World world = commandBuffer.getExternalData().getWorld();
TransformComponent transformComponent = archetypeChunk.getComponent(index, TransformComponent.getComponentType());
assert transformComponent != null;
Transform transform = transformComponent.getTransform();
HeadRotation headRotationComponent = archetypeChunk.getComponent(index, HeadRotation.getComponentType());
assert headRotationComponent != null;
Vector3f headRotation = headRotationComponent.getRotation();
PlayerRef playerRefComponent = archetypeChunk.getComponent(index, PlayerRef.getComponentType());
assert playerRefComponent != null;
playerRefComponent.updatePosition(world, transform, headRotation);
}
}
}