package com.tlcplugins.tlcairdrops; import com.cryptomorin.xseries.XMaterial; import com.cryptomorin.xseries.XSound; import com.cryptomorin.xseries.particles.XParticle; import com.tlcplugins.tlcairdrops.model.ActiveAirdrop; import com.tlcplugins.tlcairdrops.model.AirdropType; import org.bukkit.*; import org.bukkit.block.Block; import org.bukkit.block.Chest; import org.bukkit.block.data.BlockData; import org.bukkit.entity.ArmorStand; import org.bukkit.entity.EntityType; import org.bukkit.entity.Player; import org.bukkit.inventory.Inventory; import org.bukkit.inventory.ItemStack; import org.bukkit.scheduler.BukkitRunnable; import org.bukkit.scheduler.BukkitTask; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.logging.Logger; public class AirdropManager { private final TlCAirdrops plugin; private final ConfigManager config; private final LootParser lootParser; private final Logger logger; private final Random random = new Random(); private final Map activeAirdrops = new ConcurrentHashMap<>(); public AirdropManager(TlCAirdrops plugin, ConfigManager config, LootParser lootParser) { this.plugin = plugin; this.config = config; this.lootParser = lootParser; this.logger = plugin.getLogger(); } public Map getActiveAirdrops() { return Collections.unmodifiableMap(activeAirdrops); } public AirdropType pickRandomType() { Map types = config.getAirdropTypes(); if (types.isEmpty()) return null; int totalWeight = types.values().stream().mapToInt(AirdropType::getWeight).sum(); int roll = random.nextInt(Math.max(1, totalWeight)); int cumulative = 0; for (AirdropType type : types.values()) { cumulative += type.getWeight(); if (roll < cumulative) { return type; } } return types.values().iterator().next(); } public boolean spawnRandom() { List worldNames = config.getEnabledWorlds(); if (worldNames.isEmpty()) { logger.warning("No enabled worlds configured!"); return false; } List worlds = new ArrayList<>(); for (String name : worldNames) { World w = Bukkit.getWorld(name); if (w != null) worlds.add(w); } if (worlds.isEmpty()) { logger.warning("None of the enabled worlds are loaded!"); return false; } World world = worlds.get(random.nextInt(worlds.size())); AirdropType type = pickRandomType(); if (type == null) { logger.warning("No airdrop types found!"); return false; } return spawnInWorld(type, world); } public boolean spawnInWorld(AirdropType type, World world) { Location safeLoc = findSafeLocation(world); if (safeLoc == null) { if (config.isDebug()) { logger.warning("Could not find safe location in world: " + world.getName()); } return false; } startIncomingSequence(type, safeLoc); return true; } public boolean spawnAt(AirdropType type, Location groundLocation) { Location loc = groundLocation.clone(); loc.setX(Math.floor(loc.getX()) + 0.5); loc.setY(Math.floor(loc.getY()) + 1); loc.setZ(Math.floor(loc.getZ()) + 0.5); startIncomingSequence(type, loc); return true; } private Location findSafeLocation(World world) { WorldBorder border = world.getWorldBorder(); Location center = border.getCenter(); double halfSize = (border.getSize() / 2.0) * 0.75; for (int attempt = 0; attempt < 30; attempt++) { int x = (int) (center.getX() + (random.nextDouble() * halfSize * 2 - halfSize)); int z = (int) (center.getZ() + (random.nextDouble() * halfSize * 2 - halfSize)); int highestY = world.getHighestBlockYAt(x, z); if (highestY <= world.getMinHeight()) continue; Block highBlock = world.getBlockAt(x, highestY, z); Material type = highBlock.getType(); String typeName = type.name(); if (typeName.contains("WATER") || typeName.contains("LAVA") || type == Material.AIR || type == Material.VOID_AIR || type == Material.CAVE_AIR) { continue; } Location target = new Location(world, x + 0.5, highestY + 1.0, z + 0.5); return target; } return null; } private void startIncomingSequence(AirdropType type, Location targetLocation) { int countdown = config.getLandingCountdown(); BlockData originalData = targetLocation.getBlock().getBlockData(); ActiveAirdrop airdrop = new ActiveAirdrop(type, targetLocation.clone(), originalData); activeAirdrops.put(blockKey(targetLocation), airdrop); broadcastIncoming(type, targetLocation); BukkitTask task = new BukkitRunnable() { int remaining = countdown; @Override public void run() { if (remaining <= 0) { land(airdrop); cancel(); return; } broadcastCountdown(airdrop, remaining); spawnFallingParticles(type, targetLocation); remaining--; } }.runTaskTimer(plugin, 0L, 20L); airdrop.setCountdownTask(task); } private void broadcastIncoming(AirdropType type, Location loc) { String worldName = loc.getWorld() != null ? loc.getWorld().getName() : "?"; int x = loc.getBlockX(); int z = loc.getBlockZ(); String chatMsg = config.msg("airdrop-incoming") .replace("{world}", worldName) .replace("{x}", String.valueOf(x)) .replace("{z}", String.valueOf(z)) .replace("{name}", type.getDisplayName()); String broadcastType = config.getBroadcastType(); int radius = config.getBroadcastRadius(); List targets = getTargetPlayers(loc, radius); for (Player p : targets) { if (!p.hasPermission("tlcairdrops.notify")) continue; if (broadcastType.equals("CHAT") || broadcastType.equals("ALL")) { p.sendMessage(chatMsg); } if (broadcastType.equals("TITLE") || broadcastType.equals("ALL")) { String subtitle = config.msgRaw("airdrop-landing-subtitle") .replace("{world}", worldName) .replace("{x}", String.valueOf(x)) .replace("{z}", String.valueOf(z)); MessageUtil.sendTitle(p, config.msgRaw("airdrop-landing-title"), subtitle, 10, 60, 20); } } } private void broadcastCountdown(ActiveAirdrop airdrop, int seconds) { Location loc = airdrop.getChestLocation(); int radius = config.getBroadcastRadius(); List targets = getTargetPlayers(loc, radius); String broadcastType = config.getBroadcastType(); String barMsg = config.msgRaw("airdrop-countdown-actionbar") .replace("{seconds}", String.valueOf(seconds)) .replace("{x}", String.valueOf(loc.getBlockX())) .replace("{z}", String.valueOf(loc.getBlockZ())); for (Player p : targets) { if (!p.hasPermission("tlcairdrops.notify")) continue; if (broadcastType.equals("ACTIONBAR") || broadcastType.equals("ALL")) { MessageUtil.sendActionBar(p, barMsg); } if ((broadcastType.equals("TITLE") || broadcastType.equals("ALL")) && seconds <= 5) { String mainTitle = config.msgRaw("countdown-title-main").replace("{seconds}", String.valueOf(seconds)); String subTitle = config.msgRaw("countdown-title-sub"); MessageUtil.sendTitle(p, mainTitle, subTitle, 0, 25, 5); } } } private void land(ActiveAirdrop airdrop) { Location loc = airdrop.getChestLocation(); World world = loc.getWorld(); if (world == null) { removeAirdrop(airdrop, false); return; } AirdropType type = airdrop.getType(); airdrop.setState(ActiveAirdrop.State.LANDED); Material containerMaterial = XMaterial.matchXMaterial(type.getContainer().toUpperCase()) .map(XMaterial::parseMaterial) .orElse(Material.CHEST); if (containerMaterial == null) containerMaterial = Material.CHEST; Block block = loc.getBlock(); block.setType(containerMaterial); if (block.getState() instanceof Chest chest) { Inventory inv = chest.getBlockInventory(); List loot = lootParser.generateLoot(type.getLootTable()); List slots = new ArrayList<>(); for (int i = 0; i < inv.getSize(); i++) slots.add(i); Collections.shuffle(slots); int slotIdx = 0; for (ItemStack item : loot) { if (slotIdx >= slots.size()) break; inv.setItem(slots.get(slotIdx++), item); } } spawnHologram(airdrop); if (config.isLandingLightning()) { world.strikeLightningEffect(loc); } playLandingEffect(type, loc); String worldName = world.getName(); String landedMsg = config.msg("airdrop-landed") .replace("{name}", type.getDisplayName()) .replace("{x}", String.valueOf(loc.getBlockX())) .replace("{z}", String.valueOf(loc.getBlockZ())) .replace("{world}", worldName); broadcastToAll(landedMsg); scheduleUnlock(airdrop); scheduleExpire(airdrop); startEffectLoop(airdrop); } private void spawnHologram(ActiveAirdrop airdrop) { Location loc = airdrop.getChestLocation(); World world = loc.getWorld(); if (world == null) return; Location topLoc = loc.clone().add(0, 2.5, 0); ArmorStand top = (ArmorStand) world.spawnEntity(topLoc, EntityType.ARMOR_STAND); configureHologramStand(top, airdrop.getType().getHologram()); airdrop.setHologramTop(top); Location bottomLoc = loc.clone().add(0, 1.9, 0); ArmorStand bottom = (ArmorStand) world.spawnEntity(bottomLoc, EntityType.ARMOR_STAND); configureHologramStand(bottom, airdrop.getType().getHologramSub()); airdrop.setHologramBottom(bottom); } private void configureHologramStand(ArmorStand stand, String name) { stand.setCustomName(name); stand.setCustomNameVisible(true); stand.setVisible(false); stand.setGravity(false); stand.setInvulnerable(true); stand.setSmall(true); stand.setCollidable(false); stand.setMarker(true); } private void scheduleUnlock(ActiveAirdrop airdrop) { int unlockTime = config.getUnlockTime(); airdrop.setRemainingUnlockSeconds(unlockTime); BukkitTask task = new BukkitRunnable() { int remaining = unlockTime; @Override public void run() { if (remaining <= 0) { unlock(airdrop); cancel(); return; } airdrop.setRemainingUnlockSeconds(remaining); sendUnlockCountdown(airdrop, remaining); remaining--; } }.runTaskTimer(plugin, 20L, 20L); airdrop.setUnlockTask(task); } private void sendUnlockCountdown(ActiveAirdrop airdrop, int seconds) { Location loc = airdrop.getChestLocation(); List targets = getTargetPlayers(loc, config.getProtectionRadius() * 3); String barMsg = config.msgRaw("airdrop-countdown-actionbar") .replace("{seconds}", String.valueOf(seconds)) .replace("{x}", String.valueOf(loc.getBlockX())) .replace("{z}", String.valueOf(loc.getBlockZ())); for (Player p : targets) { MessageUtil.sendActionBar(p, barMsg); } } private void unlock(ActiveAirdrop airdrop) { airdrop.setState(ActiveAirdrop.State.UNLOCKED); Location loc = airdrop.getChestLocation(); World world = loc.getWorld(); String unlockedMsg = config.msg("airdrop-unlocked") .replace("{name}", airdrop.getType().getDisplayName()) .replace("{x}", String.valueOf(loc.getBlockX())) .replace("{z}", String.valueOf(loc.getBlockZ())) .replace("{world}", world != null ? world.getName() : "?"); broadcastToAll(unlockedMsg); if (world != null) { String broadcastType = config.getBroadcastType(); for (Player p : Bukkit.getOnlinePlayers()) { if (!p.hasPermission("tlcairdrops.notify")) continue; if (p.getWorld().equals(world)) { if (broadcastType.equals("TITLE") || broadcastType.equals("ALL")) { String sub = config.msgRaw("airdrop-unlocked-subtitle") .replace("{x}", String.valueOf(loc.getBlockX())) .replace("{z}", String.valueOf(loc.getBlockZ())); MessageUtil.sendTitle(p, config.msgRaw("airdrop-unlocked-title"), sub, 10, 60, 20); } } } XSound.matchXSound(airdrop.getType().getSound()).ifPresent(s -> { for (Player p : Bukkit.getOnlinePlayers()) { if (p.getWorld().equals(world)) { s.play(p); } } }); } } private void scheduleExpire(ActiveAirdrop airdrop) { int totalSeconds = config.getUnlockTime() + config.getEventDuration(); BukkitTask task = new BukkitRunnable() { @Override public void run() { if (airdrop.getState() == ActiveAirdrop.State.EXPIRED) return; expire(airdrop); } }.runTaskLater(plugin, totalSeconds * 20L); airdrop.setExpireTask(task); } private void expire(ActiveAirdrop airdrop) { if (airdrop.getState() == ActiveAirdrop.State.EXPIRED) return; airdrop.setState(ActiveAirdrop.State.EXPIRED); String msg = config.msg("airdrop-expired") .replace("{name}", airdrop.getType().getDisplayName()); broadcastToAll(msg); removeAirdrop(airdrop, true); } public void removeAirdrop(ActiveAirdrop airdrop, boolean restoreBlock) { airdrop.setState(ActiveAirdrop.State.EXPIRED); airdrop.cancelTasks(); activeAirdrops.remove(blockKey(airdrop.getChestLocation())); if (airdrop.getHologramTop() != null && !airdrop.getHologramTop().isDead()) { airdrop.getHologramTop().remove(); } if (airdrop.getHologramBottom() != null && !airdrop.getHologramBottom().isDead()) { airdrop.getHologramBottom().remove(); } if (restoreBlock) { Location loc = airdrop.getChestLocation(); Block block = loc.getBlock(); if (block.getType() != Material.AIR && block.getType() != Material.CAVE_AIR) { block.setType(Material.AIR); } } } public void handleChestOpen(Player player, Location chestLoc) { ActiveAirdrop airdrop = getAirdropAt(chestLoc); if (airdrop == null) return; if (airdrop.getFirstOpener() == null) { airdrop.setFirstOpener(player.getUniqueId()); String claimedMsg = config.msg("airdrop-claimed") .replace("{player}", player.getName()) .replace("{name}", airdrop.getType().getDisplayName()); broadcastToAll(claimedMsg); executeCommands(airdrop.getType(), player); } } private void executeCommands(AirdropType type, Player player) { for (String cmd : type.getCommands()) { String parsed = cmd.replace("%player%", player.getName()) .replace("{player}", player.getName()); Bukkit.dispatchCommand(Bukkit.getConsoleSender(), parsed); } } public ActiveAirdrop getAirdropAt(Location loc) { return activeAirdrops.get(blockKey(loc)); } public boolean isInProtectionZone(Location loc) { double radius = config.getProtectionRadius(); for (ActiveAirdrop airdrop : activeAirdrops.values()) { if (airdrop.getState() == ActiveAirdrop.State.EXPIRED) continue; Location center = airdrop.getChestLocation(); if (loc.getWorld() == null || !loc.getWorld().equals(center.getWorld())) continue; if (loc.distance(center) <= radius) return true; } return false; } public ActiveAirdrop getAirdropInZone(Location loc) { double radius = config.getProtectionRadius(); for (ActiveAirdrop airdrop : activeAirdrops.values()) { if (airdrop.getState() == ActiveAirdrop.State.EXPIRED) continue; Location center = airdrop.getChestLocation(); if (loc.getWorld() == null || !loc.getWorld().equals(center.getWorld())) continue; if (loc.distance(center) <= radius) return airdrop; } return null; } private void playLandingEffect(AirdropType type, Location loc) { World world = loc.getWorld(); if (world == null) return; XSound.matchXSound(type.getSound()).ifPresent(s -> world.getPlayers().forEach(s::play)); XParticle.of(type.getParticle()).ifPresent(p -> world.spawnParticle(p.get(), loc, 80, 1.5, 1.0, 1.5, 0.1) ); } private void spawnFallingParticles(AirdropType type, Location loc) { World world = loc.getWorld(); if (world == null) return; Location high = loc.clone().add(0, 3, 0); XParticle.of(type.getParticle()).ifPresent(p -> world.spawnParticle(p.get(), high, 5, 0.3, 0.3, 0.3, 0.05) ); } private void startEffectLoop(ActiveAirdrop airdrop) { BukkitTask task = new BukkitRunnable() { @Override public void run() { if (airdrop.getState() == ActiveAirdrop.State.EXPIRED) { cancel(); return; } Location loc = airdrop.getChestLocation(); World world = loc.getWorld(); if (world == null) return; XParticle.of(airdrop.getType().getParticle()).ifPresent(p -> world.spawnParticle(p.get(), loc.clone().add(0.5, 1, 0.5), 3, 0.5, 0.5, 0.5, 0.0) ); } }.runTaskTimer(plugin, 20L, 40L); airdrop.setEffectTask(task); } private void broadcastToAll(String message) { for (Player p : Bukkit.getOnlinePlayers()) { if (p.hasPermission("tlcairdrops.notify")) { p.sendMessage(message); } } } private List getTargetPlayers(Location loc, double radius) { if (radius <= 0) { List all = new ArrayList<>(); for (Player p : Bukkit.getOnlinePlayers()) { if (loc.getWorld() == null || p.getWorld().equals(loc.getWorld()) || radius == -1) { all.add(p); } } return all; } List nearby = new ArrayList<>(); World world = loc.getWorld(); if (world == null) return nearby; for (Player p : world.getPlayers()) { if (p.getLocation().distance(loc) <= radius) { nearby.add(p); } } return nearby; } private Location blockKey(Location loc) { return new Location(loc.getWorld(), loc.getBlockX(), loc.getBlockY(), loc.getBlockZ()); } public void cleanup() { for (ActiveAirdrop airdrop : new ArrayList<>(activeAirdrops.values())) { removeAirdrop(airdrop, false); } activeAirdrops.clear(); } }