package com.example.factionsrpg.npc; import com.cryptomorin.xseries.XAttribute; import com.example.factionsrpg.FactionsRPG; import com.example.factionsrpg.npc.behavior.AttackerBehavior; import com.example.factionsrpg.npc.behavior.DefenderBehavior; import com.example.factionsrpg.npc.behavior.PatrolBehavior; import org.bukkit.Bukkit; import org.bukkit.Location; import org.bukkit.World; import org.bukkit.entity.EntityType; import org.bukkit.entity.IronGolem; import org.bukkit.entity.LivingEntity; import org.bukkit.scheduler.BukkitTask; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; public class NPCArmyManager { private final FactionsRPG plugin; private final List activeNPCs; private final Map behaviorMap; private BukkitTask behaviorTask; private int updateIndex; public NPCArmyManager(FactionsRPG plugin) { this.plugin = plugin; this.activeNPCs = new ArrayList<>(); this.behaviorMap = new HashMap<>(); this.updateIndex = 0; } public void spawnDefenseNPCs() { int maxNPCs = plugin.getConfigManager().getMaxActiveNPCs(); Location spawnLoc = plugin.getLocationManager().getSpawnLocation(); if (spawnLoc == null || spawnLoc.getWorld() == null) { plugin.getLogger().warning("Cannot spawn defense NPCs - invalid spawn location!"); return; } int defendersToSpawn = maxNPCs / 2; int attackersToSpawn = maxNPCs / 3; int patrolsToSpawn = maxNPCs - defendersToSpawn - attackersToSpawn; for (int i = 0; i < defendersToSpawn; i++) { spawnNPC(spawnLoc, NPCRole.DEFENDER); } for (int i = 0; i < attackersToSpawn; i++) { Location targetLoc = plugin.getLocationManager().getRandomTargetLocation(); if (targetLoc != null) { spawnNPC(spawnLoc, NPCRole.ATTACKER); } } for (int i = 0; i < patrolsToSpawn; i++) { spawnNPC(spawnLoc, NPCRole.PATROL); } startBehaviorTask(); Bukkit.broadcastMessage("§a§l[NPC ARMY]"); Bukkit.broadcastMessage("§e" + activeNPCs.size() + " defenders have joined the battle!"); } private void spawnNPC(Location location, NPCRole role) { if (activeNPCs.size() >= plugin.getConfigManager().getMaxActiveNPCs()) { return; } World world = location.getWorld(); Location spawnLoc = location.clone().add( (Math.random() - 0.5) * 10, 0, (Math.random() - 0.5) * 10 ); LivingEntity entity = (LivingEntity) world.spawnEntity(spawnLoc, EntityType.IRON_GOLEM); if (entity instanceof IronGolem) { IronGolem golem = (IronGolem) entity; golem.setPlayerCreated(true); golem.setCustomName("§a" + role.name() + " NPC"); golem.setCustomNameVisible(true); } XAttribute.of("max_health").ifPresent(attr -> { double health = plugin.getConfigManager().getNPCHealth(); entity.getAttribute(attr.get()).setBaseValue(health); entity.setHealth(health); }); NPCEntity npc = new NPCEntity(entity, role); activeNPCs.add(npc); Object behavior = createBehavior(role, location); behaviorMap.put(npc, behavior); } private Object createBehavior(NPCRole role, Location location) { switch (role) { case DEFENDER: return new DefenderBehavior(location, 30.0); case ATTACKER: Location target = plugin.getLocationManager().getRandomTargetLocation(); return new AttackerBehavior(target != null ? target : location); case PATROL: return new PatrolBehavior(location, 40.0); default: return new DefenderBehavior(location, 30.0); } } private void startBehaviorTask() { if (behaviorTask != null) { behaviorTask.cancel(); } behaviorTask = Bukkit.getScheduler().runTaskTimer(plugin, this::updateBehaviorsStaggered, 20L, 20L); } private void updateBehaviorsStaggered() { if (activeNPCs.isEmpty()) { return; } int npcsPerTick = Math.max(1, activeNPCs.size() / 4); List toRemove = new ArrayList<>(); for (int i = 0; i < npcsPerTick; i++) { if (updateIndex >= activeNPCs.size()) { updateIndex = 0; break; } NPCEntity npc = activeNPCs.get(updateIndex); updateIndex++; if (!npc.isValid()) { toRemove.add(npc); continue; } Object behavior = behaviorMap.get(npc); if (behavior == null) { continue; } try { switch (npc.getRole()) { case DEFENDER: ((DefenderBehavior) behavior).execute(npc); break; case ATTACKER: ((AttackerBehavior) behavior).execute(npc); break; case PATROL: ((PatrolBehavior) behavior).execute(npc); break; } } catch (Exception e) { if (plugin.getConfigManager().isDebug()) { plugin.getLogger().warning("Error updating NPC behavior: " + e.getMessage()); } } } for (NPCEntity npc : toRemove) { activeNPCs.remove(npc); behaviorMap.remove(npc); } } public void cleanup() { if (behaviorTask != null) { behaviorTask.cancel(); behaviorTask = null; } for (NPCEntity npc : new ArrayList<>(activeNPCs)) { npc.remove(); } activeNPCs.clear(); behaviorMap.clear(); updateIndex = 0; } public int getActiveNPCCount() { return activeNPCs.size(); } }