package com.miningarena.managers; import com.miningarena.MiningArenaPlugin; import com.miningarena.scoreboard.ArenaScoreboard; import org.bukkit.*; import org.bukkit.block.Block; import org.bukkit.configuration.file.FileConfiguration; import org.bukkit.entity.*; import org.bukkit.scheduler.BukkitRunnable; import org.bukkit.scheduler.BukkitTask; import java.util.*; /** * Orchestrates the full Mining Arena event lifecycle: * 1. Player count monitoring → countdown * 2. Event start (ore & mob spawning, arena lock) * 3. Scoreboard updates * 4. Event end (time limit or all diamonds mined) */ public class EventManager { // ── State Enum ──────────────────────────────────────────── public enum EventState { IDLE, COUNTDOWN, ACTIVE } // ── Fields ──────────────────────────────────────────────── private final MiningArenaPlugin plugin; private final ArenaManager arenaManager; private final EconomyManager economyManager; EventState state = EventState.IDLE; // Countdown / event timers private BukkitTask countdownTask; private BukkitTask eventTask; private BukkitTask monitorTask; private BukkitTask scoreboardTask; private int countdownSeconds; private int timeLeftSeconds; // Ore tracking private final Set diamondOreLocations = new HashSet<>(); private final Set emeraldOreLocations = new HashSet<>(); private final Set goldOreLocations = new HashSet<>(); private int totalDiamonds; private int remainingDiamonds; private int remainingEmeralds; private int remainingGold; // Mob tracking private final Set trackedMobs = new HashSet<>(); // Per-player earnings this event private final Map playerEarnings = new HashMap<>(); // Scoreboard helper private ArenaScoreboard arenaScoreboard; // ── Constructor ─────────────────────────────────────────── public EventManager(MiningArenaPlugin plugin, ArenaManager arenaManager, EconomyManager economyManager) { this.plugin = plugin; this.arenaManager = arenaManager; this.economyManager = economyManager; this.arenaScoreboard = new ArenaScoreboard(plugin, this, arenaManager); startPlayerMonitor(); } // ── 1. Player Monitor ───────────────────────────────────── /** Checks every 5 s if enough players are inside the arena. */ private void startPlayerMonitor() { monitorTask = new BukkitRunnable() { @Override public void run() { if (state != EventState.IDLE) return; int minPlayers = plugin.getConfig().getInt("event.min-players", 10); if (arenaManager.getPlayersInArena() >= minPlayers) { startCountdown(); } } }.runTaskTimer(plugin, 0L, 100L); // every 5 s } // ── 2. Countdown ────────────────────────────────────────── public void startCountdown() { if (state != EventState.IDLE) return; state = EventState.COUNTDOWN; countdownSeconds = plugin.getConfig().getInt("event.countdown", 60); FileConfiguration cfg = plugin.getConfig(); broadcastArena(cfg.getString("messages.prefix", "§8[§6⛏§8] ") + "§aArena event is starting in §e" + countdownSeconds + "§a seconds! Join now!"); countdownTask = new BukkitRunnable() { int seconds = countdownSeconds; @Override public void run() { int minPlayers = plugin.getConfig().getInt("event.min-players", 10); if (arenaManager.getPlayersInArena() < minPlayers) { cancelCountdown(); return; } if (seconds <= 0) { startEvent(); cancel(); return; } // Announce at key intervals if (seconds == 60 || seconds == 30 || seconds == 10 || seconds <= 5) { broadcastArena(plugin.getConfig().getString("messages.prefix","§8[§6⛏§8] ") + "§eEvent starts in §a" + seconds + " §eseconds!"); } seconds--; } }.runTaskTimer(plugin, 20L, 20L); } private void cancelCountdown() { state = EventState.IDLE; if (countdownTask != null) countdownTask.cancel(); broadcastArena(plugin.getConfig().getString("messages.prefix","§8[§6⛏§8] ") + plugin.getConfig().getString("messages.not-enough-players", "§cNot enough players. Countdown cancelled.")); } // ── 3. Event Start ──────────────────────────────────────── public void startEvent() { state = EventState.ACTIVE; arenaManager.setArenaLocked(true); playerEarnings.clear(); FileConfiguration cfg = plugin.getConfig(); broadcastArena(cfg.getString("messages.prefix","§8[§6⛏§8] ") + cfg.getString("messages.event-started", "§6§l⛏ Mining Event has started!")); spawnOres(); spawnMobs(); timeLeftSeconds = cfg.getInt("event.duration", 600); // Scoreboard arenaScoreboard.createScoreboards(); startScoreboardUpdater(); // Countdown timer eventTask = new BukkitRunnable() { @Override public void run() { if (timeLeftSeconds <= 0) { endEvent("§c§lEvent Over! Time's up!"); cancel(); return; } timeLeftSeconds--; // Announce every minute and last 30/10/5/3/2/1 s if (timeLeftSeconds > 0 && (timeLeftSeconds % 60 == 0 || timeLeftSeconds == 30 || timeLeftSeconds <= 10)) { broadcastArena(plugin.getConfig() .getString("messages.prefix","§8[§6⛏§8] ") + "§eTime remaining: §a" + formatTime(timeLeftSeconds)); } } }.runTaskTimer(plugin, 20L, 20L); } // ── Ore Spawning ────────────────────────────────────────── private void spawnOres() { FileConfiguration cfg = plugin.getConfig(); int dCount = cfg.getInt("ores.diamond.count", 15); int eCount = cfg.getInt("ores.emerald.count", 8); int gCount = cfg.getInt("ores.gold.count", 30); placeOreBlocks(Material.DIAMOND_ORE, dCount, diamondOreLocations); placeOreBlocks(Material.EMERALD_ORE, eCount, emeraldOreLocations); placeOreBlocks(Material.GOLD_ORE, gCount, goldOreLocations); totalDiamonds = dCount; remainingDiamonds = dCount; remainingEmeralds = eCount; remainingGold = gCount; } private void placeOreBlocks(Material material, int count, Set locationSet) { locationSet.clear(); for (int i = 0; i < count; i++) { Location loc = arenaManager.getRandomOreLocation(); loc.getBlock().setType(material); locationSet.add(loc.getBlock().getLocation()); } } // ── Mob Spawning ────────────────────────────────────────── private void spawnMobs() { FileConfiguration cfg = plugin.getConfig(); spawnMobType(EntityType.ZOMBIE, cfg.getInt("mobs.zombie.count", 5)); spawnMobType(EntityType.SKELETON, cfg.getInt("mobs.skeleton.count", 4)); spawnMobType(EntityType.CREEPER, cfg.getInt("mobs.creeper.count", 3)); spawnBoss(cfg.getInt("mobs.boss.count", 1)); } private void spawnMobType(EntityType type, int count) { for (int i = 0; i < count; i++) { Location loc = arenaManager.getRandomArenaLocation(); Entity e = loc.getWorld().spawnEntity(loc, type); e.setMetadata("arena_mob", new org.bukkit.metadata.FixedMetadataValue(plugin, true)); trackedMobs.add(e.getUniqueId()); } } private void spawnBoss(int count) { FileConfiguration cfg = plugin.getConfig(); double bossHealth = cfg.getDouble("mobs.boss.health", 200.0); String bossName = cfg.getString("mobs.boss.name", "§4§l☠ Arena Boss ☠"); for (int i = 0; i < count; i++) { Location loc = arenaManager.getRandomArenaLocation(); Zombie boss = (Zombie) loc.getWorld().spawnEntity(loc, EntityType.ZOMBIE); boss.setCustomName(bossName); boss.setCustomNameVisible(true); boss.setMaxHealth(bossHealth); boss.setHealth(bossHealth); boss.setBaby(false); boss.setMetadata("arena_mob", new org.bukkit.metadata.FixedMetadataValue(plugin, true)); boss.setMetadata("arena_boss", new org.bukkit.metadata.FixedMetadataValue(plugin, true)); trackedMobs.add(boss.getUniqueId()); } } // ── 4. Ore Break Handling ───────────────────────────────── /** * Called by BlockListener when a player breaks an ore in the arena. * Returns the reward amount (0 if not an arena ore). */ public double handleOreBreak(Block block, Player player) { if (state != EventState.ACTIVE) return 0; Location blockLoc = block.getLocation(); FileConfiguration cfg = plugin.getConfig(); double reward = 0; if (diamondOreLocations.remove(blockLoc)) { int min = cfg.getInt("ores.diamond.min-reward", 100); int max = cfg.getInt("ores.diamond.max-reward", 500); reward = min + Math.random() * (max - min); remainingDiamonds--; } else if (emeraldOreLocations.remove(blockLoc)) { int min = cfg.getInt("ores.emerald.min-reward", 150); int max = cfg.getInt("ores.emerald.max-reward", 600); reward = min + Math.random() * (max - min); remainingEmeralds--; } else if (goldOreLocations.remove(blockLoc)) { int min = cfg.getInt("ores.gold.min-reward", 20); int max = cfg.getInt("ores.gold.max-reward", 100); reward = min + Math.random() * (max - min); remainingGold--; } if (reward > 0) { economyManager.giveMoney(player, Math.round(reward), block.getType().name().replace("_ORE","").toLowerCase()); addEarning(player, reward); } // Check end condition: all diamonds mined if (remainingDiamonds <= 0) { Bukkit.getScheduler().runTask(plugin, () -> endEvent(cfg.getString("messages.event-ended-ores", "§c§lEvent Over! All diamond ores have been mined!"))); } return reward; } // ── 5. Mob Kill Handling ────────────────────────────────── /** * Called by MobListener when a player kills an arena mob. * Returns the reward amount (0 if not an arena mob). */ public double handleMobKill(LivingEntity entity, Player killer) { if (state != EventState.ACTIVE) return 0; if (!trackedMobs.remove(entity.getUniqueId())) return 0; FileConfiguration cfg = plugin.getConfig(); double reward = 0; if (entity.hasMetadata("arena_boss")) { reward = cfg.getDouble("mobs.boss.reward", 1000); } else { switch (entity.getType()) { case ZOMBIE -> reward = cfg.getDouble("mobs.zombie.reward", 50); case SKELETON -> reward = cfg.getDouble("mobs.skeleton.reward", 75); case CREEPER -> reward = cfg.getDouble("mobs.creeper.reward", 100); default -> reward = 50; } } if (reward > 0) { economyManager.giveMoney(killer, reward, entity.getType().name().toLowerCase()); addEarning(killer, reward); } return reward; } // ── 6. Scoreboard Updater ───────────────────────────────── private void startScoreboardUpdater() { int interval = plugin.getConfig().getInt("scoreboard.update-interval", 20); scoreboardTask = new BukkitRunnable() { @Override public void run() { if (state == EventState.ACTIVE) { arenaScoreboard.updateAll(); } } }.runTaskTimer(plugin, 0L, interval); } // ── 7. Event End ────────────────────────────────────────── public void endEvent(String reason) { if (state != EventState.ACTIVE) return; state = EventState.IDLE; // Cancel timers if (eventTask != null) eventTask.cancel(); if (scoreboardTask != null) scoreboardTask.cancel(); // Broadcast reason broadcastArena(plugin.getConfig().getString("messages.prefix","§8[§6⛏§8] ") + reason); // Show top earner showTopMiner(); // Remove remaining arena mobs cleanupMobs(); // Restore ore blocks to stone cleanupOres(); // Unlock arena arenaManager.setArenaLocked(false); // Remove scoreboards arenaScoreboard.removeAll(); } /** Force-ends an active or countdown event (used on plugin disable). */ public void forceEndEvent() { if (state == EventState.COUNTDOWN && countdownTask != null) countdownTask.cancel(); if (state == EventState.ACTIVE) endEvent("§cPlugin is reloading/disabling."); if (monitorTask != null) monitorTask.cancel(); } // ── Helper Methods ──────────────────────────────────────── private void showTopMiner() { if (playerEarnings.isEmpty()) return; UUID topUUID = Collections.max(playerEarnings.entrySet(), Map.Entry.comparingByValue()).getKey(); Player topPlayer = Bukkit.getPlayer(topUUID); String name = topPlayer != null ? topPlayer.getName() : Bukkit.getOfflinePlayer(topUUID).getName(); String template = plugin.getConfig().getString("messages.top-miner", "§e§lTop Miner: §f{player}"); broadcastArena(plugin.getConfig().getString("messages.prefix","§8[§6⛏§8] ") + template.replace("{player}", name != null ? name : "Unknown")); } private void cleanupMobs() { for (World w : plugin.getServer().getWorlds()) { for (Entity e : w.getEntities()) { if (e.hasMetadata("arena_mob")) { e.remove(); } } } trackedMobs.clear(); } private void cleanupOres() { restoreBlocks(diamondOreLocations); restoreBlocks(emeraldOreLocations); restoreBlocks(goldOreLocations); diamondOreLocations.clear(); emeraldOreLocations.clear(); goldOreLocations.clear(); } private void restoreBlocks(Set locations) { for (Location loc : locations) { Block b = loc.getBlock(); if (b.getType() == Material.DIAMOND_ORE || b.getType() == Material.EMERALD_ORE || b.getType() == Material.GOLD_ORE) { b.setType(Material.STONE); } } } /** Broadcasts a message to all players currently inside the arena. */ public void broadcastArena(String message) { for (Player p : plugin.getServer().getOnlinePlayers()) { if (arenaManager.isInsideArena(p.getLocation())) { p.sendMessage(message); } } plugin.getLogger().info("[Broadcast] " + ChatColor.stripColor(message)); } private void addEarning(Player player, double amount) { playerEarnings.merge(player.getUniqueId(), amount, Double::sum); } public String formatTime(int seconds) { int m = seconds / 60; int s = seconds % 60; return String.format("%02d:%02d", m, s); } // ── Getters (used by Scoreboard) ────────────────────────── public EventState getState() { return state; } public int getTimeLeftSeconds() { return timeLeftSeconds; } public int getRemainingDiamonds() { return remainingDiamonds; } public int getRemainingEmeralds() { return remainingEmeralds; } public int getRemainingGold() { return remainingGold; } public Map getEarnings() { return Collections.unmodifiableMap(playerEarnings); } public String getTopMinerName() { if (playerEarnings.isEmpty()) return "§7None"; UUID topUUID = Collections.max(playerEarnings.entrySet(), Map.Entry.comparingByValue()).getKey(); Player p = Bukkit.getPlayer(topUUID); return p != null ? p.getName() : (Bukkit.getOfflinePlayer(topUUID).getName() != null ? Bukkit.getOfflinePlayer(topUUID).getName() : "Unknown"); } }