package com.customplugins.customduels.match; import com.customplugins.customduels.CustomDuels; import com.customplugins.customduels.arena.Arena; import com.customplugins.customduels.kit.DuelKit; import com.customplugins.customduels.stats.PlayerStats; import com.cryptomorin.xseries.XSound; import net.kyori.adventure.text.Component; import net.kyori.adventure.text.minimessage.MiniMessage; import net.kyori.adventure.title.Title; import org.bukkit.*; import org.bukkit.entity.*; import org.bukkit.inventory.ItemStack; import java.util.*; import java.util.concurrent.ConcurrentHashMap; public class MatchManager { private final CustomDuels plugin; private final Map activeMatches = new ConcurrentHashMap<>(); private final Map playerMatchMap = new ConcurrentHashMap<>(); private final Map spectatorMatchMap = new ConcurrentHashMap<>(); private final Map rematchRequests = new ConcurrentHashMap<>(); private final MiniMessage miniMessage = MiniMessage.miniMessage(); public MatchManager(CustomDuels plugin) { this.plugin = plugin; } public DuelMatch createMatch(DuelKit kit, Arena arena, MatchType matchType, RoundFormat roundFormat, List team1, List team2) { DuelMatch match = new DuelMatch(kit, arena, matchType, roundFormat); match.getTeam1().addAll(team1); match.getTeam2().addAll(team2); activeMatches.put(match.getMatchId(), match); for (UUID uuid : match.getAllParticipants()) { playerMatchMap.put(uuid, match.getMatchId()); } arena.setInUse(true); startCountdown(match); return match; } private void startCountdown(DuelMatch match) { match.setState(MatchState.COUNTDOWN); int seconds = plugin.getConfigManager().getCountdownSeconds(); for (UUID uuid : match.getAllParticipants()) { Player player = Bukkit.getPlayer(uuid); if (player == null) continue; saveAndClearInventory(player, match); plugin.getKitManager().applyKit(player, match.getKit()); applyKitSettings(player, match.getKit(), false); } teleportToArena(match); final int[] countdown = {seconds}; Bukkit.getScheduler().runTaskTimer(plugin, () -> { if (match.getState() == MatchState.FINISHED) return; if (countdown[0] <= 0) { startMatch(match); return; } for (UUID uuid : match.getAllParticipants()) { Player player = Bukkit.getPlayer(uuid); if (player == null) continue; Map ph = Map.of("seconds", String.valueOf(countdown[0])); player.sendActionBar(plugin.getConfigManager().getMessage("match.countdown", ph)); player.showTitle(Title.title( miniMessage.deserialize("" + countdown[0]), miniMessage.deserialize("Get ready!"), Title.Times.times( java.time.Duration.ofMillis(200), java.time.Duration.ofMillis(800), java.time.Duration.ofMillis(200) ) )); XSound.matchXSound("BLOCK_NOTE_BLOCK_PLING").ifPresent(s -> s.play(player)); } countdown[0]--; }, 0L, 20L); } private void startMatch(DuelMatch match) { match.setState(MatchState.ACTIVE); for (UUID uuid : match.getAllParticipants()) { Player player = Bukkit.getPlayer(uuid); if (player == null) continue; applyKitSettings(player, match.getKit(), true); player.sendMessage(plugin.getConfigManager().getMessage("match.start")); player.showTitle(Title.title( miniMessage.deserialize("FIGHT!"), Component.empty(), Title.Times.times( java.time.Duration.ofMillis(100), java.time.Duration.ofMillis(1000), java.time.Duration.ofMillis(500) ) )); XSound.matchXSound("ENTITY_ENDER_DRAGON_GROWL").ifPresent(s -> s.play(player)); } } public void handlePlayerDeath(Player player, DuelMatch match) { if (match.getState() != MatchState.ACTIVE) return; match.getEliminated().add(player.getUniqueId()); List opponentTeam = match.getOpponentTeam(player.getUniqueId()); List playerTeam = match.isTeam1(player.getUniqueId()) ? match.getTeam1() : match.getTeam2(); boolean teamEliminated = match.getEliminated().containsAll(playerTeam); if (teamEliminated) { List winnerTeam = opponentTeam; List loserTeam = playerTeam; if (match.getRoundFormat() == RoundFormat.BO1) { endMatch(match, winnerTeam, loserTeam); } else { endRound(match, winnerTeam, loserTeam); } } } private void endRound(DuelMatch match, List winnerTeam, List loserTeam) { boolean team1Won = winnerTeam == match.getTeam1() || match.getTeam1().containsAll(winnerTeam); if (team1Won) { match.setTeam1RoundsWon(match.getTeam1RoundsWon() + 1); } else { match.setTeam2RoundsWon(match.getTeam2RoundsWon() + 1); } int roundsToWin = match.getRoundFormat().getRoundsToWin(); if (match.getTeam1RoundsWon() >= roundsToWin) { endMatch(match, match.getTeam1(), match.getTeam2()); } else if (match.getTeam2RoundsWon() >= roundsToWin) { endMatch(match, match.getTeam2(), match.getTeam1()); } else { match.setCurrentRound(match.getCurrentRound() + 1); match.getEliminated().clear(); for (UUID uuid : match.getAllParticipants()) { Player p = Bukkit.getPlayer(uuid); if (p == null) continue; plugin.getKitManager().applyKit(p, match.getKit()); p.setHealth(p.getAttribute(org.bukkit.attribute.Attribute.GENERIC_MAX_HEALTH).getValue()); p.setFoodLevel(20); } teleportToArena(match); startCountdown(match); } } public void endMatch(DuelMatch match, List winnerTeam, List loserTeam) { if (match.getState() == MatchState.FINISHED || match.getState() == MatchState.ENDING) return; match.setState(MatchState.ENDING); match.setWinnerTeam(winnerTeam); match.setLoserTeam(loserTeam); if (match.is1v1() && !winnerTeam.isEmpty() && !loserTeam.isEmpty()) { match.setWinner(winnerTeam.get(0)); match.setLoser(loserTeam.get(0)); } storePostMatchInventories(match); processMatchResults(match); Bukkit.getScheduler().runTaskLater(plugin, () -> finalizeMatch(match), plugin.getConfigManager().getMatchEndDelay() * 20L); } private void processMatchResults(DuelMatch match) { if (match.getWinner() == null || match.getLoser() == null) return; Player winner = Bukkit.getPlayer(match.getWinner()); Player loser = Bukkit.getPlayer(match.getLoser()); PlayerStats winnerStats = plugin.getStatsManager().getStats(match.getWinner()); PlayerStats loserStats = plugin.getStatsManager().getStats(match.getLoser()); if (winnerStats != null) { winnerStats.addWin(match.getKit().getId()); winnerStats.addKill(); } if (loserStats != null) { loserStats.addLoss(match.getKit().getId()); loserStats.addDeath(); } if (match.isRanked() && winnerStats != null && loserStats != null) { int eloChange = plugin.getStatsManager().calculateEloChange( winnerStats.getElo(), loserStats.getElo(), plugin.getConfigManager().getEloKFactor()); match.setEloChange(eloChange); winnerStats.setElo(winnerStats.getElo() + eloChange); loserStats.setElo(Math.max(100, loserStats.getElo() - eloChange)); winnerStats.setKitElo(match.getKit().getId(), winnerStats.getKitElo(match.getKit().getId()) + eloChange); loserStats.setKitElo(match.getKit().getId(), Math.max(100, loserStats.getKitElo(match.getKit().getId()) - eloChange)); if (winner != null) { winner.sendMessage(plugin.getConfigManager().getMessage("match.elo-change-gain", Map.of("amount", String.valueOf(eloChange), "kit", match.getKit().getDisplayName()))); } if (loser != null) { loser.sendMessage(plugin.getConfigManager().getMessage("match.elo-change-loss", Map.of("amount", String.valueOf(eloChange), "kit", match.getKit().getDisplayName()))); } } int pointsReward = plugin.getConfigManager().getWinPointsReward(); if (winnerStats != null) { winnerStats.setPvpPoints(winnerStats.getPvpPoints() + pointsReward); if (winner != null) { winner.sendMessage(plugin.getConfigManager().getMessage("points.win-reward", Map.of("amount", String.valueOf(pointsReward)))); } } if (winnerStats != null) plugin.getStatsManager().saveStats(winnerStats); if (loserStats != null) plugin.getStatsManager().saveStats(loserStats); plugin.getDatabaseManager().saveMatchHistory( match.getWinner(), match.getLoser(), match.getKit().getId(), match.getDurationSeconds(), match.isRanked(), match.getEloChange()); if (winner != null) { winner.sendMessage(plugin.getConfigManager().getMessage("match.end-win")); winner.showTitle(Title.title( miniMessage.deserialize("VICTORY!"), miniMessage.deserialize("You won the duel!"), Title.Times.times(java.time.Duration.ofMillis(500), java.time.Duration.ofSeconds(3), java.time.Duration.ofMillis(500)) )); if (plugin.getConfigManager().isFireworksEnabled()) { spawnWinnerFireworks(winner); } } if (loser != null) { loser.sendMessage(plugin.getConfigManager().getMessage("match.end-loss")); loser.showTitle(Title.title( miniMessage.deserialize("DEFEAT!"), miniMessage.deserialize("Better luck next time!"), Title.Times.times(java.time.Duration.ofMillis(500), java.time.Duration.ofSeconds(3), java.time.Duration.ofMillis(500)) )); } if (match.is1v1()) { String winnerName = winner != null ? winner.getName() : "Unknown"; String loserName = loser != null ? loser.getName() : "Unknown"; Component announcement = plugin.getConfigManager().getMessage("match.winner-announcement", Map.of("winner", winnerName, "loser", loserName, "kit", match.getKit().getDisplayName())); Bukkit.broadcast(announcement); } processBet(match); offerRematch(match); } private void processBet(DuelMatch match) { if (!plugin.getConfigManager().isBettingEnabled()) return; DuelMatch.BetData bet = match.getBetData(); if (bet == null || !bet.bothAccepted()) return; if (match.getWinner() == null) return; Player winner = Bukkit.getPlayer(match.getWinner()); if (winner == null) return; double totalMoney = bet.getMoneyBet1() + bet.getMoneyBet2(); if (totalMoney > 0 && plugin.getIntegrationManager().isVaultEnabled()) { plugin.getIntegrationManager().getEconomy().depositPlayer(winner, totalMoney); } if (bet.getItemBet1() != null) { for (ItemStack item : bet.getItemBet1()) { if (item != null) winner.getInventory().addItem(item); } } if (bet.getItemBet2() != null) { for (ItemStack item : bet.getItemBet2()) { if (item != null) winner.getInventory().addItem(item); } } } private void offerRematch(DuelMatch match) { if (!match.is1v1() || match.getWinner() == null || match.getLoser() == null) return; Player winner = Bukkit.getPlayer(match.getWinner()); Player loser = Bukkit.getPlayer(match.getLoser()); if (winner == null || loser == null) return; Component rematchBtn = plugin.getConfigManager().getMessageNoPrefix("match.rematch-button"); winner.sendMessage(rematchBtn); loser.sendMessage(rematchBtn); rematchRequests.put(match.getWinner(), match.getLoser()); rematchRequests.put(match.getLoser(), match.getWinner()); Bukkit.getScheduler().runTaskLater(plugin, () -> { rematchRequests.remove(match.getWinner()); rematchRequests.remove(match.getLoser()); }, 30 * 20L); } private void finalizeMatch(DuelMatch match) { match.setState(MatchState.FINISHED); for (UUID uuid : match.getAllParticipants()) { Player player = Bukkit.getPlayer(uuid); if (player == null) continue; restoreInventory(player, match); teleportToLobby(player); applyKitSettings(player, match.getKit(), false); plugin.getScoreboardManager().setLobbyScoreboard(player); } for (UUID uuid : new HashSet<>(match.getSpectators())) { Player spectator = Bukkit.getPlayer(uuid); if (spectator == null) continue; spectator.sendMessage(plugin.getConfigManager().getMessage("spectate.match-ended")); teleportToLobby(spectator); spectatorMatchMap.remove(uuid); plugin.getScoreboardManager().setLobbyScoreboard(spectator); } if (plugin.getConfigManager().isEntityCleanupEnabled() && match.getArena().getSpawn1() != null) { cleanupArenaEntities(match.getArena()); } match.getArena().setInUse(false); plugin.getArenaManager().regenerateArena(match.getArena()); for (UUID uuid : match.getAllParticipants()) { playerMatchMap.remove(uuid); } activeMatches.remove(match.getMatchId()); } private void cleanupArenaEntities(Arena arena) { Location spawn1 = arena.getSpawn1(); if (spawn1 == null || spawn1.getWorld() == null) return; World world = spawn1.getWorld(); world.getEntities().forEach(entity -> { if (entity instanceof Item || entity instanceof Arrow || entity instanceof ThrownPotion || entity instanceof AreaEffectCloud || entity instanceof ExperienceOrb) { if (entity.getLocation().distance(spawn1) < 100) { entity.remove(); } } }); } private void spawnWinnerFireworks(Player player) { int count = plugin.getConfigManager().getFireworksCount(); for (int i = 0; i < count; i++) { final int delay = i * 10; Bukkit.getScheduler().runTaskLater(plugin, () -> { Firework fw = player.getWorld().spawn(player.getLocation(), Firework.class); FireworkMeta meta = fw.getFireworkMeta(); meta.setPower(1); meta.addEffect(FireworkEffect.builder() .with(FireworkEffect.Type.BALL_LARGE) .withColor(Color.GOLD, Color.YELLOW) .withFade(Color.WHITE) .withTrail() .withFlicker() .build()); fw.setFireworkMeta(meta); }, delay); } } private void saveAndClearInventory(Player player, DuelMatch match) { match.getSavedInventories().put(player.getUniqueId(), player.getInventory().getContents().clone()); match.getSavedArmor().put(player.getUniqueId(), player.getInventory().getArmorContents().clone()); match.getSavedHealth().put(player.getUniqueId(), player.getHealth()); player.getInventory().clear(); player.setHealth(player.getAttribute(org.bukkit.attribute.Attribute.GENERIC_MAX_HEALTH).getValue()); player.setFoodLevel(20); player.setExp(0); player.setLevel(0); player.getActivePotionEffects().forEach(effect -> player.removePotionEffect(effect.getType())); } private void storePostMatchInventories(DuelMatch match) { for (UUID uuid : match.getAllParticipants()) { Player player = Bukkit.getPlayer(uuid); if (player == null) continue; match.getPostMatchInventories().put(uuid, player.getInventory().getContents().clone()); match.getPostMatchArmor().put(uuid, player.getInventory().getArmorContents().clone()); } } private void restoreInventory(Player player, DuelMatch match) { player.getInventory().clear(); ItemStack[] contents = match.getSavedInventories().get(player.getUniqueId()); ItemStack[] armor = match.getSavedArmor().get(player.getUniqueId()); if (contents != null) player.getInventory().setContents(contents); if (armor != null) player.getInventory().setArmorContents(armor); Double health = match.getSavedHealth().get(player.getUniqueId()); if (health != null) player.setHealth(Math.min(health, player.getAttribute(org.bukkit.attribute.Attribute.GENERIC_MAX_HEALTH).getValue())); player.getActivePotionEffects().forEach(effect -> player.removePotionEffect(effect.getType())); player.updateInventory(); } private void teleportToArena(DuelMatch match) { List team1 = match.getTeam1(); List team2 = match.getTeam2(); for (UUID uuid : team1) { Player player = Bukkit.getPlayer(uuid); if (player != null && match.getArena().getSpawn1() != null) { player.teleport(match.getArena().getSpawn1()); } } for (UUID uuid : team2) { Player player = Bukkit.getPlayer(uuid); if (player != null && match.getArena().getSpawn2() != null) { player.teleport(match.getArena().getSpawn2()); } } } private void teleportToLobby(Player player) { Location lobby = Bukkit.getWorlds().get(0).getSpawnLocation(); player.teleport(lobby); } private void applyKitSettings(Player player, DuelKit kit, boolean pvpEnabled) { DuelKit.KitSettings settings = kit.getSettings(); if (!settings.isNaturalRegen()) { player.setHealthScaled(false); } if (!settings.isHunger()) { player.setFoodLevel(20); player.setSaturation(20f); } player.setAllowFlight(false); player.setFlying(false); } public void addSpectator(Player spectator, DuelMatch match) { match.getSpectators().add(spectator.getUniqueId()); spectatorMatchMap.put(spectator.getUniqueId(), match.getMatchId()); spectator.setGameMode(GameMode.SPECTATOR); if (match.getArena().getSpawn1() != null) { spectator.teleport(match.getArena().getSpawn1()); } for (UUID uuid : match.getAllParticipants()) { Player participant = Bukkit.getPlayer(uuid); if (participant != null) { participant.sendMessage(plugin.getConfigManager().getMessage("match.spectators-count", Map.of("count", String.valueOf(match.getSpectators().size())))); } } } public void removeSpectator(Player spectator) { UUID matchId = spectatorMatchMap.remove(spectator.getUniqueId()); if (matchId == null) return; DuelMatch match = activeMatches.get(matchId); if (match != null) match.getSpectators().remove(spectator.getUniqueId()); spectator.setGameMode(GameMode.SURVIVAL); teleportToLobby(spectator); } public DuelMatch getMatch(UUID matchId) { return activeMatches.get(matchId); } public DuelMatch getPlayerMatch(UUID playerUuid) { UUID matchId = playerMatchMap.get(playerUuid); if (matchId == null) return null; return activeMatches.get(matchId); } public DuelMatch getSpectatorMatch(UUID spectatorUuid) { UUID matchId = spectatorMatchMap.get(spectatorUuid); if (matchId == null) return null; return activeMatches.get(matchId); } public boolean isInMatch(UUID uuid) { return playerMatchMap.containsKey(uuid); } public boolean isSpectating(UUID uuid) { return spectatorMatchMap.containsKey(uuid); } public Collection getActiveMatches() { return activeMatches.values(); } public int getActiveMatchCount() { return activeMatches.size(); } public UUID getRematchTarget(UUID uuid) { return rematchRequests.get(uuid); } public void clearRematch(UUID uuid) { UUID other = rematchRequests.remove(uuid); if (other != null) rematchRequests.remove(other); } public void handleDisconnect(Player player) { DuelMatch match = getPlayerMatch(player.getUniqueId()); if (match == null) return; if (!plugin.getConfigManager().isDisconnectLoss()) return; if (match.getState() != MatchState.ACTIVE && match.getState() != MatchState.COUNTDOWN) return; List opponentTeam = match.getOpponentTeam(player.getUniqueId()); List playerTeam = match.isTeam1(player.getUniqueId()) ? match.getTeam1() : match.getTeam2(); Bukkit.broadcast(plugin.getConfigManager().getMessage("match.disconnect-loss", Map.of("player", player.getName()))); endMatch(match, opponentTeam, playerTeam); } public void endAllMatches() { for (DuelMatch match : new ArrayList<>(activeMatches.values())) { finalizeMatch(match); } } }