package dev.afonso.galleryac.check.combat; import dev.afonso.galleryac.GalleryAC; import dev.afonso.galleryac.config.SettingsManager; import net.citizensnpcs.api.CitizensAPI; import net.citizensnpcs.api.event.CitizensEnableEvent; import net.citizensnpcs.api.npc.NPC; import net.citizensnpcs.api.npc.NPCRegistry; import net.citizensnpcs.api.trait.Trait; import org.bukkit.Bukkit; import org.bukkit.Location; import org.bukkit.Material; import org.bukkit.entity.Entity; import org.bukkit.entity.Player; import org.bukkit.event.*; import org.bukkit.event.entity.EntityDamageByEntityEvent; import org.bukkit.event.player.PlayerKickEvent; import org.bukkit.event.player.PlayerQuitEvent; import java.lang.reflect.Method; import java.util.*; public class TriggerBotA implements Listener { private final GalleryAC plugin; private final SettingsManager settings; private long serverTick = 0L; private final Map hitCount = new HashMap<>(128); private final Map lastHitTime = new HashMap<>(128); private final Map nextThreshold = new HashMap<>(128); private final Map lastAttackTick = new HashMap<>(128); private final Set pendingTrigger = new HashSet<>(128); private final Map pendingStopTicksRequired = new HashMap<>(128); private final Map cooldownReadyStreak = new HashMap<>(128); private final Map npcHome = new HashMap<>(); private final Set npcInUse = new HashSet<>(); private final Map attackerToActiveNpcId = new HashMap<>(); private int npcIndex = 0; private final Random rng = new Random(); public TriggerBotA(GalleryAC plugin) { this.plugin = plugin; this.settings = plugin.getSettingsManager(); Bukkit.getPluginManager().registerEvents(this, plugin); Bukkit.getScheduler().runTaskTimer(plugin, () -> serverTick++, 1L, 1L); startPendingMonitor(); } private boolean isCooldownReady(Player p) { if (!settings.isTriggerBotRequireAttackCooldown()) return true; return p.getAttackCooldown() >= settings.getTriggerBotMinAttackCooldown(); } @EventHandler public void onCitizensLoad(CitizensEnableEvent e) { Bukkit.getScheduler().runTaskLater(plugin, this::initBots, 40L); } private void initBots() { NPCRegistry reg = CitizensAPI.getNPCRegistry(); Map homes = settings.getTriggerBotHomeLocations(); for (int id : settings.getTriggerBotNpcIds()) { NPC npc = reg.getById(id); if (npc == null) continue; Location home = homes.getOrDefault(id, npc.getStoredLocation()); if (home == null) continue; npcHome.put(id, home.clone()); forceRespawn(npc, home); setTab(npc, false); } plugin.getLogger().info("TriggerBotA NPCs initialized."); } @EventHandler(priority = EventPriority.MONITOR, ignoreCancelled = true) public void onHit(EntityDamageByEntityEvent e) { if (!(e.getDamager() instanceof Player p)) return; if (!settings.isTriggerBotEnabled()) return; UUID id = p.getUniqueId(); lastAttackTick.put(id, serverTick); long now = System.currentTimeMillis(); if (now - lastHitTime.getOrDefault(id, 0L) > settings.getTriggerBotResetMs()) resetPlayer(id); lastHitTime.put(id, now); if (pendingTrigger.contains(id) || attackerToActiveNpcId.containsKey(id)) return; int hits = hitCount.merge(id, 1, Integer::sum); nextThreshold.putIfAbsent(id, randomThreshold()); if (hits < nextThreshold.get(id)) return; hitCount.remove(id); nextThreshold.remove(id); pendingTrigger.add(id); pendingStopTicksRequired.put(id, randomStopTicks()); cooldownReadyStreak.put(id, 0); } private boolean isHoldingRequiredItem(Player p) { Set required = settings.getTriggerBotRequiredItems(); if (required.isEmpty()) return true; return required.contains(p.getInventory().getItemInMainHand().getType()); } private void makeVisibleOnlyTo(Player attacker, Entity npcEntity) { for (Player online : Bukkit.getOnlinePlayers()) { if (online.equals(attacker)) online.showEntity(plugin, npcEntity); else online.hideEntity(plugin, npcEntity); } } private void resetVisibility(Entity npcEntity) { for (Player online : Bukkit.getOnlinePlayers()) online.showEntity(plugin, npcEntity); } private void startPendingMonitor() { Bukkit.getScheduler().runTaskTimer(plugin, () -> { Iterator it = pendingTrigger.iterator(); while (it.hasNext()) { UUID id = it.next(); Player p = Bukkit.getPlayer(id); if (p == null) { it.remove(); continue; } long since = serverTick - lastAttackTick.getOrDefault(id, -999L); int required = pendingStopTicksRequired.get(id); if (since < required) continue; if (!isHoldingRequiredItem(p)) continue; if (settings.isTriggerBotRequireAttackCooldown()) { if (isCooldownReady(p)) { cooldownReadyStreak.merge(id, 1, Integer::sum); } else { cooldownReadyStreak.put(id, 0); continue; } } it.remove(); Integer npcId = pickFreeNpcId(); if (npcId == null) continue; npcInUse.add(npcId); attackerToActiveNpcId.put(id, npcId); runBotSequence(p, npcId); } }, 1L, 1L); } private void runBotSequence(Player attacker, int npcId) { NPC npc = CitizensAPI.getNPCRegistry().getById(npcId); if (npc == null) return; forceRespawn(npc, attacker.getLocation()); Entity ent = npc.getEntity(); if (ent == null) return; makeVisibleOnlyTo(attacker, ent); attacker.addPassenger(ent); Bukkit.getScheduler().runTaskLater(plugin, () -> attacker.removePassenger(ent), settings.getTriggerBotRideTicks()); Bukkit.getScheduler().runTaskLater(plugin, () -> restoreNpc(npcId, attacker.getUniqueId()), settings.getTriggerBotRideTicks() + settings.getTriggerBotFallTicks()); } private void restoreNpc(int npcId, UUID attacker) { NPC npc = CitizensAPI.getNPCRegistry().getById(npcId); Location home = npcHome.get(npcId); if (npc != null && home != null) { forceRespawn(npc, home); setTab(npc, false); Entity ent = npc.getEntity(); if (ent != null) resetVisibility(ent); } npcInUse.remove(npcId); attackerToActiveNpcId.remove(attacker); } private void forceRespawn(NPC npc, Location loc) { try { npc.despawn(); npc.spawn(loc); } catch (Exception ignored) {} } private int randomThreshold() { int[] arr = settings.getTriggerBotHitThresholds(); return arr[rng.nextInt(arr.length)]; } private int randomStopTicks() { return rng.nextInt(settings.getTriggerBotStopMax() - settings.getTriggerBotStopMin() + 1) + settings.getTriggerBotStopMin(); } private Integer pickFreeNpcId() { List ids = settings.getTriggerBotNpcIds(); for (int i = 0; i < ids.size(); i++) { int id = ids.get(npcIndex++ % ids.size()); if (!npcInUse.contains(id)) return id; } return null; } private void setTab(NPC npc, boolean value) { try { Class traitClass = (Class) Class.forName("net.citizensnpcs.trait.PlayerListTrait"); Trait trait = npc.getOrAddTrait(traitClass); Method m = trait.getClass().getMethod("setInTabList", boolean.class); m.invoke(trait, value); } catch (Throwable ignored) {} } private void resetPlayer(UUID id) { hitCount.remove(id); nextThreshold.remove(id); pendingTrigger.remove(id); pendingStopTicksRequired.remove(id); cooldownReadyStreak.remove(id); } @EventHandler public void onQuit(PlayerQuitEvent e) { cleanup(e.getPlayer().getUniqueId()); } @EventHandler public void onKick(PlayerKickEvent e) { cleanup(e.getPlayer().getUniqueId()); } private void cleanup(UUID id) { resetPlayer(id); Integer npc = attackerToActiveNpcId.get(id); if (npc != null) restoreNpc(npc, id); } public void shutdown() { for (int id : npcHome.keySet()) { NPC npc = CitizensAPI.getNPCRegistry().getById(id); if (npc != null) forceRespawn(npc, npcHome.get(id)); } } }