package com.deadlyxplayz.deadlyfates.managers; import com.cryptomorin.xseries.XPotion; import com.cryptomorin.xseries.XSound; import com.deadlyxplayz.deadlyfates.DeadlyFates; import com.deadlyxplayz.deadlyfates.model.PlayerData; import com.deadlyxplayz.deadlyfates.model.PowerType; import com.deadlyxplayz.deadlyfates.util.ItemUtil; import com.deadlyxplayz.deadlyfates.util.ParticleUtil; import org.bukkit.*; import org.bukkit.attribute.Attribute; import org.bukkit.attribute.AttributeInstance; import org.bukkit.block.Block; import org.bukkit.entity.*; import org.bukkit.inventory.ItemStack; import org.bukkit.potion.PotionEffect; import org.bukkit.potion.PotionEffectType; import org.bukkit.scheduler.BukkitRunnable; import java.util.*; import java.util.concurrent.ConcurrentHashMap; public class PowerManager { private final DeadlyFates plugin; // UUID -> PowerType -> cooldown expiry millis private final Map> cooldowns = new ConcurrentHashMap<>(); // Players currently invisible (Phantom Stealth active) private final Set phantomActive = new HashSet<>(); // Stored armor/held items during Phantom Stealth private final Map hiddenArmor = new HashMap<>(); private final Map hiddenOffhand = new HashMap<>(); // Players currently flying (Sky Sovereign active) private final Set skyActive = new HashSet<>(); // Players currently invulnerable (Titan Juggernaut active) private final Set titanActive = new HashSet<>(); // Tracked hellfire projectiles private final Set hellfireProjectiles = new HashSet<>(); public PowerManager(DeadlyFates plugin) { this.plugin = plugin; } public boolean isOnCooldown(UUID uuid, PowerType type) { Map map = cooldowns.get(uuid); if (map == null) return false; Long expiry = map.get(type); return expiry != null && expiry > System.currentTimeMillis(); } public long getRemainingCooldownSeconds(UUID uuid, PowerType type) { Map map = cooldowns.get(uuid); if (map == null) return 0; Long expiry = map.get(type); if (expiry == null || expiry <= System.currentTimeMillis()) return 0; return (expiry - System.currentTimeMillis()) / 1000L; } public void setCooldown(UUID uuid, PowerType type, int seconds) { cooldowns.computeIfAbsent(uuid, k -> new ConcurrentHashMap<>()) .put(type, System.currentTimeMillis() + (seconds * 1000L)); } public void activatePower(Player player, PowerType type) { PlayerData data = plugin.getPlayerDataManager().getPlayerData(player.getUniqueId()); int cooldownSeconds = data.getEffectiveCooldown(type); if (isOnCooldown(player.getUniqueId(), type)) { long remaining = getRemainingCooldownSeconds(player.getUniqueId(), type); player.sendMessage(ItemUtil.c("&cAbility on cooldown for &e" + remaining + "s&c!")); return; } setCooldown(player.getUniqueId(), type, cooldownSeconds); int durationTicks = (int)(100 * data.getActiveDurationMultiplier()); switch (type) { case VOID_MONARCH -> activateVoidMonarch(player); case HELLFIRE_OVERLORD -> activateHellfire(player); case GAIA_GUARDIAN -> activateGaia(player); case PHANTOM_STEALTH -> activatePhantom(player, durationTicks); case SKY_SOVEREIGN -> activateSky(player, durationTicks); case BLOOD_VAMPIRE -> activateBloodVampire(player); case THUNDER_GOD -> activateThunderGod(player); case TITAN_JUGGERNAUT -> activateTitan(player, durationTicks); case SONIC_ASSASSIN -> activateSonicAssassin(player); case FROST_WARDEN -> activateFrostWarden(player); } } // ─── VOID MONARCH ────────────────────────────────────────────────────────── private void activateVoidMonarch(Player player) { Location origin = player.getLocation().add(0, 1, 0); List nearby = new ArrayList<>(player.getNearbyEntities(8, 8, 8)); XSound.matchXSound("ENTITY_ENDERMAN_TELEPORT").ifPresent(s -> s.play(player)); // Sphere visual burst ParticleUtil.spawnSphere(origin, Particle.PORTAL, 2.5, 80); for (Entity entity : nearby) { if (entity.equals(player)) continue; if (!(entity instanceof LivingEntity)) continue; org.bukkit.util.Vector dir = origin.toVector().subtract(entity.getLocation().toVector()).normalize(); entity.setVelocity(dir.multiply(2.5)); } player.sendMessage(ItemUtil.c("&5Void Monarch: &7Gravitational pull activated!")); } // ─── HELLFIRE OVERLORD ───────────────────────────────────────────────────── private void activateHellfire(Player player) { XSound.matchXSound("ENTITY_GHAST_SHOOT").ifPresent(s -> s.play(player)); Fireball fb = player.launchProjectile(Fireball.class); fb.setIsIncendiary(false); fb.setYield(0f); hellfireProjectiles.add(fb.getUniqueId()); player.sendMessage(ItemUtil.c("&cHellfire Overlord: &7Fireball launched!")); } public void hellfireImpact(Location impactLoc, Entity hitEntity) { if (hitEntity instanceof LivingEntity le) { le.damage(6.0); le.setFireTicks(100); } // Set fire trap on ground for (int x = -2; x <= 2; x++) { for (int z = -2; z <= 2; z++) { if (Math.sqrt(x * x + z * z) <= 2.2) { Block support = impactLoc.clone().add(x, -1, z).getBlock(); Block fireBlock = impactLoc.clone().add(x, 0, z).getBlock(); if (support.getType().isSolid() && fireBlock.getType() == Material.AIR) { fireBlock.setType(Material.FIRE); } } } } // Growing FLAME circle new BukkitRunnable() { double radius = 0.5; int step = 0; @Override public void run() { if (step++ >= 12) { cancel(); return; } int pts = Math.max(8, (int)(radius * 10)); ParticleUtil.spawnCircle(impactLoc.clone().add(0, 0.1, 0), Particle.FLAME, radius, pts); radius += 0.35; } }.runTaskTimer(plugin, 0L, 2L); } public boolean isHellfireProjectile(UUID uuid) { return hellfireProjectiles.contains(uuid); } public void removeHellfireProjectile(UUID uuid) { hellfireProjectiles.remove(uuid); } // ─── GAIA GUARDIAN ───────────────────────────────────────────────────────── private void activateGaia(Player player) { XSound.matchXSound("BLOCK_GRASS_BREAK").ifPresent(s -> s.play(player)); Location center = player.getLocation(); // Summon Evoker Fangs in a circle int fangCount = 12; for (int i = 0; i < fangCount; i++) { double angle = (2 * Math.PI / fangCount) * i; double x = Math.cos(angle) * 3.0; double z = Math.sin(angle) * 3.0; center.getWorld().spawn(center.clone().add(x, 0, z), EvokerFangs.class, fang -> fang.setOwner(player)); } // Double helix of HAPPY_VILLAGER new BukkitRunnable() { double angle = 0; int count = 0; @Override public void run() { if (count++ >= 40 || !player.isOnline()) { cancel(); return; } double height = count * 0.08; ParticleUtil.spawnHelix(player.getLocation(), Particle.HAPPY_VILLAGER, 1.5, angle, height - 1.5); angle += 0.25; } }.runTaskTimer(plugin, 0L, 1L); player.sendMessage(ItemUtil.c("&aGaia Guardian: &7The earth rises to defend you!")); } // ─── PHANTOM STEALTH ─────────────────────────────────────────────────────── private void activatePhantom(Player player, int durationTicks) { if (phantomActive.contains(player.getUniqueId())) return; XSound.matchXSound("ENTITY_ILLUSIONER_PREPARE_BLINDNESS").ifPresent(s -> s.play(player)); phantomActive.add(player.getUniqueId()); // Dense smoke poof for (int i = 0; i < 40; i++) { double ox = (Math.random() - 0.5) * 2; double oy = Math.random() * 2; double oz = (Math.random() - 0.5) * 2; player.getWorld().spawnParticle(Particle.LARGE_SMOKE, player.getLocation().add(ox, oy, oz), 1, 0, 0, 0, 0); } // Apply invisibility XPotion.matchXPotion("INVISIBILITY") .map(xp -> xp.buildPotionEffect(durationTicks + 20, 0)) .ifPresent(player::addPotionEffect); // Hide armor and offhand ItemStack[] armor = player.getInventory().getArmorContents().clone(); hiddenArmor.put(player.getUniqueId(), armor); hiddenOffhand.put(player.getUniqueId(), player.getInventory().getItemInOffHand().clone()); player.getInventory().setArmorContents(new ItemStack[4]); player.getInventory().setItemInOffHand(new ItemStack(Material.AIR)); player.sendMessage(ItemUtil.c("&fPhantom Stealth: &7You vanish into the shadows!")); new BukkitRunnable() { @Override public void run() { if (!player.isOnline()) { phantomActive.remove(player.getUniqueId()); cancel(); return; } restorePhantom(player); } }.runTaskLater(plugin, durationTicks); } public void restorePhantom(Player player) { phantomActive.remove(player.getUniqueId()); ItemStack[] armor = hiddenArmor.remove(player.getUniqueId()); ItemStack offhand = hiddenOffhand.remove(player.getUniqueId()); if (armor != null) player.getInventory().setArmorContents(armor); if (offhand != null) player.getInventory().setItemInOffHand(offhand); player.removePotionEffect(PotionEffectType.INVISIBILITY); } public boolean isPhantomActive(UUID uuid) { return phantomActive.contains(uuid); } // ─── SKY SOVEREIGN ───────────────────────────────────────────────────────── private void activateSky(Player player, int durationTicks) { XSound.matchXSound("ENTITY_ENDER_DRAGON_FLAP").ifPresent(s -> s.play(player)); skyActive.add(player.getUniqueId()); player.setAllowFlight(true); player.setFlying(true); player.sendMessage(ItemUtil.c("&bSky Sovereign: &7The skies are yours!")); new BukkitRunnable() { int elapsed = 0; @Override public void run() { if (!player.isOnline() || elapsed >= durationTicks) { skyActive.remove(player.getUniqueId()); if (player.isOnline() && player.getGameMode() == org.bukkit.GameMode.SURVIVAL) { player.setFlying(false); player.setAllowFlight(false); } cancel(); return; } elapsed++; // CLOUD particle trail at feet player.getWorld().spawnParticle(Particle.CLOUD, player.getLocation(), 2, 0.3, 0, 0.3, 0); } }.runTaskTimer(plugin, 0L, 1L); } public boolean isSkyActive(UUID uuid) { return skyActive.contains(uuid); } // ─── BLOOD VAMPIRE ───────────────────────────────────────────────────────── private void activateBloodVampire(Player player) { // Find nearest living entity LivingEntity nearest = null; double minDist = Double.MAX_VALUE; for (Entity e : player.getNearbyEntities(8, 8, 8)) { if (e instanceof LivingEntity le && !e.equals(player)) { double d = le.getLocation().distanceSquared(player.getLocation()); if (d < minDist) { minDist = d; nearest = le; } } } if (nearest == null) { player.sendMessage(ItemUtil.c("&4No target found nearby!")); // Refund cooldown cooldowns.getOrDefault(player.getUniqueId(), new HashMap<>()).remove(PowerType.BLOOD_VAMPIRE); return; } XSound.matchXSound("ENTITY_WITCH_DRINK").ifPresent(s -> s.play(player)); double drainAmount = 4.0; // 2 hearts double newTargetHealth = Math.max(0.5, nearest.getHealth() - drainAmount); nearest.setHealth(newTargetHealth); AttributeInstance maxHealthAttr = player.getAttribute(Attribute.MAX_HEALTH); double maxHealth = maxHealthAttr != null ? maxHealthAttr.getValue() : 20.0; player.setHealth(Math.min(maxHealth, player.getHealth() + drainAmount)); final LivingEntity target = nearest; new BukkitRunnable() { int count = 0; @Override public void run() { if (count++ >= 40 || !player.isOnline() || target.isDead()) { cancel(); return; } ParticleUtil.spawnDustLine( player.getLocation().add(0, 1, 0), target.getLocation().add(0, 1, 0), Color.RED, 1.5f, 0.4 ); } }.runTaskTimer(plugin, 0L, 1L); player.sendMessage(ItemUtil.c("&4Blood Vampire: &7Life drained!")); } // ─── THUNDER GOD ─────────────────────────────────────────────────────────── private void activateThunderGod(Player player) { XSound.matchXSound("ENTITY_LIGHTNING_BOLT_THUNDER").ifPresent(s -> s.play(player)); Location center = player.getLocation(); List targets = new ArrayList<>(); for (Entity e : player.getNearbyEntities(10, 10, 10)) { if (e instanceof LivingEntity le && !e.equals(player)) { targets.add(le); center.getWorld().strikeLightning(e.getLocation()); } } // Expanding electric spark ring on ground new BukkitRunnable() { double radius = 0.5; int step = 0; @Override public void run() { if (step++ >= 14) { cancel(); return; } int pts = Math.max(12, (int)(radius * 8)); ParticleUtil.spawnCircle(center.clone().add(0, 0.05, 0), Particle.ELECTRIC_SPARK, radius, pts); radius += 0.7; } }.runTaskTimer(plugin, 0L, 2L); player.sendMessage(ItemUtil.c("&eThunder God: &7Lightning descends upon your enemies!")); } // ─── TITAN JUGGERNAUT ────────────────────────────────────────────────────── private void activateTitan(Player player, int durationTicks) { if (titanActive.contains(player.getUniqueId())) return; XSound.matchXSound("BLOCK_ANVIL_LAND").ifPresent(s -> s.play(player)); titanActive.add(player.getUniqueId()); player.setInvulnerable(true); XPotion.matchXPotion("SLOWNESS") .map(xp -> xp.buildPotionEffect(durationTicks + 20, 3)) .ifPresent(player::addPotionEffect); player.sendMessage(ItemUtil.c("&8Titan Juggernaut: &7You are unbreakable!")); new BukkitRunnable() { int elapsed = 0; @Override public void run() { if (!player.isOnline() || elapsed >= durationTicks) { titanActive.remove(player.getUniqueId()); if (player.isOnline()) { player.setInvulnerable(false); player.removePotionEffect(PotionEffectType.SLOWNESS); } cancel(); return; } elapsed++; if (elapsed % 4 == 0) { ParticleUtil.spawnDome(player.getLocation(), Particle.CRIT, 2.0, 8); } } }.runTaskTimer(plugin, 0L, 1L); } // ─── SONIC ASSASSIN ──────────────────────────────────────────────────────── private void activateSonicAssassin(Player player) { Player nearest = null; double minDist = Double.MAX_VALUE; for (Entity e : player.getNearbyEntities(20, 20, 20)) { if (e instanceof Player p && !p.equals(player)) { double d = p.getLocation().distanceSquared(player.getLocation()); if (d < minDist) { minDist = d; nearest = p; } } } if (nearest == null) { player.sendMessage(ItemUtil.c("&dNo target found nearby!")); cooldowns.getOrDefault(player.getUniqueId(), new HashMap<>()).remove(PowerType.SONIC_ASSASSIN); return; } XSound.matchXSound("ENTITY_ENDERMAN_SCREAM").ifPresent(s -> s.play(player)); Location originalLoc = player.getLocation(); // Teleport behind target Location targetLoc = nearest.getLocation().clone(); double yaw = Math.toRadians(targetLoc.getYaw()); double offsetX = Math.sin(yaw) * 1.8; double offsetZ = -Math.cos(yaw) * 1.8; Location behind = targetLoc.clone().add(offsetX, 0, offsetZ); behind.setYaw((targetLoc.getYaw() + 180) % 360); behind.setPitch(0); player.teleport(behind); // Two intersecting DRAGON_BREATH circles at original location ParticleUtil.spawnCircle(originalLoc.clone().add(0, 1, 0), Particle.DRAGON_BREATH, 1.5, 36); ParticleUtil.spawnVerticalCircle(originalLoc.clone().add(0, 1, 0), Particle.DRAGON_BREATH, 1.5, 36, 0); ParticleUtil.spawnVerticalCircle(originalLoc.clone().add(0, 1, 0), Particle.DRAGON_BREATH, 1.5, 36, Math.PI / 2); player.sendMessage(ItemUtil.c("&dSonic Assassin: &7You phase through reality!")); } // ─── FROST WARDEN ────────────────────────────────────────────────────────── private void activateFrostWarden(Player player) { XSound.matchXSound("BLOCK_GLASS_BREAK").ifPresent(s -> s.play(player)); Location center = player.getLocation(); for (Entity e : player.getNearbyEntities(5, 5, 5)) { if (!(e instanceof LivingEntity le) || e.equals(player)) continue; le.setFreezeTicks(le.getMaxFreezeTicks()); XPotion.matchXPotion("SLOWNESS").map(xp -> xp.buildPotionEffect(100, 4)).ifPresent(le::addPotionEffect); XPotion.matchXPotion("MINING_FATIGUE").map(xp -> xp.buildPotionEffect(100, 2)).ifPresent(le::addPotionEffect); } // Snowflake burst pattern ParticleUtil.spawnBurst(center.clone().add(0, 0.1, 0), Particle.SNOWFLAKE, 8, 3.0, 10); player.sendMessage(ItemUtil.c("&3Frost Warden: &7The world freezes around you!")); } // ─── PASSIVE HELPERS ──────────────────────────────────────────────────────── public void applyPassiveEffects(Player player, PowerType type) { PlayerData data = plugin.getPlayerDataManager().getPlayerData(player.getUniqueId()); if (data.getPower() != type) return; switch (type) { case PHANTOM_STEALTH -> XPotion.matchXPotion("SPEED").map(xp -> xp.buildPotionEffect(60, 0)).ifPresent(player::addPotionEffect); case SKY_SOVEREIGN -> XPotion.matchXPotion("SLOW_FALLING").map(xp -> xp.buildPotionEffect(60, 0)).ifPresent(player::addPotionEffect); case BLOOD_VAMPIRE -> {} // handled in event case THUNDER_GOD -> XPotion.matchXPotion("HASTE").map(xp -> xp.buildPotionEffect(60, 0)).ifPresent(player::addPotionEffect); case TITAN_JUGGERNAUT -> XPotion.matchXPotion("RESISTANCE").map(xp -> xp.buildPotionEffect(60, 0)).ifPresent(player::addPotionEffect); case SONIC_ASSASSIN -> XPotion.matchXPotion("JUMP_BOOST").map(xp -> xp.buildPotionEffect(60, 1)).ifPresent(player::addPotionEffect); default -> {} } } public void onPlayerQuit(Player player) { skyActive.remove(player.getUniqueId()); titanActive.remove(player.getUniqueId()); if (phantomActive.contains(player.getUniqueId())) { restorePhantom(player); } if (player.getGameMode() == org.bukkit.GameMode.SURVIVAL) { player.setAllowFlight(false); } } }