package com.example.randomdropmadness.manager; import com.cryptomorin.xseries.XMaterial; import com.cryptomorin.xseries.XSound; import com.cryptomorin.xseries.particles.XParticle; import com.example.randomdropmadness.RandomDropMadness; import com.example.randomdropmadness.config.ConfigManager; import com.example.randomdropmadness.data.RarityTier; import com.example.randomdropmadness.data.StatsManager; import com.example.randomdropmadness.util.ItemUtil; import com.example.randomdropmadness.util.MessageUtil; import org.bukkit.Bukkit; import org.bukkit.Location; import org.bukkit.Particle; import org.bukkit.World; import org.bukkit.entity.EntityType; import org.bukkit.entity.Firework; import org.bukkit.entity.Player; import org.bukkit.inventory.meta.FireworkMeta; import org.bukkit.scheduler.BukkitTask; import org.bukkit.Color; import org.bukkit.FireworkEffect; import org.bukkit.inventory.ItemStack; import java.util.List; import java.util.Random; public class DropManager { private final RandomDropMadness plugin; private final ConfigManager config; private final StatsManager stats; private final Random random = new Random(); private BukkitTask mainTask; private BukkitTask countdownTask; private BukkitTask actionBarTask; private boolean running = false; private int secondsRemaining; public DropManager(RandomDropMadness plugin) { this.plugin = plugin; this.config = plugin.getConfigManager(); this.stats = plugin.getStatsManager(); } public boolean isRunning() { return running; } public void start() { if (running) return; running = true; if (config.isBossBarEnabled()) { plugin.getBossBarManager().addAll(); } startCountdown(); plugin.getLogger().info("DropManager started with interval: " + config.getDropInterval() + "s"); } public void stop() { if (!running) return; running = false; cancelTasks(); plugin.getBossBarManager().removeAll(); plugin.getLogger().info("DropManager stopped."); } public void forceNext() { if (!running) return; cancelTasks(); secondsRemaining = 0; triggerWarningAndDrop(); } public void restart() { stop(); start(); } private void cancelTasks() { if (mainTask != null) { mainTask.cancel(); mainTask = null; } if (countdownTask != null) { countdownTask.cancel(); countdownTask = null; } if (actionBarTask != null) { actionBarTask.cancel(); actionBarTask = null; } } private void startCountdown() { secondsRemaining = config.getDropInterval(); countdownTask = Bukkit.getScheduler().runTaskTimer(plugin, () -> { if (!running) return; if (config.isBossBarEnabled()) { plugin.getBossBarManager().update(secondsRemaining, config.getDropInterval()); } if (secondsRemaining == 5) { triggerWarningAndDrop(); return; } if (secondsRemaining > 0) { secondsRemaining--; } }, 20L, 20L); if (config.isActionBarEnabled()) { actionBarTask = Bukkit.getScheduler().runTaskTimer(plugin, () -> { if (!running) return; String bar = "\u00a7e\u00a7l⏱ \u00a7fNext Drop: \u00a7e" + secondsRemaining + "s"; for (Player player : Bukkit.getOnlinePlayers()) { if (!isBlacklisted(player.getWorld())) { MessageUtil.sendActionBar(player, bar); } } }, 20L, 20L); } } private void triggerWarningAndDrop() { Bukkit.broadcastMessage(config.getMessage("warning")); if (config.isBossBarEnabled()) { plugin.getBossBarManager().setDropping(); } final int[] countdown = {5}; BukkitTask cdTask = Bukkit.getScheduler().runTaskTimer(plugin, () -> { if (countdown[0] > 0) { sendCountdownTitle(countdown[0]); countdown[0]--; } }, 0L, 20L); Bukkit.getScheduler().runTaskLater(plugin, () -> { cdTask.cancel(); executeDrop(); secondsRemaining = config.getDropInterval(); }, 100L); } private void sendCountdownTitle(int count) { String color = count <= 2 ? "\u00a7c" : (count == 3 ? "\u00a7e" : "\u00a7a"); String title = color + "\u00a7l" + count; String subtitle = "\u00a77Get ready for your drop!"; for (Player player : Bukkit.getOnlinePlayers()) { if (!isBlacklisted(player.getWorld())) { player.sendTitle(title, subtitle, 0, 25, 5); } } } private void executeDrop() { RarityTier eventTier = rollEventTier(); if (eventTier == RarityTier.CHAOS) { executeChaosEvent(); return; } for (Player player : Bukkit.getOnlinePlayers()) { if (isBlacklisted(player.getWorld())) continue; if (!player.hasPermission("rdm.receive")) continue; if (eventTier == RarityTier.LEGENDARY) { executeLegendaryDrop(player); } else if (eventTier == RarityTier.TROLL) { executeTrollDrop(player); } else { RarityTier tier = rollItemTier(); executeNormalDrop(player, tier); } } } private RarityTier rollEventTier() { int roll = random.nextInt(100); int cursor = 0; if (config.isChaosEnabled()) { cursor += config.getChaosChance(); if (roll < cursor) return RarityTier.CHAOS; } if (config.isTrollEnabled()) { cursor += config.getTrollChance(); if (roll < cursor) return RarityTier.TROLL; } if (config.isLegendaryEnabled()) { cursor += config.getLegendaryChance(); if (roll < cursor) return RarityTier.LEGENDARY; } return RarityTier.COMMON; } private RarityTier rollItemTier() { int roll = random.nextInt(100); if (roll < 2) return RarityTier.MYTHIC; if (roll < 10) return RarityTier.EPIC; if (roll < 30) return RarityTier.RARE; return RarityTier.COMMON; } private void executeNormalDrop(Player player, RarityTier tier) { List pool = config.getItemPool(tier); if (pool.isEmpty()) { pool = config.getItemPool(RarityTier.COMMON); } if (pool.isEmpty()) return; String entry = pool.get(random.nextInt(pool.size())); ItemStack item = ItemUtil.parseItemEntry(entry); if (item == null) return; if (tier == RarityTier.MYTHIC) { item = ItemUtil.buildMythicItem(item); } dropItemOnPlayer(player, item); spawnDropEffects(player, tier); stats.recordDrop(player.getUniqueId(), tier); String msgKey = "drop-" + tier.name().toLowerCase(); player.sendMessage(config.getMessage(msgKey)); } private void executeLegendaryDrop(Player player) { List pool = config.getItemPool(RarityTier.MYTHIC); if (pool.isEmpty()) return; for (int i = 0; i < 3; i++) { String entry = pool.get(random.nextInt(pool.size())); ItemStack item = ItemUtil.parseItemEntry(entry); if (item != null) { item = ItemUtil.buildLegendaryItem(item); dropItemOnPlayer(player, item); } } spawnLegendaryEffects(player); stats.recordDrop(player.getUniqueId(), RarityTier.LEGENDARY); player.sendMessage(config.getMessage("drop-legendary")); player.sendTitle("\u00a7e\u00a7l★ LEGENDARY ★", "\u00a77Netherite gear from the gods!", 10, 60, 20); } private void executeTrollDrop(Player player) { List pool = config.getItemPool(RarityTier.TROLL); if (pool.isEmpty()) return; for (int i = 0; i < 3; i++) { String entry = pool.get(random.nextInt(pool.size())); ItemStack item = ItemUtil.parseItemEntry(entry); if (item != null) { dropItemOnPlayer(player, item); } } spawnTrollEffects(player); stats.recordDrop(player.getUniqueId(), RarityTier.TROLL); player.sendMessage(config.getMessage("drop-troll")); player.sendTitle("\u00a7c\u00a7l☠ TROLLED! ☠", "\u00a77Better luck next time...", 10, 60, 20); } private void executeChaosEvent() { Bukkit.broadcastMessage(config.getMessage("drop-chaos")); for (Player player : Bukkit.getOnlinePlayers()) { if (isBlacklisted(player.getWorld())) continue; player.sendTitle("\u00a74\u00a7l☢ CHAOS! ☢", "\u00a7cTNT RAIN HAS BEGUN!", 10, 60, 20); stats.recordDrop(player.getUniqueId(), RarityTier.CHAOS); } int duration = config.getChaosDuration(); final int[] elapsed = {0}; BukkitTask chaosTask = Bukkit.getScheduler().runTaskTimer(plugin, () -> { if (elapsed[0] >= duration * 4) return; elapsed[0]++; for (Player player : Bukkit.getOnlinePlayers()) { if (isBlacklisted(player.getWorld())) continue; spawnChaosTNT(player); spawnChaosFirework(player); XSound.matchXSound("ENTITY_CREEPER_PRIMED").ifPresent(s -> s.play(player)); } }, 0L, 5L); Bukkit.getScheduler().runTaskLater(plugin, chaosTask::cancel, (long) duration * 20L + 20L); } private void spawnChaosTNT(Player player) { Location base = player.getLocation(); World world = base.getWorld(); if (world == null) return; double offsetX = (random.nextDouble() - 0.5) * 10; double offsetZ = (random.nextDouble() - 0.5) * 10; Location spawnLoc = base.clone().add(offsetX, config.getDropHeight() + 3, offsetZ); ItemStack tnt = XMaterial.matchXMaterial("TNT").map(XMaterial::parseItem).orElse(null); if (tnt != null) { world.dropItem(spawnLoc, tnt); } XParticle.of("EXPLOSION").ifPresent(p -> world.spawnParticle(p.get(), spawnLoc, 5, 0.5, 0.5, 0.5, 0)); } private void spawnChaosFirework(Player player) { Location loc = player.getLocation().add( (random.nextDouble() - 0.5) * 8, 1, (random.nextDouble() - 0.5) * 8 ); World world = loc.getWorld(); if (world == null) return; Firework fw = (Firework) world.spawnEntity(loc, EntityType.FIREWORK_ROCKET); FireworkMeta meta = fw.getFireworkMeta(); meta.addEffect(FireworkEffect.builder() .withColor(Color.RED, Color.ORANGE, Color.YELLOW) .with(FireworkEffect.Type.BALL_LARGE) .withFlicker() .withTrail() .build()); meta.setPower(1); fw.setFireworkMeta(meta); } private void dropItemOnPlayer(Player player, ItemStack item) { if (item == null) return; Location dropLoc = player.getLocation().add(0, config.getDropHeight(), 0); World world = dropLoc.getWorld(); if (world == null) return; world.dropItem(dropLoc, item); } private void spawnDropEffects(Player player, RarityTier tier) { Location loc = player.getLocation().add(0, config.getDropHeight(), 0); World world = loc.getWorld(); if (world == null) return; world.strikeLightningEffect(player.getLocation()); switch (tier) { case COMMON: XParticle.of("CLOUD").ifPresent(p -> world.spawnParticle(p.get(), loc, 20, 0.5, 0.5, 0.5, 0.05)); XSound.matchXSound("ENTITY_ITEM_PICKUP").ifPresent(s -> s.play(player)); break; case RARE: XParticle.of("ENCHANT").ifPresent(p -> world.spawnParticle(p.get(), loc, 30, 0.5, 0.5, 0.5, 0.1)); XSound.matchXSound("ENTITY_EXPERIENCE_ORB_PICKUP").ifPresent(s -> s.play(player)); break; case EPIC: XParticle.of("DRAGON_BREATH").ifPresent(p -> world.spawnParticle(p.get(), loc, 40, 0.5, 0.5, 0.5, 0.1)); XSound.matchXSound("ENTITY_ENDER_DRAGON_GROWL").ifPresent(s -> s.play(player)); break; case MYTHIC: XParticle.of("TOTEM_OF_UNDYING").ifPresent(p -> world.spawnParticle(p.get(), loc, 60, 0.5, 0.5, 0.5, 0.2)); XSound.matchXSound("UI_TOAST_CHALLENGE_COMPLETE").ifPresent(s -> s.play(player)); break; default: break; } } private void spawnLegendaryEffects(Player player) { Location loc = player.getLocation(); World world = loc.getWorld(); if (world == null) return; world.strikeLightningEffect(loc); world.strikeLightningEffect(loc.clone().add(1, 0, 0)); world.strikeLightningEffect(loc.clone().add(-1, 0, 0)); XParticle.of("TOTEM_OF_UNDYING").ifPresent(p -> world.spawnParticle(p.get(), loc.clone().add(0, 3, 0), 100, 1, 1, 1, 0.3)); XParticle.of("FIREWORKS_SPARK").ifPresent(p -> world.spawnParticle(p.get(), loc.clone().add(0, 3, 0), 80, 1, 1, 1, 0.2)); XSound.matchXSound("UI_TOAST_CHALLENGE_COMPLETE").ifPresent(s -> s.play(player)); XSound.matchXSound("ENTITY_WITHER_SPAWN").ifPresent(s -> s.play(player)); Firework fw = (Firework) world.spawnEntity(loc.clone().add(0, 1, 0), EntityType.FIREWORK_ROCKET); FireworkMeta meta = fw.getFireworkMeta(); meta.addEffect(FireworkEffect.builder() .withColor(Color.YELLOW, Color.ORANGE, Color.WHITE) .with(FireworkEffect.Type.STAR) .withFlicker() .withTrail() .build()); meta.setPower(2); fw.setFireworkMeta(meta); } private void spawnTrollEffects(Player player) { Location loc = player.getLocation(); World world = loc.getWorld(); if (world == null) return; XParticle.of("VILLAGER_ANGRY").ifPresent(p -> world.spawnParticle(p.get(), loc.clone().add(0, 1, 0), 20, 0.5, 0.5, 0.5, 0)); XParticle.of("SMOKE_LARGE").ifPresent(p -> world.spawnParticle(p.get(), loc.clone().add(0, 2, 0), 30, 0.5, 0.5, 0.5, 0.05)); XSound.matchXSound("ENTITY_VILLAGER_NO").ifPresent(s -> s.play(player)); XSound.matchXSound("ENTITY_CHICKEN_HURT").ifPresent(s -> s.play(player)); } private boolean isBlacklisted(World world) { return config.getBlacklistedWorlds().contains(world.getName()); } }