package com.burnedkirby.TurnBasedMinecraft.common; import com.burnedkirby.TurnBasedMinecraft.common.networking.PacketBattleInfo; import com.burnedkirby.TurnBasedMinecraft.common.networking.PacketBattleMessage; import com.burnedkirby.TurnBasedMinecraft.common.networking.PacketBattlePing; import net.minecraft.resources.ResourceKey; import net.minecraft.server.level.ServerPlayer; import net.minecraft.world.InteractionHand; import net.minecraft.world.damagesource.DamageSource; import net.minecraft.world.effect.MobEffects; import net.minecraft.world.entity.Entity; import net.minecraft.world.entity.LivingEntity; import net.minecraft.world.entity.Mob; import net.minecraft.world.entity.monster.Creeper; import net.minecraft.world.entity.player.Player; import net.minecraft.world.item.*; import net.minecraft.world.level.Level; import net.minecraftforge.common.CreativeModeTabRegistry; import net.minecraftforge.network.PacketDistributor; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicInteger; public class Battle { private final int id; private Map sideA; private Map sideB; private Map players; private PriorityQueue turnOrderQueue; private Queue sideAEntryQueue; private Queue sideBEntryQueue; private State state; private AtomicInteger playerCount; private AtomicInteger undecidedCount; private long lastInstant; private long timer; private boolean timerForever; private boolean isServer; private boolean battleEnded; private BattleManager battleManager; private Random random; public String debugLog; // TODO remove after freeze bug has been found private ResourceKey dimension; private long pingTimerNanos; public enum State { DECISION(0), ACTION(1), DECISION_PLAYER_READY(2); private int value; private static Map map = new HashMap(); State(int value) { this.value = value; } public int getValue() { return value; } static { for (State state : State.values()) { map.put(state.value, state); } } public static State valueOf(int stateType) { return map.get(stateType); } } public enum Decision { UNDECIDED(0), ATTACK(1), DEFEND(2), FLEE(3), USE_ITEM(4), SWITCH_ITEM(5), CREEPER_WAIT(6), CREEPER_EXPLODE(7); private int value; private static Map map = new HashMap(); Decision(int value) { this.value = value; } public int getValue() { return value; } static { for (Decision decision : Decision.values()) { map.put(decision.value, decision); } } public static Decision valueOf(int decisionType) { return map.get(decisionType); } } public Battle(BattleManager battleManager, int id, Collection sideA, Collection sideB, boolean isServer, ResourceKey dimension) { this.battleManager = battleManager; this.isServer = isServer; this.id = id; this.sideA = new ConcurrentHashMap(); this.sideB = new ConcurrentHashMap(); players = new ConcurrentHashMap(); turnOrderQueue = new PriorityQueue(new Combatant.CombatantComparator()); sideAEntryQueue = new ArrayDeque(); sideBEntryQueue = new ArrayDeque(); playerCount = new AtomicInteger(0); undecidedCount = new AtomicInteger(0); random = new Random(); this.dimension = dimension; pingTimerNanos = 0; if (sideA != null) { for (Entity e : sideA) { EntityInfo entityInfo; try { entityInfo = TurnBasedMinecraftMod.proxy.getConfig().getCustomEntityInfoReference(e.getCustomName().getString()); } catch (NullPointerException exception) { entityInfo = null; } if (entityInfo == null) { entityInfo = TurnBasedMinecraftMod.proxy.getConfig().getMatchingEntityInfo(e); } if (entityInfo == null && !(e instanceof Player) && TurnBasedMinecraftMod.proxy.isServerRunning()) { continue; } Combatant newCombatant = new Combatant(e, entityInfo); newCombatant.isSideA = true; newCombatant.battleID = getId(); this.sideA.put(e.getId(), newCombatant); if (e instanceof Player) { newCombatant.recalcSpeedOnCompare = true; playerCount.incrementAndGet(); players.put(e.getId(), newCombatant); } if (TurnBasedMinecraftMod.proxy.getConfig().isFreezeCombatantsEnabled()) { newCombatant.x = e.getX(); newCombatant.z = e.getZ(); newCombatant.yaw = e.getXRot(); newCombatant.pitch = e.getYRot(); } } } if (sideB != null) { for (Entity e : sideB) { EntityInfo entityInfo; try { entityInfo = TurnBasedMinecraftMod.proxy.getConfig().getCustomEntityInfoReference(e.getCustomName().getString()); } catch (NullPointerException exception) { entityInfo = null; } if (entityInfo == null) { entityInfo = TurnBasedMinecraftMod.proxy.getConfig().getMatchingEntityInfo(e); } if (entityInfo == null && !(e instanceof Player) && TurnBasedMinecraftMod.proxy.isServerRunning()) { continue; } Combatant newCombatant = new Combatant(e, entityInfo); newCombatant.isSideA = false; newCombatant.battleID = getId(); this.sideB.put(e.getId(), newCombatant); if (e instanceof Player) { newCombatant.recalcSpeedOnCompare = true; playerCount.incrementAndGet(); players.put(e.getId(), newCombatant); } if (TurnBasedMinecraftMod.proxy.getConfig().isFreezeCombatantsEnabled()) { newCombatant.x = e.getX(); newCombatant.z = e.getZ(); newCombatant.yaw = e.getXRot(); newCombatant.pitch = e.getYRot(); } } } if (isServer) { for (Combatant c : this.sideA.values()) { if (c.entityInfo != null) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, c.entity.getId(), 0, id, c.entityInfo.category); } else if (c.entity instanceof Player) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, c.entity.getId(), 0, id, "player"); } else { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, c.entity.getId(), 0, id); } } for (Combatant c : this.sideB.values()) { if (c.entityInfo != null) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, c.entity.getId(), 0, id, c.entityInfo.category); } else if (c.entity instanceof Player) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, c.entity.getId(), 0, id, "player"); } else { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, c.entity.getId(), 0, id); } } } lastInstant = System.nanoTime(); state = State.DECISION; undecidedCount.set(playerCount.get()); timer = TurnBasedMinecraftMod.proxy.getConfig().getDecisionDurationNanos(); timerForever = TurnBasedMinecraftMod.proxy.getConfig().isBattleDecisionDurationForever(); battleEnded = false; notifyPlayersBattleInfo(); } public int getId() { return id; } public Entity getCombatantEntity(int entityID) { Combatant c = sideA.get(entityID); if (c != null) { return c.entity; } c = sideB.get(entityID); if (c != null) { return c.entity; } return null; } public boolean hasCombatant(int entityID) { for (Combatant c : sideAEntryQueue) { if (c.entity.getId() == entityID) { return true; } } for (Combatant c : sideBEntryQueue) { if (c.entity.getId() == entityID) { return true; } } return sideA.containsKey(entityID) || sideB.containsKey(entityID); } public boolean hasCombatantInSideA(int entityID) { for (Combatant c : sideAEntryQueue) { if (c.entity.getId() == entityID) { return true; } } return sideA.containsKey(entityID); } public void addCombatantToSideA(Entity e) { EntityInfo entityInfo; try { entityInfo = TurnBasedMinecraftMod.proxy.getConfig().getCustomEntityInfoReference(e.getCustomName().getString()); } catch (NullPointerException exception) { entityInfo = null; } if (entityInfo == null) { entityInfo = TurnBasedMinecraftMod.proxy.getConfig().getMatchingEntityInfo(e); } if (isServer && entityInfo == null && !(e instanceof Player) && TurnBasedMinecraftMod.proxy.isServerRunning()) { return; } Combatant newCombatant = new Combatant(e, entityInfo); newCombatant.isSideA = true; newCombatant.battleID = getId(); if (isServer) { sideAEntryQueue.add(newCombatant); } else { sideA.put(e.getId(), newCombatant); } if (e instanceof Player) { newCombatant.recalcSpeedOnCompare = true; playerCount.incrementAndGet(); players.put(e.getId(), newCombatant); if (state == State.DECISION) { undecidedCount.incrementAndGet(); } } if (TurnBasedMinecraftMod.proxy.getConfig().isFreezeCombatantsEnabled()) { newCombatant.x = e.getX(); newCombatant.z = e.getZ(); newCombatant.yaw = e.getXRot(); newCombatant.pitch = e.getYRot(); } if (isServer) { if (newCombatant.entityInfo != null) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, newCombatant.entity.getId(), 0, id, newCombatant.entityInfo.category); } else if (newCombatant.entity instanceof Player) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, newCombatant.entity.getId(), 0, id, "player"); } else { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, newCombatant.entity.getId(), 0, id); } } notifyPlayersBattleInfo(); } public void addCombatantToSideB(Entity e) { EntityInfo entityInfo; try { entityInfo = TurnBasedMinecraftMod.proxy.getConfig().getCustomEntityInfoReference(e.getCustomName().getString()); } catch (NullPointerException exception) { entityInfo = null; } if (entityInfo == null) { entityInfo = TurnBasedMinecraftMod.proxy.getConfig().getMatchingEntityInfo(e); } if (isServer && entityInfo == null && !(e instanceof Player) && TurnBasedMinecraftMod.proxy.isServerRunning()) { return; } Combatant newCombatant = new Combatant(e, entityInfo); newCombatant.isSideA = false; newCombatant.battleID = getId(); if (isServer) { sideBEntryQueue.add(newCombatant); } else { sideB.put(e.getId(), newCombatant); } if (e instanceof Player) { newCombatant.recalcSpeedOnCompare = true; playerCount.incrementAndGet(); players.put(e.getId(), newCombatant); if (state == State.DECISION) { undecidedCount.incrementAndGet(); } } if (TurnBasedMinecraftMod.proxy.getConfig().isFreezeCombatantsEnabled()) { newCombatant.x = e.getX(); newCombatant.z = e.getZ(); newCombatant.yaw = e.getXRot(); newCombatant.pitch = e.getYRot(); } if (isServer) { if (newCombatant.entityInfo != null) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, newCombatant.entity.getId(), 0, id, newCombatant.entityInfo.category); } else if (newCombatant.entity instanceof Player) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, newCombatant.entity.getId(), 0, id, "player"); } else { sendMessageToAllPlayers(PacketBattleMessage.MessageType.ENTERED, newCombatant.entity.getId(), 0, id); } } notifyPlayersBattleInfo(); } public void clearCombatants() { sideA.clear(); sideB.clear(); sideAEntryQueue.clear(); sideBEntryQueue.clear(); players.clear(); playerCount.set(0); undecidedCount.set(0); } public Collection getSideA() { return sideA.values(); } public Collection getSideB() { return sideB.values(); } public Set> getSideAEntrySet() { return sideA.entrySet(); } public Set> getSideBEntrySet() { return sideB.entrySet(); } public Collection getSideAIDs() { Collection sideAIDs = new ArrayList(sideA.size()); for (Combatant combatant : sideA.values()) { sideAIDs.add(combatant.entity.getId()); } return sideAIDs; } public Collection getSideBIDs() { Collection sideBIDs = new ArrayList(sideB.size()); for (Combatant combatant : sideB.values()) { sideBIDs.add(combatant.entity.getId()); } return sideBIDs; } public Combatant getCombatantByID(int entityID) { Combatant combatant = sideA.get(entityID); if (combatant == null) { combatant = sideB.get(entityID); } return combatant; } public void setDecision(int entityID, Decision decision, int targetIDOrItemID) { if (state != State.DECISION) { return; } Combatant combatant = players.get(entityID); if (combatant == null || combatant.decision != Decision.UNDECIDED) { return; } combatant.decision = decision; if (decision == Decision.ATTACK) { combatant.targetEntityID = targetIDOrItemID; } else if (decision == Decision.USE_ITEM || decision == Decision.SWITCH_ITEM) { combatant.itemToUse = targetIDOrItemID; } undecidedCount.decrementAndGet(); } public State getState() { return state; } public void setState(State state) { this.state = state; } public long getTimerSeconds() { return timer / 1000000000L; } public long getTimerNanos() { return timer; } public int getSize() { int size = sideA.size() + sideB.size(); size += sideAEntryQueue.size(); size += sideBEntryQueue.size(); return size; } protected void notifyPlayersBattleInfo() { if (!isServer) { return; } PacketBattleInfo infoPacket = new PacketBattleInfo(getId(), getSideAIDs(), getSideBIDs(), timer, TurnBasedMinecraftMod.proxy.getConfig().getDecisionDurationNanos(), !TurnBasedMinecraftMod.proxy.getConfig().isBattleDecisionDurationForever()); for (Combatant p : players.values()) { TurnBasedMinecraftMod.getHandler().send(infoPacket, PacketDistributor.PLAYER.with((ServerPlayer)p.entity)); } } protected void notifyPlayersBattlePing() { if (!isServer) { return; } PacketBattlePing pingPacket = new PacketBattlePing(getId(), (int)(timer / 1000000000L)); for (Combatant p : players.values()) { TurnBasedMinecraftMod.getHandler().send(pingPacket, PacketDistributor.PLAYER.with((ServerPlayer)p.entity)); } } protected void sendMessageToAllPlayers(PacketBattleMessage.MessageType type, int from, int to, int amount) { sendMessageToAllPlayers(type, from, to, amount, new String()); } protected void sendMessageToAllPlayers(PacketBattleMessage.MessageType type, int from, int to, int amount, String custom) { if (!isServer) { return; } PacketBattleMessage packet = new PacketBattleMessage(type, from, to, dimension, amount, custom); for (Combatant p : players.values()) { if (p.entity.isAlive()) { TurnBasedMinecraftMod.getHandler().send(packet, PacketDistributor.PLAYER.with((ServerPlayer)p.entity)); } } } /** * @return true if at least one combatant was removed */ private boolean healthCheck() { boolean didRemove = false; for (Iterator> iter = sideA.entrySet().iterator(); iter.hasNext(); ) { Map.Entry entry = iter.next(); if (!entry.getValue().entity.isAlive()) { iter.remove(); players.remove(entry.getKey()); removeCombatantPostRemove(entry.getValue()); didRemove = true; String category = null; if (entry.getValue().entityInfo != null) { category = entry.getValue().entityInfo.category; } else if (entry.getValue().entity instanceof Player) { category = "player"; } sendMessageToAllPlayers(PacketBattleMessage.MessageType.DIED, entry.getValue().entity.getId(), 0, 0, category); } } for (Iterator> iter = sideB.entrySet().iterator(); iter.hasNext(); ) { Map.Entry entry = iter.next(); if (!entry.getValue().entity.isAlive()) { iter.remove(); players.remove(entry.getKey()); removeCombatantPostRemove(entry.getValue()); didRemove = true; String category = null; if (entry.getValue().entityInfo != null) { category = entry.getValue().entityInfo.category; } else if (entry.getValue().entity instanceof Player) { category = "player"; } sendMessageToAllPlayers(PacketBattleMessage.MessageType.DIED, entry.getValue().entity.getId(), 0, 0, category); } } if (players.isEmpty() || sideA.isEmpty() || sideB.isEmpty()) { battleEnded = true; } else if (didRemove) { resetUndecidedCount(); } return didRemove; } /** * @return true if at least one combatant was removed */ private boolean isCreativeCheck() { boolean didRemove = false; for (Iterator> iter = players.entrySet().iterator(); iter.hasNext(); ) { Map.Entry entry = iter.next(); if (entry.getValue().entity != null && ((Player) entry.getValue().entity).isCreative()) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.BECAME_CREATIVE, entry.getValue().entity.getId(), 0, 0); iter.remove(); sideA.remove(entry.getKey()); sideB.remove(entry.getKey()); playerCount.decrementAndGet(); removeCombatantPostRemove(entry.getValue()); didRemove = true; } } if (didRemove) { resetUndecidedCount(); } return didRemove; } private void resetUndecidedCount() { if (state == State.DECISION) { undecidedCount.set(0); for (Combatant p : players.values()) { if (p.decision == Decision.UNDECIDED) { undecidedCount.incrementAndGet(); } } } } private void enforceFreezePositions() { for (Combatant c : sideA.values()) { c.entity.setPos(c.x, c.entity.getY(), c.z); c.entity.setYBodyRot(c.yaw); c.entity.setYHeadRot(c.pitch); } for (Combatant c : sideB.values()) { c.entity.setPos(c.x, c.entity.getY(), c.z); c.entity.setYBodyRot(c.yaw); c.entity.setYHeadRot(c.pitch); } } private void removeCombatant(Combatant c) { sideA.remove(c.entity.getId()); sideB.remove(c.entity.getId()); if (players.remove(c.entity.getId()) != null) { playerCount.decrementAndGet(); } removeCombatantPostRemove(c); } private void removeCombatantPostRemove(Combatant c) { if (c.entity instanceof Player) { TurnBasedMinecraftMod.getHandler().send(new PacketBattleMessage(PacketBattleMessage.MessageType.ENDED, 0, 0, dimension, 0), PacketDistributor.PLAYER.with((ServerPlayer)c.entity)); } battleManager.addRecentlyLeftBattle(c); } public void forceRemoveCombatant(EntityIDDimPair e) { sideA.remove(e.id); sideB.remove(e.id); if (players.remove(e.id) != null) { playerCount.decrementAndGet(); } for (Iterator iter = sideAEntryQueue.iterator(); iter.hasNext(); ) { Combatant c = iter.next(); if (c.entity.getId() == e.id) { iter.remove(); break; } } for (Iterator iter = sideBEntryQueue.iterator(); iter.hasNext(); ) { Combatant c = iter.next(); if (c.entity.getId() == e.id) { iter.remove(); break; } } } private void setDecisionState() { for (Combatant c : sideA.values()) { c.decision = Decision.UNDECIDED; } for (Combatant c : sideB.values()) { c.decision = Decision.UNDECIDED; } state = State.DECISION; undecidedCount.set(players.size()); } /** * @return True if battle has ended */ public boolean update() { if (!isServer) { return false; } else if (battleEnded) { Collection combatants = new ArrayList(); combatants.addAll(sideA.values()); combatants.addAll(sideB.values()); for (Combatant c : combatants) { removeCombatant(c); } return true; } long nextInstant = System.nanoTime(); long dt = nextInstant - lastInstant; lastInstant = nextInstant; try { return update(dt); } catch (Throwable t) { TurnBasedMinecraftMod.logger.error("Update: ", t); setDecisionState(); boolean changed = false; if (healthCheck()) { changed = true; } if (isCreativeCheck()) { changed = true; } sendMessageToAllPlayers(PacketBattleMessage.MessageType.TURN_END, 0, 0, 1); if (changed) { notifyPlayersBattleInfo(); } return battleEnded; } } private boolean update(final long dt) { pingTimerNanos += dt; if (pingTimerNanos >= 4000000000L) { pingTimerNanos = 0; notifyPlayersBattlePing(); } if (battleEnded) { Collection combatants = new ArrayList(); combatants.addAll(sideA.values()); combatants.addAll(sideB.values()); for (Combatant c : combatants) { removeCombatant(c); } return true; } boolean combatantsChanged = false; for (Combatant c = sideAEntryQueue.poll(); c != null; c = sideAEntryQueue.poll()) { sideA.put(c.entity.getId(), c); combatantsChanged = true; } for (Combatant c = sideBEntryQueue.poll(); c != null; c = sideBEntryQueue.poll()) { sideB.put(c.entity.getId(), c); combatantsChanged = true; } if (TurnBasedMinecraftMod.proxy.getConfig().isFreezeCombatantsEnabled()) { enforceFreezePositions(); } defuseCreepers(); switch (state) { case DECISION: timer -= dt; if ((!timerForever && timer <= 0) || undecidedCount.get() <= 0) { for (Combatant c : sideA.values()) { // picking decision for sideA non-players if (!(c.entity instanceof Player) && c.decision == Decision.UNDECIDED && c.entityInfo != null) { if (c.entity instanceof Creeper) { if (c.creeperTurns++ < TurnBasedMinecraftMod.proxy.getConfig().getCreeperExplodeTurn()) { c.decision = Decision.CREEPER_WAIT; } else { c.decision = Decision.CREEPER_EXPLODE; } continue; } int percentage = random.nextInt(100); if (percentage < c.entityInfo.decisionAttack) { c.decision = Decision.ATTACK; } else if (percentage - c.entityInfo.decisionAttack < c.entityInfo.decisionDefend) { c.decision = Decision.DEFEND; } else if (percentage - c.entityInfo.decisionAttack - c.entityInfo.decisionDefend < c.entityInfo.decisionFlee) { c.decision = Decision.FLEE; } } } for (Combatant c : sideB.values()) { if (!(c.entity instanceof Player) && c.decision == Decision.UNDECIDED && c.entityInfo != null) { if (c.entity instanceof Creeper) { if (c.creeperTurns++ < TurnBasedMinecraftMod.proxy.getConfig().getCreeperExplodeTurn()) { c.decision = Decision.CREEPER_WAIT; } else { c.decision = Decision.CREEPER_EXPLODE; } continue; } int percentage = random.nextInt(100); if (percentage < c.entityInfo.decisionAttack) { c.decision = Decision.ATTACK; } else if (percentage - c.entityInfo.decisionAttack < c.entityInfo.decisionDefend) { c.decision = Decision.DEFEND; } else if (percentage - c.entityInfo.decisionAttack - c.entityInfo.decisionDefend < c.entityInfo.decisionFlee) { c.decision = Decision.FLEE; } } } state = State.ACTION; timer = TurnBasedMinecraftMod.proxy.getConfig().getDecisionDurationNanos(); timerForever = TurnBasedMinecraftMod.proxy.getConfig().isBattleDecisionDurationForever(); sendMessageToAllPlayers(PacketBattleMessage.MessageType.TURN_BEGIN, 0, 0, 0); turnOrderQueue.clear(); for (Combatant c : sideA.values()) { turnOrderQueue.add(c); } for (Combatant c : sideB.values()) { turnOrderQueue.add(c); } return update(0); } else { if (healthCheck()) { combatantsChanged = true; } if (isCreativeCheck()) { combatantsChanged = true; } } break; case ACTION: { do { // depend on BattleUpdater's tick limit as rate-of-update for doing Battle decisions Combatant next = turnOrderQueue.poll(); if (next == null || !next.entity.isAlive()) { break; } debugLog = next.entity.getDisplayName().getString(); next.remainingDefenses = 0; Decision decision = next.decision; next.decision = Decision.UNDECIDED; switch (decision) { case UNDECIDED: debugLog += " undecided"; sendMessageToAllPlayers(PacketBattleMessage.MessageType.DID_NOTHING, next.entity.getId(), 0, 0); break; case ATTACK: debugLog += " attack"; Combatant target = null; if (next.entity instanceof Player) { debugLog += " as player"; target = sideA.get(next.targetEntityID); if (target == null) { target = sideB.get(next.targetEntityID); } if (target == null || !target.entity.isAlive() || target == next) { continue; } ItemStack heldItemStack = ((Player) next.entity).getMainHandItem(); if (heldItemStack.getItem() instanceof BowItem) { debugLog += " with bow"; if (Utility.doesPlayerHaveArrows((Player) next.entity)) { final Entity nextEntity = next.entity; final Entity targetEntity = target.entity; final float yawDirection = Utility.yawDirection(next.entity.getX(), next.entity.getZ(), target.entity.getX(), target.entity.getZ()); final float pitchDirection = Utility.pitchDirection(next.entity.getX(), next.entity.getY(), next.entity.getZ(), target.entity.getX(), target.entity.getY(), target.entity.getZ()); final int randomTimeLeft = random.nextInt(heldItemStack.getUseDuration((LivingEntity)next.entity) / 3); if (TurnBasedMinecraftMod.proxy.getConfig().isFreezeCombatantsEnabled()) { next.yaw = yawDirection; next.pitch = pitchDirection; } // have player look at attack target ((ServerPlayer) nextEntity).connection.teleport(nextEntity.getX(), nextEntity.getY(), nextEntity.getZ(), yawDirection, pitchDirection); BowItem itemBow = (BowItem) heldItemStack.getItem(); TurnBasedMinecraftMod.proxy.getAttackerViaBowSet().add(new AttackerViaBow(nextEntity, getId())); itemBow.releaseUsing(((Player) nextEntity).getMainHandItem(), nextEntity.level(), (LivingEntity) nextEntity, randomTimeLeft); sendMessageToAllPlayers(PacketBattleMessage.MessageType.FIRED_ARROW, nextEntity.getId(), targetEntity.getId(), 0); } else { sendMessageToAllPlayers(PacketBattleMessage.MessageType.BOW_NO_AMMO, next.entity.getId(), 0, 0); } continue; } else if (heldItemStack.getItem() instanceof CrossbowItem) { debugLog += " with crossbow"; if (Utility.doesPlayerHaveArrows((Player)next.entity)) { // Similar to attack with bow. final Entity nextEntity = next.entity; final Entity targetEntity = target.entity; final float yawDirection = Utility.yawDirection(next.entity.getX(), next.entity.getZ(), target.entity.getX(), target.entity.getZ()); final float pitchDirection = Utility.pitchDirection(next.entity.getX(), next.entity.getY(), next.entity.getZ(), target.entity.getX(), target.entity.getY(), target.entity.getZ()); if (TurnBasedMinecraftMod.proxy.getConfig().isFreezeCombatantsEnabled()) { next.yaw = yawDirection; next.pitch = pitchDirection; } // have player look at attack target ((ServerPlayer) nextEntity).connection.teleport(nextEntity.getX(), nextEntity.getY(), nextEntity.getZ(), yawDirection, pitchDirection); CrossbowItem itemCrossbow = (CrossbowItem) heldItemStack.getItem(); TurnBasedMinecraftMod.proxy.getAttackerViaBowSet().add(new AttackerViaBow(nextEntity, getId())); itemCrossbow.releaseUsing(((Player) nextEntity).getMainHandItem(), nextEntity.level(), (LivingEntity) nextEntity, -100); itemCrossbow.use(nextEntity.level(), (Player)nextEntity, InteractionHand.MAIN_HAND); sendMessageToAllPlayers(PacketBattleMessage.MessageType.FIRED_ARROW, nextEntity.getId(), targetEntity.getId(), 0); } else { sendMessageToAllPlayers(PacketBattleMessage.MessageType.CROSSBOW_NO_AMMO, next.entity.getId(), 0, 0); } continue; } debugLog += " without bow"; int hitChance = TurnBasedMinecraftMod.proxy.getConfig().getPlayerAttackProbability(); if (target.entity instanceof Player) { hitChance = hitChance * (100 - TurnBasedMinecraftMod.proxy.getConfig().getPlayerEvasion()) / 100; } else { hitChance = hitChance * (100 - target.entityInfo.evasion) / 100; } if (hitChance < TurnBasedMinecraftMod.proxy.getConfig().getMinimumHitPercentage()) { hitChance = TurnBasedMinecraftMod.proxy.getConfig().getMinimumHitPercentage(); } if (random.nextInt(100) < hitChance) { if (target.remainingDefenses <= 0) { debugLog += " hit success"; // attack final Entity nextEntity = next.entity; final Entity targetEntity = target.entity; final EntityInfo targetEntityInfo = target.entityInfo; final float yawDirection = Utility.yawDirection(next.entity.getX(), next.entity.getZ(), target.entity.getX(), target.entity.getZ()); final float pitchDirection = Utility.pitchDirection(next.entity.getX(), next.entity.getY(), next.entity.getZ(), target.entity.getX(), target.entity.getY(), target.entity.getZ()); final boolean defenseDamageTriggered; if (!(targetEntity instanceof Player) && targetEntityInfo.defenseDamage > 0 && targetEntityInfo.defenseDamageProbability > 0) { if (random.nextInt(100) < targetEntityInfo.defenseDamageProbability) { defenseDamageTriggered = true; } else { defenseDamageTriggered = false; } } else { defenseDamageTriggered = false; } if (TurnBasedMinecraftMod.proxy.getConfig().isFreezeCombatantsEnabled()) { next.yaw = yawDirection; next.pitch = pitchDirection; } // have player look at attack target ((ServerPlayer) nextEntity).connection.teleport(nextEntity.getX(), nextEntity.getY(), nextEntity.getZ(), yawDirection, pitchDirection); TurnBasedMinecraftMod.proxy.setAttackingEntity(nextEntity); TurnBasedMinecraftMod.proxy.setAttackingDamage(0); ((Player) nextEntity).attack(targetEntity); TurnBasedMinecraftMod.proxy.setAttackingEntity(null); sendMessageToAllPlayers(PacketBattleMessage.MessageType.ATTACK, nextEntity.getId(), targetEntity.getId(), TurnBasedMinecraftMod.proxy.getAttackingDamage()); if (defenseDamageTriggered) { // defense damage DamageSource defenseDamageSource = targetEntity.damageSources().mobAttack((LivingEntity) targetEntity); TurnBasedMinecraftMod.proxy.setAttackingEntity(targetEntity); nextEntity.invulnerableTime = 0; nextEntity.hurt(defenseDamageSource, targetEntityInfo.defenseDamage); TurnBasedMinecraftMod.proxy.setAttackingEntity(null); sendMessageToAllPlayers(PacketBattleMessage.MessageType.DEFENSE_DAMAGE, targetEntity.getId(), nextEntity.getId(), targetEntityInfo.defenseDamage); } } else { debugLog += " hit blocked"; // blocked --target.remainingDefenses; sendMessageToAllPlayers(PacketBattleMessage.MessageType.DEFEND, target.entity.getId(), next.entity.getId(), 0); } } else { debugLog += " hit missed"; // miss sendMessageToAllPlayers(PacketBattleMessage.MessageType.MISS, next.entity.getId(), target.entity.getId(), 0); } } else { debugLog += " as mob"; LivingEntity attackTarget = ((Mob) next.entity).getTarget(); if (attackTarget != null && hasCombatant(attackTarget.getId())) { debugLog += " to targeted"; target = getCombatantByID(attackTarget.getId()); } else { debugLog += " to random other side"; if (next.isSideA) { if (sideB.size() > 0) { int randomTargetIndex = random.nextInt(sideB.size()); for (Combatant c : sideB.values()) { if (randomTargetIndex-- == 0) { target = c; break; } } } } else { if (sideA.size() > 0) { int randomTargetIndex = random.nextInt(sideA.size()); for (Combatant c : sideA.values()) { if (randomTargetIndex-- == 0) { target = c; break; } } } } } if (target == null || !target.entity.isAlive() || target == next) { continue; } int hitChance = next.entityInfo.attackProbability; if (target.entity instanceof Player) { hitChance = hitChance * (100 - TurnBasedMinecraftMod.proxy.getConfig().getPlayerEvasion()) / 100; } else { hitChance = hitChance * (100 - target.entityInfo.evasion) / 100; } if (hitChance < TurnBasedMinecraftMod.proxy.getConfig().getMinimumHitPercentage()) { hitChance = TurnBasedMinecraftMod.proxy.getConfig().getMinimumHitPercentage(); } if (random.nextInt(100) < hitChance) { if (target.remainingDefenses <= 0) { debugLog += " hit success"; DamageSource damageSource = next.entity.damageSources().mobAttack((LivingEntity) next.entity); int damageAmount = next.entityInfo.attackPower; if (next.entityInfo.attackVariance > 0) { damageAmount += random.nextInt(next.entityInfo.attackVariance * 2 + 1) - next.entityInfo.attackVariance; } if (damageAmount < 0) { damageAmount = 0; } // attack final Entity nextEntity = next.entity; final EntityInfo nextEntityInfo = next.entityInfo; final Entity targetEntity = target.entity; final EntityInfo targetEntityInfo = target.entityInfo; final int finalDamageAmount = damageAmount; final boolean defenseDamageTriggered; final boolean attackEffectTriggered; if (!(targetEntity instanceof Player) && targetEntityInfo.defenseDamage > 0 && targetEntityInfo.defenseDamageProbability > 0) { if (random.nextInt(100) < targetEntityInfo.defenseDamageProbability) { defenseDamageTriggered = true; } else { defenseDamageTriggered = false; } } else { defenseDamageTriggered = false; } if (nextEntityInfo.attackEffect != EntityInfo.Effect.UNKNOWN && nextEntityInfo.attackEffectProbability > 0) { if (random.nextInt(100) < nextEntityInfo.attackEffectProbability) { attackEffectTriggered = true; } else { attackEffectTriggered = false; } } else { attackEffectTriggered = false; } TurnBasedMinecraftMod.proxy.setAttackingEntity(nextEntity); targetEntity.invulnerableTime = 0; targetEntity.hurt(damageSource, finalDamageAmount); TurnBasedMinecraftMod.proxy.setAttackingEntity(null); sendMessageToAllPlayers(PacketBattleMessage.MessageType.ATTACK, nextEntity.getId(), targetEntity.getId(), finalDamageAmount); if (defenseDamageTriggered) { // defense damage DamageSource defenseDamageSource = targetEntity.damageSources().mobAttack((LivingEntity) targetEntity); TurnBasedMinecraftMod.proxy.setAttackingEntity(targetEntity); nextEntity.invulnerableTime = 0; nextEntity.hurt(defenseDamageSource, targetEntityInfo.defenseDamage); TurnBasedMinecraftMod.proxy.setAttackingEntity(null); sendMessageToAllPlayers(PacketBattleMessage.MessageType.DEFENSE_DAMAGE, targetEntity.getId(), nextEntity.getId(), targetEntityInfo.defenseDamage); } // attack effect if (attackEffectTriggered) { nextEntityInfo.attackEffect.applyEffectToEntity((LivingEntity) targetEntity); sendMessageToAllPlayers(PacketBattleMessage.MessageType.WAS_AFFECTED, nextEntity.getId(), targetEntity.getId(), 0, nextEntityInfo.attackEffect.getAffectedString()); } } else { debugLog += " hit blocked"; // blocked --target.remainingDefenses; sendMessageToAllPlayers(PacketBattleMessage.MessageType.DEFEND, target.entity.getId(), next.entity.getId(), 0); } } else { debugLog += " hit missed"; // miss sendMessageToAllPlayers(PacketBattleMessage.MessageType.MISS, next.entity.getId(), target.entity.getId(), 0); } } break; case DEFEND: debugLog += " defend"; next.remainingDefenses = TurnBasedMinecraftMod.proxy.getConfig().getDefenseDuration(); sendMessageToAllPlayers(PacketBattleMessage.MessageType.DEFENDING, next.entity.getId(), 0, 0); break; case FLEE: debugLog += " flee"; int fastestEnemySpeed = 0; if (next.isSideA) { for (Combatant c : sideB.values()) { if (c.entity instanceof Player) { int playerSpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerSpeed(); if (((Player) c.entity).hasEffect(MobEffects.MOVEMENT_SPEED)) { playerSpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerHasteSpeed(); } else if (((Player) c.entity).hasEffect(MobEffects.MOVEMENT_SLOWDOWN)) { playerSpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerSlowSpeed(); } if (playerSpeed > fastestEnemySpeed) { fastestEnemySpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerSpeed(); } } else { if (c.entityInfo.speed > fastestEnemySpeed) { fastestEnemySpeed = c.entityInfo.speed; } } } } else { for (Combatant c : sideA.values()) { if (c.entity instanceof Player) { int playerSpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerSpeed(); if (((Player) c.entity).hasEffect(MobEffects.MOVEMENT_SPEED)) { playerSpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerHasteSpeed(); } else if (((Player) c.entity).hasEffect(MobEffects.MOVEMENT_SLOWDOWN)) { playerSpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerSlowSpeed(); } if (playerSpeed > fastestEnemySpeed) { fastestEnemySpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerSpeed(); } } else { if (c.entityInfo.speed > fastestEnemySpeed) { fastestEnemySpeed = c.entityInfo.speed; } } } } int fleeProbability = 0; if (next.entity instanceof Player) { int playerSpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerSpeed(); if (((Player) next.entity).hasEffect(MobEffects.MOVEMENT_SPEED)) { playerSpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerHasteSpeed(); } else if (((Player) next.entity).hasEffect(MobEffects.MOVEMENT_SLOWDOWN)) { playerSpeed = TurnBasedMinecraftMod.proxy.getConfig().getPlayerSlowSpeed(); } if (fastestEnemySpeed >= playerSpeed) { fleeProbability = TurnBasedMinecraftMod.proxy.getConfig().getFleeBadProbability(); } else { fleeProbability = TurnBasedMinecraftMod.proxy.getConfig().getFleeGoodProbability(); } } else { if (fastestEnemySpeed >= next.entityInfo.speed) { fleeProbability = TurnBasedMinecraftMod.proxy.getConfig().getFleeBadProbability(); } else { fleeProbability = TurnBasedMinecraftMod.proxy.getConfig().getFleeGoodProbability(); } } if (random.nextInt(100) < fleeProbability) { debugLog += " success"; // flee success combatantsChanged = true; String fleeingCategory = new String(); if (next.entityInfo != null) { fleeingCategory = next.entityInfo.category; } else if (next.entity instanceof Player) { fleeingCategory = "player"; } removeCombatant(next); sendMessageToAllPlayers(PacketBattleMessage.MessageType.FLEE, next.entity.getId(), 0, 1, fleeingCategory); } else { debugLog += " fail"; // flee fail sendMessageToAllPlayers(PacketBattleMessage.MessageType.FLEE, next.entity.getId(), 0, 0); } break; case USE_ITEM: debugLog += " use item"; if (next.itemToUse < 0 || next.itemToUse > 8) { debugLog += " invalid"; sendMessageToAllPlayers(PacketBattleMessage.MessageType.USED_ITEM, next.entity.getId(), 0, PacketBattleMessage.UsedItemAction.USED_INVALID.getValue()); break; } ItemStack targetItemStack = ((Player) next.entity).getInventory().getItem(next.itemToUse); Item targetItem = targetItemStack.getItem(); if (targetItem == null) { debugLog += " null"; sendMessageToAllPlayers(PacketBattleMessage.MessageType.USED_ITEM, next.entity.getId(), 0, PacketBattleMessage.UsedItemAction.USED_NOTHING.getValue()); break; } else if (Utility.isItemEdible(targetItemStack)) { debugLog += " food"; sendMessageToAllPlayers(PacketBattleMessage.MessageType.USED_ITEM, next.entity.getId(), 0, PacketBattleMessage.UsedItemAction.USED_FOOD.getValue(), targetItemStack.getDisplayName().getString()); final Entity nextEntity = next.entity; final int nextItemToUse = next.itemToUse; ((Player) nextEntity).getInventory().setItem(nextItemToUse, targetItem.finishUsingItem(targetItemStack, nextEntity.level(), (LivingEntity) nextEntity)); } else { // then check vanilla foods final CreativeModeTab foodAndDrinksTab = CreativeModeTabRegistry.getTab(CreativeModeTabs.FOOD_AND_DRINKS.location()); if (foodAndDrinksTab.contains(targetItemStack) && Utility.isItemEdible(targetItemStack)) { debugLog += " food"; sendMessageToAllPlayers(PacketBattleMessage.MessageType.USED_ITEM, next.entity.getId(), 0, PacketBattleMessage.UsedItemAction.USED_FOOD.getValue(), targetItemStack.getDisplayName().getString()); final Entity nextEntity = next.entity; final int nextItemToUse = next.itemToUse; ((Player) nextEntity).getInventory().setItem(nextItemToUse, targetItem.finishUsingItem(targetItemStack, nextEntity.level(), (LivingEntity) nextEntity)); } else if (targetItem instanceof PotionItem && !(targetItem instanceof ThrowablePotionItem)) { debugLog += " potion"; sendMessageToAllPlayers(PacketBattleMessage.MessageType.USED_ITEM, next.entity.getId(), 0, PacketBattleMessage.UsedItemAction.USED_POTION.getValue(), targetItemStack.getDisplayName().getString()); final Entity nextEntity = next.entity; final int nextItemToUse = next.itemToUse; ((Player) nextEntity).getInventory().setItem(nextItemToUse, targetItem.finishUsingItem(targetItemStack, nextEntity.level(), (LivingEntity) nextEntity)); } else { debugLog += " non-consumable"; sendMessageToAllPlayers(PacketBattleMessage.MessageType.USED_ITEM, next.entity.getId(), 0, PacketBattleMessage.UsedItemAction.USED_INVALID.getValue(), targetItemStack.getDisplayName().getString()); final Entity nextEntity = next.entity; final int nextItemToUse = next.itemToUse; final int prevItem = ((Player)nextEntity).getInventory().selected; ((Player)nextEntity).getInventory().selected = nextItemToUse; ((Player)nextEntity).getInventory().setItem(nextItemToUse, targetItem.use(nextEntity.level(), (Player)nextEntity, InteractionHand.MAIN_HAND).getObject()); ((Player)nextEntity).getInventory().selected = prevItem; } } break; case SWITCH_ITEM: { debugLog += " switch item"; if (next.itemToUse < 0 || next.itemToUse > 8) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.SWITCHED_ITEM, next.entity.getId(), 0, 0); break; } final Entity nextEntity = next.entity; final int nextItemToUse = next.itemToUse; ((Player) nextEntity).getInventory().selected = nextItemToUse; sendMessageToAllPlayers(PacketBattleMessage.MessageType.SWITCHED_ITEM, next.entity.getId(), 0, 1); } break; case CREEPER_WAIT: debugLog += " creeper wait"; if (next.creeperTurns < TurnBasedMinecraftMod.proxy.getConfig().getCreeperExplodeTurn()) { sendMessageToAllPlayers(PacketBattleMessage.MessageType.CREEPER_WAIT, next.entity.getId(), 0, 0); } else { sendMessageToAllPlayers(PacketBattleMessage.MessageType.CREEPER_WAIT_FINAL, next.entity.getId(), 0, 0); } break; case CREEPER_EXPLODE: { debugLog += " creeper explode"; sendMessageToAllPlayers(PacketBattleMessage.MessageType.CREEPER_EXPLODE, next.entity.getId(), 0, 0); final Entity nextEntity = next.entity; final EntityInfo nextEntityInfo = next.entityInfo; for (Combatant c : sideA.values()) { if (c.entity.getId() != next.entity.getId()) { int hitChance = next.entityInfo.attackProbability; if (c.entity instanceof Player) { hitChance = hitChance * (100 - TurnBasedMinecraftMod.proxy.getConfig().getPlayerEvasion()) / 100; } else { hitChance = hitChance * (100 - c.entityInfo.evasion) / 100; } if (hitChance < TurnBasedMinecraftMod.proxy.getConfig().getMinimumHitPercentage()) { hitChance = TurnBasedMinecraftMod.proxy.getConfig().getMinimumHitPercentage(); } if (random.nextInt(100) < hitChance) { final Entity targetEntity = c.entity; final EntityInfo targetEntityInfo = c.entityInfo; int damageAmount = nextEntityInfo.attackPower; if (nextEntityInfo.attackVariance > 0) { damageAmount += random.nextInt(nextEntityInfo.attackVariance * 2 + 1) - nextEntityInfo.attackVariance; } if (damageAmount < 0) { damageAmount = 0; } final int finalDamageAmount = damageAmount; final boolean attackEffectTriggered; if (nextEntityInfo.attackEffect != EntityInfo.Effect.UNKNOWN && nextEntityInfo.attackEffectProbability > 0) { if (random.nextInt(100) < nextEntityInfo.attackEffectProbability) { attackEffectTriggered = true; } else { attackEffectTriggered = false; } } else { attackEffectTriggered = false; } TurnBasedMinecraftMod.proxy.setAttackingEntity(nextEntity); targetEntity.invulnerableTime = 0; targetEntity.hurt(nextEntity.damageSources().mobAttack((LivingEntity) nextEntity), finalDamageAmount); TurnBasedMinecraftMod.proxy.setAttackingEntity(null); sendMessageToAllPlayers(PacketBattleMessage.MessageType.ATTACK, nextEntity.getId(), targetEntity.getId(), finalDamageAmount); if (attackEffectTriggered) { nextEntityInfo.attackEffect.applyEffectToEntity((LivingEntity) targetEntity); sendMessageToAllPlayers(PacketBattleMessage.MessageType.WAS_AFFECTED, nextEntity.getId(), targetEntity.getId(), 0, nextEntityInfo.attackEffect.getAffectedString()); } } } } for (Combatant c : sideB.values()) { if (c.entity.getId() != next.entity.getId()) { int hitChance = next.entityInfo.attackProbability; if (c.entity instanceof Player) { hitChance = hitChance * (100 - TurnBasedMinecraftMod.proxy.getConfig().getPlayerEvasion()) / 100; } else { hitChance = hitChance * (100 - c.entityInfo.evasion) / 100; } if (hitChance < TurnBasedMinecraftMod.proxy.getConfig().getMinimumHitPercentage()) { hitChance = TurnBasedMinecraftMod.proxy.getConfig().getMinimumHitPercentage(); } if (random.nextInt(100) < hitChance) { final Entity targetEntity = c.entity; final EntityInfo targetEntityInfo = c.entityInfo; int damageAmount = nextEntityInfo.attackPower; if (nextEntityInfo.attackVariance > 0) { damageAmount += random.nextInt(nextEntityInfo.attackVariance * 2 + 1) - nextEntityInfo.attackVariance; } if (damageAmount < 0) { damageAmount = 0; } final int finalDamageAmount = damageAmount; final boolean attackEffectTriggered; if (nextEntityInfo.attackEffect != EntityInfo.Effect.UNKNOWN && nextEntityInfo.attackEffectProbability > 0) { if (random.nextInt(100) < nextEntityInfo.attackEffectProbability) { attackEffectTriggered = true; } else { attackEffectTriggered = false; } } else { attackEffectTriggered = false; } TurnBasedMinecraftMod.proxy.setAttackingEntity(nextEntity); targetEntity.invulnerableTime = 0; targetEntity.hurt(nextEntity.damageSources().mobAttack((LivingEntity) nextEntity), finalDamageAmount); TurnBasedMinecraftMod.proxy.setAttackingEntity(null); sendMessageToAllPlayers(PacketBattleMessage.MessageType.ATTACK, nextEntity.getId(), targetEntity.getId(), finalDamageAmount); if (attackEffectTriggered) { nextEntityInfo.attackEffect.applyEffectToEntity((LivingEntity) targetEntity); sendMessageToAllPlayers(PacketBattleMessage.MessageType.WAS_AFFECTED, nextEntity.getId(), targetEntity.getId(), 0, nextEntityInfo.attackEffect.getAffectedString()); } } } } ((Creeper) nextEntity).setSwellDir(1000000); } break; } } while (false); debugLog = "Action almost end"; if (turnOrderQueue.isEmpty()) { setDecisionState(); if (healthCheck()) { combatantsChanged = true; } if (isCreativeCheck()) { combatantsChanged = true; } debugLog += ", adding task"; sendMessageToAllPlayers(PacketBattleMessage.MessageType.TURN_END, 0, 0, 0); } debugLog = "Actions end"; break; } // case ACTION default: state = State.DECISION; break; } // switch(state) debugLog = "Update almost end"; if (combatantsChanged) { notifyPlayersBattleInfo(); } if (battleEnded) { Collection combatants = new ArrayList(); combatants.addAll(sideA.values()); combatants.addAll(sideB.values()); for (Combatant c : combatants) { removeCombatant(c); } } debugLog = "Update end"; return battleEnded; } // update(final long dt) private void defuseCreepers() { for (Combatant c : sideA.values()) { if (c.entity instanceof Creeper) { if (c.creeperTurns <= TurnBasedMinecraftMod.proxy.getConfig().getCreeperExplodeTurn()) { ((Creeper) c.entity).setSwellDir(-10); } else { ((Creeper) c.entity).setSwellDir(1000000); } } } for (Combatant c : sideB.values()) { if (c.entity instanceof Creeper) { if (c.creeperTurns <= TurnBasedMinecraftMod.proxy.getConfig().getCreeperExplodeTurn()) { ((Creeper) c.entity).setSwellDir(-10); } else { ((Creeper) c.entity).setSwellDir(1000000); } } } } }