package com.donutduels.duel; import com.donutduels.DonutDuels; import com.donutduels.arena.Arena; import com.donutduels.kit.DuelKit; import org.apache.commons.lang3.StringUtils; import org.bukkit.ChatColor; import org.bukkit.GameMode; import org.bukkit.Material; import org.bukkit.entity.Player; import org.bukkit.inventory.ItemStack; import org.bukkit.potion.PotionEffect; import org.bukkit.scheduler.BukkitRunnable; import java.util.*; import java.util.concurrent.ConcurrentHashMap; public class DuelManager { private final DonutDuels plugin; private final Map activeDuels; private final Map pendingRequests; private final Set duelQueue; public DuelManager(DonutDuels plugin) { this.plugin = plugin; this.activeDuels = new ConcurrentHashMap<>(); this.pendingRequests = new ConcurrentHashMap<>(); this.duelQueue = new HashSet<>(); // Start cleanup task startCleanupTask(); } public boolean sendDuelRequest(Player sender, Player target) { // Check if sender can duel if (isInDuel(sender)) { sender.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("player-in-duel"))); return false; } // Check if target can duel if (isInDuel(target)) { sender.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("player-in-duel"))); return false; } // Check for existing request String requestKey = getRequestKey(sender, target); if (pendingRequests.containsKey(requestKey)) { sender.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("duel-already-pending"))); return false; } // Check economy if (plugin.getConfigManager().isEconomyEnabled() && plugin.hasEconomy()) { double cost = plugin.getConfigManager().getDuelCost(); if (cost > 0 && !plugin.getEconomy().has(sender, cost)) { sender.sendMessage(ChatColor.RED + "You don't have enough money to send a duel request!"); return false; } } // Create request long expireTime = System.currentTimeMillis() + (plugin.getConfigManager().getRequestTimeout() * 1000L); DuelRequest request = new DuelRequest(sender, target, expireTime); pendingRequests.put(requestKey, request); // Send messages sender.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("duel-sent").replace("{player}", target.getName()))); target.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("duel-received").replace("{player}", sender.getName()))); return true; } public boolean acceptDuelRequest(Player accepter, Player requester) { String requestKey = getRequestKey(requester, accepter); DuelRequest request = pendingRequests.get(requestKey); if (request == null || request.isExpired()) { accepter.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("duel-expired"))); if (request != null) { pendingRequests.remove(requestKey); } return false; } // Check if players can still duel if (isInDuel(accepter) || isInDuel(requester)) { accepter.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("player-in-duel"))); pendingRequests.remove(requestKey); return false; } // Get available arena Arena arena = plugin.getArenaManager().getRandomAvailableArena(); if (arena == null) { accepter.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("no-arenas"))); requester.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("no-arenas"))); pendingRequests.remove(requestKey); return false; } // Get default kit DuelKit kit = plugin.getKitManager().getDefaultKit(); // Create duel Duel duel = new Duel(requester, accepter, arena, kit); // Start duel startDuel(duel); // Remove request pendingRequests.remove(requestKey); return true; } public boolean declineDuelRequest(Player decliner, Player requester) { String requestKey = getRequestKey(requester, decliner); DuelRequest request = pendingRequests.remove(requestKey); if (request == null) { return false; } decliner.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("duel-declined"))); requester.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("duel-declined"))); return true; } private void startDuel(Duel duel) { // Mark arena as in use duel.getArena().setInUse(true); // Add to active duels activeDuels.put(duel.getPlayer1().getUniqueId(), duel); activeDuels.put(duel.getPlayer2().getUniqueId(), duel); // Prepare players preparePlayers(duel); // Start countdown startCountdown(duel); // Send messages String message = ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("duel-accepted")); duel.getPlayer1().sendMessage(message); duel.getPlayer2().sendMessage(message); } private void preparePlayers(Duel duel) { Player player1 = duel.getPlayer1(); Player player2 = duel.getPlayer2(); // Teleport to arena player1.teleport(duel.getArena().getSpawn1()); player2.teleport(duel.getArena().getSpawn2()); // Set game mode player1.setGameMode(GameMode.SURVIVAL); player2.setGameMode(GameMode.SURVIVAL); // Clear and apply kit clearPlayer(player1); clearPlayer(player2); duel.getKit().applyKit(player1); duel.getKit().applyKit(player2); // Give food if configured if (plugin.getConfigManager().shouldGiveFood()) { giveFood(player1); giveFood(player2); } // Reset health and hunger player1.setHealth(player1.getMaxHealth()); player2.setHealth(player2.getMaxHealth()); player1.setFoodLevel(20); player2.setFoodLevel(20); player1.setSaturation(20); player2.setSaturation(20); } private void clearPlayer(Player player) { player.getInventory().clear(); player.getInventory().setArmorContents(new ItemStack[4]); player.setLevel(0); player.setExp(0); player.setAllowFlight(false); player.setFlying(false); // Clear potion effects for (PotionEffect effect : player.getActivePotionEffects()) { player.removePotionEffect(effect.getType()); } } private void giveFood(Player player) { try { Material foodMaterial = Material.valueOf(plugin.getConfigManager().getFoodItem()); int amount = plugin.getConfigManager().getFoodAmount(); ItemStack food = new ItemStack(foodMaterial, amount); player.getInventory().addItem(food); } catch (IllegalArgumentException e) { plugin.getLogger().warning("Invalid food item: " + plugin.getConfigManager().getFoodItem()); } } private void startCountdown(Duel duel) { duel.setState(DuelState.COUNTDOWN); int countdownTime = plugin.getConfigManager().getCountdownTime(); BukkitRunnable countdown = new BukkitRunnable() { int timeLeft = countdownTime; @Override public void run() { if (timeLeft <= 0) { // Start duel duel.setState(DuelState.ACTIVE); String startMessage = ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("duel-start")); duel.getPlayer1().sendMessage(startMessage); duel.getPlayer2().sendMessage(startMessage); // Notify spectators notifySpectators(duel, startMessage); this.cancel(); return; } String countdownMessage = ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("countdown").replace("{time}", String.valueOf(timeLeft))); duel.getPlayer1().sendMessage(countdownMessage); duel.getPlayer2().sendMessage(countdownMessage); // Notify spectators notifySpectators(duel, countdownMessage); timeLeft--; } }; int taskId = countdown.runTaskTimer(plugin, 0L, 20L).getTaskId(); duel.setCountdownTask(taskId); } public void endDuel(Duel duel, Player winner) { if (duel.getState() == DuelState.ENDING || duel.getState() == DuelState.FINISHED) { return; } duel.setState(DuelState.ENDING); duel.setWinner(winner); Player loser = duel.getLoser(); // Send messages if (winner != null) { winner.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("duel-won").replace("{player}", loser.getName()))); loser.sendMessage(ChatColor.translateAlternateColorCodes('&', plugin.getConfigManager().getMessage("duel-lost").replace("{player}", winner.getName()))); } // Update statistics plugin.getStatsManager().updateStats(duel); // Handle economy rewards if (plugin.getConfigManager().isEconomyEnabled() && plugin.hasEconomy()) { plugin.getEconomyManager().handleDuelRewards(duel); } // Restore players after delay plugin.getServer().getScheduler().runTaskLater(plugin, () -> { restorePlayers(duel); cleanupDuel(duel); }, 60L); // 3 second delay } // New overloaded method for compatibility public void endDuel(Duel duel, Player winner, Player loser, String reason) { endDuel(duel, winner); } private void restorePlayers(Duel duel) { restorePlayer(duel.getPlayer1(), duel); restorePlayer(duel.getPlayer2(), duel); // Teleport spectators back plugin.getSpectateManager().endSpectating(duel); } private void restorePlayer(Player player, Duel duel) { if (!player.isOnline()) { return; } Duel.PlayerBackup backup = duel.getPlayerBackup(player.getUniqueId()); if (backup == null) { return; } // Restore location if (backup.location.getWorld() != null) { player.teleport(backup.location); } // Restore inventory if configured if (plugin.getConfigManager().shouldRestoreInventory()) { player.getInventory().setContents(backup.inventory); player.getInventory().setArmorContents(backup.armor); } // Restore stats if configured if (plugin.getConfigManager().shouldRestoreStats()) { player.setHealth(Math.min(backup.health, player.getMaxHealth())); player.setFoodLevel(backup.foodLevel); player.setSaturation(backup.saturation); player.setExhaustion(backup.exhaustion); player.setLevel(backup.level); player.setExp(backup.exp); } // Restore game mode and flight player.setGameMode(backup.gameMode); player.setAllowFlight(backup.allowFlight); player.setFlying(backup.flying); // Restore potion effects for (PotionEffect effect : player.getActivePotionEffects()) { player.removePotionEffect(effect.getType()); } for (PotionEffect effect : backup.potionEffects) { player.addPotionEffect(effect); } } private void cleanupDuel(Duel duel) { duel.setState(DuelState.FINISHED); // Mark arena as available duel.getArena().setInUse(false); // Remove from active duels activeDuels.remove(duel.getPlayer1().getUniqueId()); activeDuels.remove(duel.getPlayer2().getUniqueId()); // Cancel countdown task if still running if (duel.getCountdownTask() != 0) { plugin.getServer().getScheduler().cancelTask(duel.getCountdownTask()); } // Record duel history plugin.getStatsManager().recordDuelHistory(duel); } public void forceEndDuel(Player player) { Duel duel = activeDuels.get(player.getUniqueId()); if (duel == null) { return; } Player opponent = duel.getOpponent(player); endDuel(duel, opponent); } // New methods for queue system public boolean joinQueue(Player player) { if (isInDuel(player) || isInQueue(player)) { return false; } duelQueue.add(player.getUniqueId()); return true; } public boolean leaveQueue(Player player) { return duelQueue.remove(player.getUniqueId()); } public boolean isInQueue(Player player) { return duelQueue.contains(player.getUniqueId()); } public int getQueueSize() { return duelQueue.size(); } // New methods for player disconnect handling public void handlePlayerDisconnect(Player player) { // Remove from queue leaveQueue(player); // End duel if in one if (isInDuel(player)) { forceEndDuel(player); } // Clean up requests cleanupPlayerRequests(player); } public void cleanupPlayerRequests(Player player) { // Remove all requests involving this player pendingRequests.entrySet().removeIf(entry -> { DuelRequest request = entry.getValue(); return request.getSender().equals(player) || request.getTarget().equals(player); }); } public void forfeitDuel(Player player) { Duel duel = activeDuels.get(player.getUniqueId()); if (duel == null) { return; } Player opponent = duel.getOpponent(player); // Send forfeit messages player.sendMessage(ChatColor.RED + "You have forfeited the duel!"); opponent.sendMessage(ChatColor.GREEN + player.getName() + " has forfeited! You win!"); endDuel(duel, opponent); } public boolean isInDuel(Player player) { return activeDuels.containsKey(player.getUniqueId()); } public Duel getDuel(Player player) { return activeDuels.get(player.getUniqueId()); } public Collection getActiveDuels() { return new HashSet<>(activeDuels.values()); } public DuelRequest getPendingRequest(Player sender, Player target) { return pendingRequests.get(getRequestKey(sender, target)); } private String getRequestKey(Player sender, Player target) { return sender.getName().toLowerCase() + ":" + target.getName().toLowerCase(); } private void notifySpectators(Duel duel, String message) { for (UUID spectatorId : duel.getSpectators()) { Player spectator = plugin.getServer().getPlayer(spectatorId); if (spectator != null && spectator.isOnline()) { spectator.sendMessage(message); } } } private void startCleanupTask() { plugin.getServer().getScheduler().runTaskTimerAsynchronously(plugin, () -> { // Clean expired requests pendingRequests.entrySet().removeIf(entry -> entry.getValue().isExpired()); }, 200L, 200L); // Every 10 seconds } public void shutdown() { // End all active duels for (Duel duel : new ArrayList<>(activeDuels.values())) { restorePlayers(duel); cleanupDuel(duel); } activeDuels.clear(); pendingRequests.clear(); duelQueue.clear(); } }