package com.bedwarselite.arena; import com.bedwarselite.BedWarsElite; import com.bedwarselite.cosmetics.CosmeticType; import com.bedwarselite.generator.Generator; import com.bedwarselite.player.BedWarsPlayer; import com.bedwarselite.util.ColorUtil; import com.bedwarselite.util.LocationUtil; import com.bedwarselite.util.ScoreboardUtil; import lombok.Getter; import lombok.Setter; import org.bukkit.*; import org.bukkit.entity.EntityType; import org.bukkit.entity.Firework; import org.bukkit.entity.Player; import org.bukkit.inventory.meta.FireworkMeta; import org.bukkit.potion.PotionEffect; import org.bukkit.potion.PotionEffectType; import org.bukkit.scheduler.BukkitRunnable; import org.bukkit.scheduler.BukkitTask; import org.bukkit.scoreboard.Scoreboard; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; /** * Core game state class for a single BedWars arena. * Manages the lifecycle from waiting → active → resetting. */ @Getter @Setter public class Arena { // ── Identity ────────────────────────────────────────────── private final String id; private String displayName; private String templateWorldName; // e.g., "bwe_alpine_template" private String activeWorldName; // e.g., "bwe_alpine_active" private GameMode gameMode; private int minPlayers; private String serializedWaitingSpawn; // ── State ───────────────────────────────────────────────── private ArenaState state; private final Map teams = new LinkedHashMap<>(); private final List generators = new ArrayList<>(); private final Map activePlayers = new ConcurrentHashMap<>(); private final Map waitingPlayers = new ConcurrentHashMap<>(); // ── Game Runtime ────────────────────────────────────────── private int gameTimeSeconds; private BukkitTask gameTick; private Scoreboard gameScoreboard; // ── Dependencies ────────────────────────────────────────── private final transient BedWarsElite plugin; public Arena(String id, String displayName, GameMode gameMode, BedWarsElite plugin) { this.id = id; this.displayName = displayName; this.gameMode = gameMode; this.plugin = plugin; this.state = ArenaState.SETUP; this.templateWorldName = "bwe_" + id + "_template"; this.activeWorldName = "bwe_" + id + "_active"; this.minPlayers = 2; // Create teams based on game mode for (int i = 0; i < gameMode.getMaxTeams(); i++) { TeamColor color = TeamColor.values()[i]; teams.put(color, new Team(color)); } } // ── Player Management ───────────────────────────────────── public boolean addWaitingPlayer(Player player) { BedWarsPlayer bwPlayer = plugin.getPlayerManager().getOrCreate(player); waitingPlayers.put(player.getUniqueId(), bwPlayer); bwPlayer.setArena(this); Location waitSpawn = getWaitingSpawn(); if (waitSpawn != null) player.teleport(waitSpawn); player.setGameMode(org.bukkit.GameMode.ADVENTURE); clearInventoryAndEffects(player); broadcastToWaiting("game.join", "arena", displayName, "player", player.getName()); checkCountdownStart(); return true; } public void removeWaitingPlayer(Player player) { BedWarsPlayer bwp = waitingPlayers.remove(player.getUniqueId()); if (bwp != null) { bwp.setArena(null); bwp.setTeam(null); } if (state == ArenaState.STARTING && waitingPlayers.size() < minPlayers) { plugin.getLobbyManager().cancelCountdown(this); } } private void checkCountdownStart() { if (state == ArenaState.WAITING && waitingPlayers.size() >= minPlayers) { state = ArenaState.STARTING; plugin.getLobbyManager().startCountdown(this); } } // ── Game Start ──────────────────────────────────────────── public void startGame() { if (state == ArenaState.ACTIVE) return; state = ArenaState.ACTIVE; gameTimeSeconds = 0; // Ensure active world is loaded if (Bukkit.getWorld(activeWorldName) == null) { plugin.getWorldResetter().cloneForFirstUse(this).thenAccept(world -> { Bukkit.getScheduler().runTask(plugin, () -> initializeGame()); }); } else { initializeGame(); } } private void initializeGame() { // Assign players to teams (auto-balance) List players = new ArrayList<>(waitingPlayers.values()); Collections.shuffle(players); List teamList = new ArrayList<>(teams.values()); activePlayers.clear(); for (int i = 0; i < players.size(); i++) { BedWarsPlayer bwp = players.get(i); Team team = teamList.get(i % teamList.size()); team.addMember(bwp); bwp.setAlive(true); activePlayers.put(bwp.getPlayer().getUniqueId(), bwp); } waitingPlayers.clear(); // Build scoreboard with team colors for nametags gameScoreboard = Bukkit.getScoreboardManager().getNewScoreboard(); for (Team team : teams.values()) { org.bukkit.scoreboard.Team sbTeam = gameScoreboard.registerNewTeam(team.getColor().name()); sbTeam.setColor(team.getColor().getChatColor()); sbTeam.setPrefix(team.getColor().getChatColor().toString()); sbTeam.setAllowFriendlyFire(false); team.setScoreboardTeam(sbTeam); } // Spawn and equip players for (BedWarsPlayer bwp : activePlayers.values()) { Player p = bwp.getPlayer(); Location spawn = bwp.getTeam() != null ? LocationUtil.deserializeInWorld(bwp.getTeam().getSerializedSpawnLocation(), activeWorldName) : Bukkit.getWorld(activeWorldName).getSpawnLocation(); if (spawn != null) p.teleport(spawn); p.setGameMode(org.bukkit.GameMode.SURVIVAL); clearInventoryAndEffects(p); giveStartingKit(bwp); p.setScoreboard(gameScoreboard); // Add to scoreboard team if (bwp.getTeam() != null) { org.bukkit.scoreboard.Team sbTeam = bwp.getTeam().getScoreboardTeam(); if (sbTeam != null) sbTeam.addEntry(p.getName()); } } // Start generators plugin.getGeneratorManager().startGenerators(this); // Start the game tick startGameTick(); broadcastToGame(ColorUtil.color("&aThe game has started! &eGood luck!")); } private void giveStartingKit(BedWarsPlayer bwp) { Player p = bwp.getPlayer(); // Wooden sword (always) p.getInventory().addItem(new com.bedwarselite.util.ItemBuilder(Material.WOODEN_SWORD) .unbreakable(true).hideAttributes().build()); // Pickaxe p.getInventory().addItem(new com.bedwarselite.util.ItemBuilder(Material.WOODEN_PICKAXE) .unbreakable(true).hideAttributes().build()); // 16 team-colored wool if (bwp.getTeam() != null) { p.getInventory().addItem(new com.bedwarselite.util.ItemBuilder(bwp.getTeam().getColor().getWoolMaterial()) .amount(16).name(bwp.getTeam().getColor().coloredName() + " Wool").build()); } // Compass p.getInventory().setItem(8, new com.bedwarselite.util.ItemBuilder(Material.COMPASS) .name("&eTarget Tracker").lore("&7Points to the nearest enemy.").build()); p.setFoodLevel(20); p.setHealth(20); plugin.getUpgradeManager().applyUpgrades(bwp); } // ── Game Tick ───────────────────────────────────────────── private void startGameTick() { gameTick = new BukkitRunnable() { int compassTick = 0; @Override public void run() { if (state != ArenaState.ACTIVE) { cancel(); return; } gameTimeSeconds++; compassTick++; // Check void deaths for (BedWarsPlayer bwp : activePlayers.values()) { if (!bwp.isAlive() || bwp.isSpectating()) continue; Player p = bwp.getPlayer(); if (p.getLocation().getY() < plugin.getConfigManager().getVoidLevel()) { p.setLastDamageCause(null); p.damage(1000.0); } } // Apply heal pool for teams that have it for (Team team : teams.values()) { if (team.getUpgradeLevel(com.bedwarselite.upgrade.UpgradeType.HEAL_POOL) > 0) { Location bedLoc = LocationUtil.deserializeInWorld(team.getSerializedBedLocation(), activeWorldName); if (bedLoc == null) continue; for (BedWarsPlayer bwp : team.getMembers()) { if (bwp.isAlive() && bwp.getPlayer().getLocation().distanceSquared(bedLoc) < 225) { bwp.getPlayer().addPotionEffect( new PotionEffect(PotionEffectType.REGENERATION, 60, 0, true, false)); } } } } // Update compass every N ticks if (compassTick >= plugin.getConfigManager().getCompassUpdateInterval()) { compassTick = 0; plugin.getCompassTracker().updateAll(Arena.this); } // Update scoreboards every second updateScoreboards(); } }.runTaskTimer(plugin, 20L, 20L); } // ── Bed Breaking ────────────────────────────────────────── /** * Handles a bed being broken. * * @param bedTeam The team whose bed was broken. * @param breaker The player who broke it (may be null). */ public void breakBed(TeamColor bedTeam, Player breaker) { Team team = teams.get(bedTeam); if (team == null || !team.isBedAlive()) return; team.setBedAlive(false); // Message to the broken team for (BedWarsPlayer bwp : team.getMembers()) { plugin.getMessageManager().send(bwp.getPlayer(), "bed.your-broken", "player", breaker != null ? breaker.getName() : "unknown"); bwp.getPlayer().playSound(bwp.getPlayer().getLocation(), Sound.ENTITY_WITHER_SPAWN, 1f, 1f); } // Message to all other players for (BedWarsPlayer bwp : activePlayers.values()) { if (bwp.getTeam() != null && bwp.getTeam().getColor() != bedTeam) { plugin.getMessageManager().send(bwp.getPlayer(), "bed.enemy-broken", "team", bedTeam.coloredName(), "player", breaker != null ? breaker.getName() : "unknown"); } } // Trigger bed break cosmetic for the breaker if (breaker != null) { plugin.getCosmeticManager().getEquipped(breaker.getUniqueId(), CosmeticType.BED_BREAK_EFFECT) .ifPresent(cosmetic -> triggerBedBreakEffect(cosmetic.getId(), breaker)); BedWarsPlayer bwBreaker = plugin.getPlayerManager().getBWPlayer(breaker).orElse(null); if (bwBreaker != null) bwBreaker.addBedBreak(); // Currency reward plugin.getCurrencyManager().addBalance(breaker.getUniqueId(), plugin.getConfigManager().getBedBreakReward()); } } private void triggerBedBreakEffect(String effectId, Player player) { Location loc = player.getLocation(); World world = player.getWorld(); switch (effectId) { case "bed_explosion" -> world.spawnParticle(Particle.EXPLOSION, loc, 10, 1, 1, 1, 0.1); case "bed_flames" -> world.spawnParticle(Particle.FLAME, loc, 50, 0.5, 0.5, 0.5, 0.05); case "bed_enderdragon" -> world.spawnParticle(Particle.DRAGON_BREATH, loc, 50, 1, 1, 1, 0.05); } } // ── Player Elimination ──────────────────────────────────── /** * Called when a player dies with their bed destroyed — eliminates them permanently. */ public void eliminatePlayer(BedWarsPlayer victim, Player killer) { victim.setAlive(false); victim.setSpectating(true); // Final kill reward if (killer != null) { BedWarsPlayer bwKiller = plugin.getPlayerManager().getBWPlayer(killer).orElse(null); if (bwKiller != null) { bwKiller.addFinalKill(); plugin.getCurrencyManager().addBalance(killer.getUniqueId(), plugin.getConfigManager().getFinalKillReward()); triggerKillEffect(bwKiller); } } // Announce broadcastToGame(plugin.getMessageManager().get("kill.final-kill", Map.of("killer", killer != null ? killer.getName() : "void", "victim", victim.getPlayer().getName()))); // Set to spectator mode (delayed to avoid death screen flicker) Bukkit.getScheduler().runTaskLater(plugin, () -> { Player p = victim.getPlayer(); if (!p.isOnline()) return; p.setGameMode(org.bukkit.GameMode.SPECTATOR); p.addPotionEffect(new PotionEffect(PotionEffectType.NIGHT_VISION, Integer.MAX_VALUE, 0, true, false)); plugin.getMessageManager().send(p, "spectator.eliminated"); }, 20L); checkWinCondition(); } private void triggerKillEffect(BedWarsPlayer bwKiller) { plugin.getCosmeticManager().getEquipped(bwKiller.getPlayer().getUniqueId(), CosmeticType.KILL_EFFECT) .ifPresent(cosmetic -> { Location loc = bwKiller.getPlayer().getLocation(); World world = bwKiller.getPlayer().getWorld(); switch (cosmetic.getId()) { case "kill_flames_effect" -> world.spawnParticle(Particle.FLAME, loc, 30, 0.3, 0.3, 0.3, 0.05); case "kill_lightning_effect" -> world.strikeLightningEffect(loc); } }); } // ── Win Condition ───────────────────────────────────────── public void checkWinCondition() { if (state != ArenaState.ACTIVE) return; List aliveTeams = teams.values().stream() .filter(t -> !t.isEliminated()) .collect(Collectors.toList()); if (aliveTeams.size() <= 1) { Team winner = aliveTeams.isEmpty() ? null : aliveTeams.get(0); endGame(winner); } } private void endGame(Team winner) { if (state == ArenaState.RESETTING) return; state = ArenaState.RESETTING; if (gameTick != null) gameTick.cancel(); plugin.getGeneratorManager().stopGenerators(this); String teamName = winner != null ? winner.getColor().coloredName() : "&7nobody"; broadcastToGame(plugin.getMessageManager().get("game.end", Map.of("team", teamName))); // Award winners if (winner != null) { for (BedWarsPlayer bwp : winner.getMembers()) { plugin.getCurrencyManager().addBalance(bwp.getPlayer().getUniqueId(), plugin.getConfigManager().getWinReward()); plugin.getPlayerManager().mergeSessionStats(bwp.getPlayer().getUniqueId(), bwp.getSessionStats(), true); triggerWinEffect(bwp); } } // Merge stats for losers for (BedWarsPlayer bwp : activePlayers.values()) { if (winner == null || bwp.getTeam() != winner) { plugin.getPlayerManager().mergeSessionStats(bwp.getPlayer().getUniqueId(), bwp.getSessionStats(), false); } } // Delay then reset Bukkit.getScheduler().runTaskLater(plugin, this::beginReset, plugin.getConfigManager().getEndDelay() * 20L); } private void triggerWinEffect(BedWarsPlayer bwp) { plugin.getCosmeticManager().getEquipped(bwp.getPlayer().getUniqueId(), CosmeticType.WIN_EFFECT) .ifPresent(cosmetic -> { Location loc = bwp.getPlayer().getLocation(); World world = bwp.getPlayer().getWorld(); switch (cosmetic.getId()) { case "win_fireworks" -> { for (int i = 0; i < 5; i++) { final int delay = i * 10; Bukkit.getScheduler().runTaskLater(plugin, () -> launchFirework(loc), delay); } } case "win_lightning" -> world.strikeLightningEffect(loc); case "win_dragon" -> world.spawnParticle(Particle.DRAGON_BREATH, loc, 200, 2, 2, 2, 0.1); } }); } private void launchFirework(Location loc) { Firework fw = (Firework) loc.getWorld().spawnEntity(loc, EntityType.FIREWORK_ROCKET); FireworkMeta meta = fw.getFireworkMeta(); meta.addEffect(FireworkEffect.builder() .withColor(Color.RED, Color.YELLOW, Color.BLUE) .with(FireworkEffect.Type.BURST) .withFlicker() .build()); meta.setPower(1); fw.setFireworkMeta(meta); } private void beginReset() { // Teleport all players to lobby Location lobby = plugin.getConfigManager().getLobbySpawn(); for (BedWarsPlayer bwp : activePlayers.values()) { Player p = bwp.getPlayer(); if (p.isOnline()) { p.setGameMode(org.bukkit.GameMode.ADVENTURE); p.removePotionEffect(PotionEffectType.NIGHT_VISION); clearInventoryAndEffects(p); if (lobby != null) p.teleport(lobby); p.setScoreboard(Bukkit.getScoreboardManager().getMainScoreboard()); } bwp.resetGameState(); } for (Team team : teams.values()) { team.setBedAlive(true); team.getMembers().clear(); team.getUpgrades().clear(); } activePlayers.clear(); // Reset world plugin.getWorldResetter().resetArena(this, world -> { state = ArenaState.WAITING; plugin.getLogger().info("Arena '" + id + "' reset and ready."); }); } // ── Scoreboard ──────────────────────────────────────────── private void updateScoreboards() { for (BedWarsPlayer bwp : activePlayers.values()) { Player p = bwp.getPlayer(); List lines = buildScoreboardLines(bwp); Scoreboard sb = ScoreboardUtil.createSidebar( plugin.getConfigManager().getScoreboardTitle(), lines); p.setScoreboard(sb); } } private List buildScoreboardLines(BedWarsPlayer bwp) { List lines = new ArrayList<>(); lines.add("&r"); lines.add("&fKills: &e" + bwp.getKills()); lines.add("&fFinal Kills: &c" + bwp.getFinalKills()); lines.add("&r "); for (Team team : teams.values()) { String bedStatus = team.isBedAlive() ? "&a✔" : "&7✗"; String alive = " &7(" + team.getAliveMemberCount() + ")"; lines.add(team.getColor().getChatColor() + "❤ " + team.getColor().getDisplayName() + " " + bedStatus + alive); } lines.add(" &r"); int mins = gameTimeSeconds / 60; int secs = gameTimeSeconds % 60; lines.add("&fTime: &e" + String.format("%02d:%02d", mins, secs)); lines.add(" &r"); lines.add("&7bwe.yourserver.net"); return lines; } // ── Utilities ───────────────────────────────────────────── public Team getTeam(TeamColor color) { return teams.get(color); } public Team getPlayerTeam(Player player) { for (Team team : teams.values()) { for (BedWarsPlayer bwp : team.getMembers()) { if (bwp.getPlayer().getUniqueId().equals(player.getUniqueId())) return team; } } return null; } public BedWarsPlayer getActiveBWPlayer(UUID uuid) { return activePlayers.get(uuid); } public boolean isActiveGame() { return state == ArenaState.ACTIVE; } public int getPlayerCount() { return waitingPlayers.size() + activePlayers.size(); } public int getMaxPlayers() { return gameMode.getMaxPlayers(); } public boolean isBedWorld(World world) { return world != null && (world.getName().equals(activeWorldName) || world.getName().equals(templateWorldName)); } public Location getWaitingSpawn() { return serializedWaitingSpawn != null ? LocationUtil.deserialize(serializedWaitingSpawn) : null; } private void clearInventoryAndEffects(Player player) { player.getInventory().clear(); player.getActivePotionEffects().forEach(e -> player.removePotionEffect(e.getType())); player.setExp(0); player.setLevel(0); player.setFoodLevel(20); player.setSaturation(20); player.setHealth(20); } private void broadcastToGame(String message) { for (BedWarsPlayer bwp : activePlayers.values()) { bwp.getPlayer().sendMessage(message); } } private void broadcastToWaiting(String messagePath, String... pairs) { for (BedWarsPlayer bwp : waitingPlayers.values()) { plugin.getMessageManager().send(bwp.getPlayer(), messagePath, pairs); } } }