package com.kodari.beaconrange; import org.bukkit.Chunk; import org.bukkit.Location; import org.bukkit.World; import org.bukkit.block.Beacon; import org.bukkit.block.BlockState; import org.bukkit.entity.Player; import org.bukkit.event.EventHandler; import org.bukkit.event.EventPriority; import org.bukkit.event.Listener; import org.bukkit.event.player.PlayerJoinEvent; import org.bukkit.event.player.PlayerMoveEvent; import org.bukkit.event.player.PlayerQuitEvent; import org.bukkit.event.world.ChunkLoadEvent; import org.bukkit.event.world.ChunkUnloadEvent; import org.bukkit.potion.PotionEffect; import org.bukkit.scheduler.BukkitRunnable; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import java.util.UUID; public class BeaconListener implements Listener { // 16 chunks = 256 blocks private static final int CUSTOM_RANGE = 512; private static final int APPLY_INTERVAL_TICKS = 60; private static final int EFFECT_DURATION_TICKS = 100; // All known beacon locations discovered so far (world UID -> set of locations) private final Map> knownBeacons = new HashMap<>(); // Chunks we have force-loaded, keyed by "world:cx:cz" private final Set forceLoadedChunks = new HashSet<>(); private final BeaconRangeExpander plugin; public BeaconListener(BeaconRangeExpander plugin) { this.plugin = plugin; startBeaconTask(); } // ------------------------------------------------------------------------- // Periodic task — apply effects and maintain force-loaded chunks // ------------------------------------------------------------------------- private void startBeaconTask() { new BukkitRunnable() { @Override public void run() { updateForceLoadedChunks(); for (Player player : plugin.getServer().getOnlinePlayers()) { applyNearbyBeacons(player); } } }.runTaskTimer(plugin, APPLY_INTERVAL_TICKS, APPLY_INTERVAL_TICKS); } /** * Force-load every chunk that contains a known beacon AND is within * CUSTOM_RANGE of at least one online player. Unload chunks that no * longer satisfy that condition. */ private void updateForceLoadedChunks() { Set needed = new HashSet<>(); for (Player player : plugin.getServer().getOnlinePlayers()) { Location pLoc = player.getLocation(); World world = pLoc.getWorld(); if (world == null) continue; UUID wid = world.getUID(); Set beacons = knownBeacons.getOrDefault(wid, Collections.emptySet()); for (Location bLoc : beacons) { if (!bLoc.getWorld().getUID().equals(wid)) continue; if (bLoc.distanceSquared(pLoc) <= (double) CUSTOM_RANGE * CUSTOM_RANGE) { int cx = bLoc.getBlockX() >> 4; int cz = bLoc.getBlockZ() >> 4; needed.add(chunkKey(world, cx, cz)); if (!world.isChunkLoaded(cx, cz)) { world.setChunkForceLoaded(cx, cz, true); } } } } // Release chunks that are no longer needed Set toRemove = new HashSet<>(forceLoadedChunks); toRemove.removeAll(needed); for (String key : toRemove) { String[] parts = key.split(":"); World world = plugin.getServer().getWorld(UUID.fromString(parts[0])); if (world != null) { int cx = Integer.parseInt(parts[1]); int cz = Integer.parseInt(parts[2]); world.setChunkForceLoaded(cx, cz, false); } } forceLoadedChunks.clear(); forceLoadedChunks.addAll(needed); } // ------------------------------------------------------------------------- // Discover beacons in chunks as they load, and scan on join // ------------------------------------------------------------------------- @EventHandler public void onChunkLoad(ChunkLoadEvent event) { scanChunkForBeacons(event.getChunk()); } @EventHandler public void onChunkUnload(ChunkUnloadEvent event) { // Remove any beacons tracked in this chunk (they'll be re-discovered on load) Chunk chunk = event.getChunk(); UUID wid = chunk.getWorld().getUID(); knownBeacons.computeIfPresent(wid, (id, set) -> { set.removeIf(loc -> (loc.getBlockX() >> 4) == chunk.getX() && (loc.getBlockZ() >> 4) == chunk.getZ()); return set; }); // Re-apply force-load flag if this chunk is still needed if (forceLoadedChunks.contains(chunkKey(chunk.getWorld(), chunk.getX(), chunk.getZ()))) { chunk.getWorld().setChunkForceLoaded(chunk.getX(), chunk.getZ(), true); } } @EventHandler public void onPlayerJoin(PlayerJoinEvent event) { new BukkitRunnable() { @Override public void run() { Player player = event.getPlayer(); if (!player.isOnline()) return; Location loc = player.getLocation(); World world = loc.getWorld(); if (world == null) return; int chunkRadius = (CUSTOM_RANGE >> 4) + 1; int cx0 = loc.getBlockX() >> 4; int cz0 = loc.getBlockZ() >> 4; for (int cx = cx0 - chunkRadius; cx <= cx0 + chunkRadius; cx++) { for (int cz = cz0 - chunkRadius; cz <= cz0 + chunkRadius; cz++) { if (world.isChunkLoaded(cx, cz)) { scanChunkForBeacons(world.getChunkAt(cx, cz)); } } } updateForceLoadedChunks(); applyNearbyBeacons(player); } }.runTaskLater(plugin, 5L); } @EventHandler public void onPlayerQuit(PlayerQuitEvent event) { new BukkitRunnable() { @Override public void run() { updateForceLoadedChunks(); } }.runTaskLater(plugin, 1L); } // ------------------------------------------------------------------------- // Player movement — apply effects immediately on block change // ------------------------------------------------------------------------- @EventHandler(priority = EventPriority.MONITOR) public void onPlayerMove(PlayerMoveEvent event) { Location from = event.getFrom(); Location to = event.getTo(); if (to == null) return; if (from.getBlockX() == to.getBlockX() && from.getBlockY() == to.getBlockY() && from.getBlockZ() == to.getBlockZ()) return; applyNearbyBeacons(event.getPlayer()); } // ------------------------------------------------------------------------- // Core helpers // ------------------------------------------------------------------------- private void scanChunkForBeacons(Chunk chunk) { for (BlockState state : chunk.getTileEntities(b -> b.getState() instanceof Beacon, false)) { if (state instanceof Beacon) { knownBeacons .computeIfAbsent(chunk.getWorld().getUID(), id -> new HashSet<>()) .add(state.getLocation()); } } } private void applyNearbyBeacons(Player player) { Location playerLoc = player.getLocation(); World world = playerLoc.getWorld(); if (world == null) return; Set beacons = knownBeacons.getOrDefault(world.getUID(), Collections.emptySet()); for (Location bLoc : new ArrayList<>(beacons)) { if (bLoc.distanceSquared(playerLoc) > (double) CUSTOM_RANGE * CUSTOM_RANGE) continue; if (!world.isChunkLoaded(bLoc.getBlockX() >> 4, bLoc.getBlockZ() >> 4)) continue; BlockState state = bLoc.getBlock().getState(); if (!(state instanceof Beacon beacon)) continue; if (beacon.getTier() == 0) continue; applyBeaconEffects(player, beacon); } } private void applyBeaconEffects(Player player, Beacon beacon) { List effects = new ArrayList<>(); PotionEffect primary = beacon.getPrimaryEffect(); PotionEffect secondary = beacon.getSecondaryEffect(); if (primary != null) effects.add(primary); if (secondary != null && !secondary.getType().equals(primary == null ? null : primary.getType())) { effects.add(secondary); } for (PotionEffect effect : effects) { int amplifier = (beacon.getTier() >= 4 && primary != null && secondary != null && primary.getType().equals(secondary.getType()) && effect.getType().equals(primary.getType())) ? 1 : 0; player.addPotionEffect(new PotionEffect( effect.getType(), EFFECT_DURATION_TICKS, amplifier, true, false, false )); } } private String chunkKey(World world, int cx, int cz) { return world.getUID() + ":" + cx + ":" + cz; } }