package com.corruptedsmp.corruption; import com.corruptedsmp.CorruptedSMP; import com.corruptedsmp.data.PlayerData; import com.corruptedsmp.data.PlayerDataManager; import com.cryptomorin.xseries.XPotion; import com.cryptomorin.xseries.XSound; import com.cryptomorin.xseries.particles.XParticle; import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer; import org.bukkit.*; import org.bukkit.attribute.Attribute; import org.bukkit.attribute.AttributeInstance; import org.bukkit.attribute.AttributeModifier; import org.bukkit.entity.*; import org.bukkit.potion.PotionEffect; import org.bukkit.potion.PotionEffectType; import org.bukkit.scheduler.BukkitRunnable; import java.util.HashMap; import java.util.Map; import java.util.UUID; @SuppressWarnings("deprecation") public class CorruptionManager { private final CorruptedSMP plugin; private final PlayerDataManager dataManager; private static final UUID SHADOW_HEALTH_UUID = UUID.fromString("4a8c2d6e-1234-5678-abcd-ff0011223344"); // Tracks last attacker per player (for Void ability) private final Map lastAttacker = new HashMap<>(); // Track Blood players scheduled for hunger drain private final Map lastHungerDrain = new HashMap<>(); public CorruptionManager(CorruptedSMP plugin) { this.plugin = plugin; this.dataManager = plugin.getPlayerDataManager(); startPassiveTicker(); } // ── Corruption Assignment ──────────────────────────────────────────────── public void setCorruption(Player player, CorruptionType type) { PlayerData data = dataManager.getData(player.getUniqueId()); if (data == null) return; // Remove old corruption modifiers if (data.getCorruption() == CorruptionType.SHADOW) { removeShadowHealthModifier(player); } data.setCorruption(type); // Apply new corruption modifiers if (type == CorruptionType.SHADOW) { applyShadowHealthModifier(player); } dataManager.save(player.getUniqueId()); } public void onPlayerLogin(Player player) { PlayerData data = dataManager.getData(player.getUniqueId()); if (data == null || data.getCorruption() == null) return; if (data.getCorruption() == CorruptionType.SHADOW) { applyShadowHealthModifier(player); } } public void onPlayerLogout(Player player) { if (player.getAttribute(Attribute.MAX_HEALTH) != null) { removeShadowHealthModifier(player); } lastAttacker.remove(player.getUniqueId()); lastHungerDrain.remove(player.getUniqueId()); } public void trackLastAttacker(UUID victim, UUID attacker) { lastAttacker.put(victim, attacker); } // ── Ability Activation ──────────────────────────────────────────────────── public void activateAbility(Player player) { PlayerData data = dataManager.getData(player.getUniqueId()); if (data == null || data.getCorruption() == null) { player.sendMessage(ChatColor.RED + "You have not chosen a Corruption yet! Use /corruptions."); return; } long cooldownMs = plugin.getConfigManager().getAbilityCooldownMillis(); // Cooldown tracked in-memory only; resets on restart (acceptable) Long lastUse = abilityLastUse.get(player.getUniqueId()); long now = System.currentTimeMillis(); if (lastUse != null && now - lastUse < cooldownMs) { long remaining = (cooldownMs - (now - lastUse)) / 1000L; player.sendMessage(ChatColor.RED + "Ability on cooldown! " + remaining + "s remaining."); return; } abilityLastUse.put(player.getUniqueId(), now); switch (data.getCorruption()) { case SHADOW -> activateShadow(player); case BLAZE -> activateBlaze(player); case VOID -> activateVoid(player); case STORM -> activateStorm(player); case PLAGUE -> activatePlague(player); case ICE -> activateIce(player); case BLOOD -> activateBlood(player); case WITHER -> activateWither(player); case ENDER -> activateEnder(player); } } private final Map abilityLastUse = new HashMap<>(); private void activateShadow(Player player) { XPotion.matchXPotion("INVISIBILITY").map(xp -> xp.buildPotionEffect(100, 0)).ifPresent(player::addPotionEffect); for (Entity e : player.getNearbyEntities(8, 8, 8)) { if (e instanceof Player target && !target.equals(player)) { XPotion.matchXPotion("BLINDNESS").map(xp -> xp.buildPotionEffect(100, 0)).ifPresent(target::addPotionEffect); } } XParticle.of("SMOKE").ifPresent(p -> player.getWorld().spawnParticle(p.get(), player.getLocation(), 40, 0.5, 1, 0.5, 0.05)); XSound.matchXSound("ENTITY_ENDERMAN_TELEPORT").ifPresent(s -> s.play(player)); player.sendMessage(ChatColor.DARK_GRAY + "You vanish into the shadows!"); } private void activateBlaze(Player player) { Location center = player.getLocation(); double radius = 4.0; int points = 16; for (int i = 0; i < points; i++) { double angle = (2 * Math.PI / points) * i; double x = Math.cos(angle) * radius; double z = Math.sin(angle) * radius; Location loc = center.clone().add(x, 0, z); loc.getWorld().spawnParticle(Particle.FLAME, loc, 10, 0.1, 0.3, 0.1, 0.02); } for (Entity e : player.getNearbyEntities(5, 3, 5)) { if (e instanceof LivingEntity target && !target.equals(player)) { target.setFireTicks(100); target.damage(3.0, player); } } XSound.matchXSound("ENTITY_BLAZE_SHOOT").ifPresent(s -> s.play(player)); player.sendMessage(ChatColor.GOLD + "A ring of fire erupts around you!"); } private void activateVoid(Player player) { UUID attackerUUID = lastAttacker.get(player.getUniqueId()); if (attackerUUID == null) { player.sendMessage(ChatColor.DARK_PURPLE + "No recent attacker to teleport to."); return; } Player attacker = Bukkit.getPlayer(attackerUUID); if (attacker == null || !attacker.isOnline()) { player.sendMessage(ChatColor.DARK_PURPLE + "Your attacker is no longer online."); return; } Location behind = attacker.getLocation().clone().subtract(attacker.getLocation().getDirection().multiply(1.5)); behind.setY(attacker.getLocation().getY()); player.teleport(behind); XParticle.of("PORTAL").ifPresent(p -> player.getWorld().spawnParticle(p.get(), player.getLocation(), 30, 0.3, 1, 0.3, 0.1)); XSound.matchXSound("ENTITY_ENDERMAN_TELEPORT").ifPresent(s -> s.play(player)); player.sendMessage(ChatColor.DARK_PURPLE + "You phase behind your attacker!"); } private void activateStorm(Player player) { int strikes = 0; for (Entity e : player.getNearbyEntities(10, 5, 10)) { if (e instanceof Player target && !target.equals(player) && strikes < 5) { player.getWorld().strikeLightning(target.getLocation()); strikes++; } } if (strikes == 0) player.sendMessage(ChatColor.AQUA + "No enemies nearby for the storm to strike!"); else player.sendMessage(ChatColor.AQUA + "The storm answers your call! (" + strikes + " strikes)"); XSound.matchXSound("ENTITY_LIGHTNING_BOLT_THUNDER").ifPresent(s -> s.play(player)); } private void activatePlague(Player player) { int count = 0; for (Entity e : player.getNearbyEntities(6, 4, 6)) { if (e instanceof LivingEntity target && !target.equals(player)) { XPotion.matchXPotion("POISON").map(xp -> xp.buildPotionEffect(100, 1)).ifPresent(target::addPotionEffect); target.getWorld().spawnParticle(Particle.ENTITY_EFFECT, target.getLocation().add(0, 1, 0), 20, 0.3, 0.5, 0.3, 0); count++; } } XSound.matchXSound("ENTITY_WITCH_THROW").ifPresent(s -> s.play(player)); player.sendMessage(ChatColor.GREEN + "Pestilence spreads to " + count + " nearby entities!"); } private void activateIce(Player player) { for (Entity e : player.getNearbyEntities(5, 4, 5)) { if (e instanceof LivingEntity target && !target.equals(player)) { XPotion.matchXPotion("SLOWNESS").map(xp -> xp.buildPotionEffect(60, 10)).ifPresent(target::addPotionEffect); target.getWorld().spawnParticle(Particle.SNOWFLAKE, target.getLocation().add(0, 1, 0), 30, 0.5, 1, 0.5, 0.05); } } XSound.matchXSound("BLOCK_GLASS_BREAK").ifPresent(s -> s.play(player)); player.sendMessage(ChatColor.WHITE + "Glacial energy freezes nearby enemies!"); } private void activateBlood(Player player) { double stolen = 0; for (Entity e : player.getNearbyEntities(5, 4, 5)) { if (e instanceof LivingEntity target && !target.equals(player)) { double drain = Math.min(target.getHealth(), 4.0); target.damage(4.0, player); stolen += drain; target.getWorld().spawnParticle(Particle.BLOCK, target.getLocation().add(0, 1, 0), 20, 0.3, 0.5, 0.3, Material.REDSTONE_BLOCK.createBlockData()); } } double healAmount = stolen; double newHealth = Math.min(player.getMaxHealth(), player.getHealth() + healAmount); player.setHealth(newHealth); XSound.matchXSound("ENTITY_PLAYER_HURT").ifPresent(s -> s.play(player)); player.sendMessage(ChatColor.RED + "You drain the life from nearby enemies! (+" + String.format("%.1f", healAmount / 2) + " hearts)"); } private void activateWither(Player player) { int count = 0; for (Entity e : player.getNearbyEntities(5, 4, 5)) { if (e instanceof LivingEntity target && !target.equals(player)) { XPotion.matchXPotion("WITHER").map(xp -> xp.buildPotionEffect(80, 1)).ifPresent(target::addPotionEffect); target.getWorld().spawnParticle(Particle.LARGE_SMOKE, target.getLocation().add(0, 1, 0), 15, 0.3, 0.5, 0.3, 0.02); count++; } } XSound.matchXSound("ENTITY_WITHER_AMBIENT").ifPresent(s -> s.play(player)); player.sendMessage(ChatColor.BLACK + "Decay spreads! " + count + " entities withered."); } private void activateEnder(Player player) { Location spawnLoc = player.getEyeLocation(); org.bukkit.util.Vector direction = player.getLocation().getDirection().normalize(); AreaEffectCloud cloud = (AreaEffectCloud) player.getWorld().spawnEntity(spawnLoc, EntityType.AREA_EFFECT_CLOUD); cloud.setParticle(Particle.DRAGON_BREATH); cloud.setRadius(2.0f); cloud.setDuration(120); cloud.setReapplicationDelay(20); cloud.addCustomEffect(new PotionEffect(PotionEffectType.INSTANT_DAMAGE, 1, 0), true); cloud.setSource(player); final int[] ticks = {0}; new BukkitRunnable() { @Override public void run() { if (ticks[0]++ >= 10 || !cloud.isValid()) { cloud.remove(); cancel(); return; } cloud.teleport(cloud.getLocation().add(direction.clone().multiply(0.8))); } }.runTaskTimer(plugin, 0L, 2L); XSound.matchXSound("ENTITY_ENDER_DRAGON_FLAP").ifPresent(s -> s.play(player)); player.sendMessage(ChatColor.LIGHT_PURPLE + "Dragon Breath surges forward!"); } // ── Blood Kill Regen ────────────────────────────────────────────────────── public void onKill(Player killer) { PlayerData data = dataManager.getData(killer.getUniqueId()); if (data == null || data.getCorruption() != CorruptionType.BLOOD) return; double newHealth = Math.min(killer.getMaxHealth(), killer.getHealth() + 2.0); killer.setHealth(newHealth); killer.sendMessage(ChatColor.RED + "Your bloodthirst heals you."); } // ── Passive Tick ────────────────────────────────────────────────────────── private void startPassiveTicker() { new BukkitRunnable() { @Override public void run() { for (Player player : Bukkit.getOnlinePlayers()) { PlayerData data = dataManager.getData(player.getUniqueId()); if (data == null || data.getCorruption() == null) continue; applyPassives(player, data.getCorruption()); applyNegativeTicks(player, data); updateActionBar(player, data); } } }.runTaskTimer(plugin, 20L, 20L); } private void applyPassives(Player player, CorruptionType type) { switch (type) { case BLAZE -> applyEffect(player, "FIRE_RESISTANCE", 40, 0); case VOID -> applyEffect(player, "SLOW_FALLING", 40, 0); case STORM -> applyEffect(player, "SPEED", 40, 0); case PLAGUE -> { player.removePotionEffect(PotionEffectType.POISON); } case WITHER -> { player.removePotionEffect(PotionEffectType.WITHER); } default -> {} } } private void applyNegativeTicks(Player player, PlayerData data) { CorruptionType type = data.getCorruption(); switch (type) { case SHADOW -> applyEffect(player, "SLOWNESS", 40, 0); case VOID -> applyEffect(player, "MINING_FATIGUE", 40, 0); case STORM -> applyEffect(player, "WEAKNESS", 40, 0); case PLAGUE -> applyEffect(player, "SLOWNESS", 40, 0); case ICE -> { float temp = player.getLocation().getBlock().getBiome().name().contains("DESERT") || player.getLocation().getBlock().getBiome().name().contains("SAVANNA") || player.getLocation().getBlock().getBiome().name().contains("BADLANDS") ? 1.0f : 0.0f; if (temp > 0) applyEffect(player, "WEAKNESS", 40, 0); else player.removePotionEffect(PotionEffectType.WEAKNESS); } case BLOOD -> { long now = System.currentTimeMillis(); long last = lastHungerDrain.getOrDefault(player.getUniqueId(), 0L); if (now - last > 4000L) { int food = player.getFoodLevel(); if (food > 0) player.setFoodLevel(Math.max(0, food - 1)); lastHungerDrain.put(player.getUniqueId(), now); } } case WITHER -> { applyEffect(player, "HUNGER", 40, 1); applyEffect(player, "WEAKNESS", 40, 0); } case ENDER -> { World world = player.getWorld(); boolean isDay = world.getTime() < 13000L; if (isDay) { applyEffect(player, "BLINDNESS", 40, 0); } else { player.removePotionEffect(PotionEffectType.BLINDNESS); } } case BLAZE -> { if (player.isInWater() || player.isInRain()) { player.damage(0.5); } } default -> {} } } private void updateActionBar(Player player, PlayerData data) { CorruptionType type = data.getCorruption(); String corruptionDisplay = type != null ? ChatColor.translateAlternateColorCodes('&', type.getColorCode() + type.getDisplayName()) : ChatColor.GRAY + "None"; String wattsColor = data.getWatts() >= 0 ? "&e" : "&c"; String msg = ChatColor.translateAlternateColorCodes('&', "&7[" + corruptionDisplay + "&7] &fWatts: " + wattsColor + data.getWatts()); player.sendActionBar(LegacyComponentSerializer.legacySection().deserialize(msg)); } private void applyEffect(Player player, String effectName, int duration, int amplifier) { XPotion.matchXPotion(effectName).map(xp -> xp.buildPotionEffect(duration, amplifier)).ifPresent(effect -> { PotionEffect existing = player.getPotionEffect(effect.getType()); if (existing == null || existing.getDuration() < (duration / 2)) { player.addPotionEffect(effect); } }); } // ── Shadow Attribute ────────────────────────────────────────────────────── private void applyShadowHealthModifier(Player player) { AttributeInstance attr = player.getAttribute(Attribute.MAX_HEALTH); if (attr == null) return; boolean hasIt = attr.getModifiers().stream().anyMatch(m -> m.getUniqueId().equals(SHADOW_HEALTH_UUID)); if (!hasIt) { attr.addModifier(new AttributeModifier(SHADOW_HEALTH_UUID, "shadow_health_penalty", -4.0, AttributeModifier.Operation.ADD_NUMBER)); } if (player.getHealth() > player.getMaxHealth()) { player.setHealth(player.getMaxHealth()); } } private void removeShadowHealthModifier(Player player) { AttributeInstance attr = player.getAttribute(Attribute.MAX_HEALTH); if (attr == null) return; attr.getModifiers().stream() .filter(m -> m.getUniqueId().equals(SHADOW_HEALTH_UUID)) .findFirst() .ifPresent(attr::removeModifier); } }