package com.fragmentsmp.fragment; import com.cryptomorin.xseries.XPotion; import com.fragmentsmp.FragmentSMP; import com.fragmentsmp.kills.KillTracker; import com.fragmentsmp.kills.Milestone; import com.fragmentsmp.vfx.VFXManager; import org.bukkit.*; import org.bukkit.attribute.Attribute; import org.bukkit.attribute.AttributeInstance; import org.bukkit.entity.*; import org.bukkit.event.entity.EntityDamageEvent; import org.bukkit.inventory.ItemStack; import org.bukkit.potion.PotionEffect; import org.bukkit.potion.PotionEffectType; import org.bukkit.scheduler.BukkitRunnable; import org.bukkit.util.Vector; import java.util.*; public class FragmentManager { private final FragmentSMP plugin; private final VFXManager vfx = new VFXManager(); private final Map> cooldowns = new HashMap<>(); private final Map comboUses = new HashMap<>(); private final Map comboRefillTime = new HashMap<>(); private final Set forcefieldActive = new HashSet<>(); private final Set rageBlastReduction = new HashSet<>(); public FragmentManager(FragmentSMP plugin) { this.plugin = plugin; } public boolean isOnCooldown(UUID uuid, FragmentType type) { Map map = cooldowns.get(uuid); if (map == null) return false; Long end = map.get(type); return end != null && System.currentTimeMillis() < end; } public long getRemainingCooldown(UUID uuid, FragmentType type) { Map map = cooldowns.get(uuid); if (map == null) return 0; Long end = map.get(type); if (end == null) return 0; long remaining = end - System.currentTimeMillis(); return Math.max(0, remaining / 1000); } private void setCooldown(UUID uuid, FragmentType type, int baseCooldownSeconds) { KillTracker kt = plugin.getKillTracker(); int kills = kt.getKills(uuid); double multiplier = 1.0; if (kills >= 60) multiplier = 0.5; else if (kills >= 10) multiplier = 0.7; long ms = (long) (baseCooldownSeconds * multiplier * 1000L); cooldowns.computeIfAbsent(uuid, k -> new HashMap<>()).put(type, System.currentTimeMillis() + ms); } public boolean hasForcefield(UUID uuid) { return forcefieldActive.contains(uuid); } public boolean hasRageBlastReduction(UUID uuid) { return rageBlastReduction.contains(uuid); } public void activate(Player player, FragmentType type) { UUID uuid = player.getUniqueId(); if (isOnCooldown(uuid, type)) { long rem = getRemainingCooldown(uuid, type); player.sendMessage(color("&cThis fragment is on cooldown for &e" + rem + "s&c.")); return; } KillTracker kt = plugin.getKillTracker(); int kills = kt.getKills(uuid); boolean buffed = kills >= 60; applyMilestone25Buff(player, kills); switch (type) { case ECHO: activateEcho(player, buffed); break; case XRAY: activateXray(player, buffed); break; case FORCEFIELD: activateForcefield(player, buffed); break; case CLONE: activateClone(player, buffed); break; case RAGE: activateRage(player, buffed); break; case BEAM: activateBeam(player, buffed); break; case FURY: activateFury(player, buffed); break; case ICE: activateIce(player, buffed); break; case COMBO: activateCombo(player, buffed); break; case FOOD: activateFood(player, buffed); break; } } private void applyMilestone25Buff(Player player, int kills) { if (kills >= 25) { XPotion.matchXPotion("STRENGTH").map(xp -> xp.buildPotionEffect(20 * 20, 1)).ifPresent(player::addPotionEffect); vfx.milestone25Buff(player); } } private int cfg(String path, int def) { return plugin.getConfig().getInt("fragments." + path, def); } private double cfgD(String path, double def) { return plugin.getConfig().getDouble("fragments." + path, def); } // ── 1. ECHO ────────────────────────────────────────────────────────────── private void activateEcho(Player player, boolean buffed) { int baseCooldown = cfg("echo.cooldown", 200); int radius = cfg("echo.radius", 200); int pullRadius = cfg("echo.pull-radius", 50); int glowTicks = cfg("echo.glow-duration", 100) * 20; int damageInterval = cfg("echo.damage-interval", 5); double damage = cfgD("echo.damage-amount", 0.5); if (buffed) { radius *= 2; pullRadius *= 2; glowTicks *= 2; damage *= 2; } setCooldown(player.getUniqueId(), FragmentType.ECHO, baseCooldown); player.sendMessage(color("&5&lECHO FRAGMENT &7activated!")); vfx.echoActivate(player); Location origin = player.getLocation(); List inRadius = new ArrayList<>(); for (Player p : player.getWorld().getPlayers()) { if (p == player) continue; double dist = p.getLocation().distance(origin); if (dist <= radius) { inRadius.add(p); p.addPotionEffect(new PotionEffect(PotionEffectType.GLOWING, glowTicks, 0)); if (dist <= pullRadius) { p.teleport(origin.clone().add(origin.getDirection().multiply(2))); vfx.echoPull(p); } } } final double dmg = damage; final int intervalTicks = damageInterval * 20; final int totalTicks = glowTicks; new BukkitRunnable() { int elapsed = 0; @Override public void run() { elapsed += intervalTicks; if (elapsed > totalTicks) { cancel(); return; } for (Player p : new ArrayList<>(inRadius)) { if (!p.isOnline()) { inRadius.remove(p); continue; } p.damage(dmg); vfx.echoGlowHit(p); } } }.runTaskTimer(plugin, intervalTicks, intervalTicks); } // ── 2. XRAY ────────────────────────────────────────────────────────────── private static final Set XRAY_ORES = new HashSet<>(Arrays.asList( Material.IRON_ORE, Material.DEEPSLATE_IRON_ORE, Material.GOLD_ORE, Material.DEEPSLATE_GOLD_ORE, Material.DIAMOND_ORE, Material.DEEPSLATE_DIAMOND_ORE, Material.EMERALD_ORE, Material.DEEPSLATE_EMERALD_ORE, Material.REDSTONE_ORE, Material.DEEPSLATE_REDSTONE_ORE, Material.LAPIS_ORE, Material.DEEPSLATE_LAPIS_ORE, Material.NETHER_QUARTZ_ORE, Material.NETHER_GOLD_ORE, Material.ANCIENT_DEBRIS )); private void activateXray(Player player, boolean buffed) { int baseCooldown = cfg("xray.cooldown", 500); int radius = cfg("xray.radius", 100); if (buffed) radius *= 2; setCooldown(player.getUniqueId(), FragmentType.XRAY, baseCooldown); player.sendMessage(color("&6&lXRAY FRAGMENT &7activated! Scanning for ores...")); vfx.xrayActivate(player); Location center = player.getLocation(); int r = radius; Map collected = new HashMap<>(); for (int x = -r; x <= r; x++) { for (int y = -r; y <= r; y++) { for (int z = -r; z <= r; z++) { Location loc = center.clone().add(x, y, z); if (loc.distanceSquared(center) > (double) r * r) continue; org.bukkit.block.Block block = loc.getBlock(); if (XRAY_ORES.contains(block.getType())) { Material mat = block.getType(); collected.merge(mat, 1, Integer::sum); block.setType(Material.AIR); } } } } if (collected.isEmpty()) { player.sendMessage(color("&6No ores found in range.")); return; } for (Map.Entry entry : collected.entrySet()) { ItemStack stack = new ItemStack(entry.getKey(), Math.min(entry.getValue(), 64)); player.getInventory().addItem(stack).forEach((slot, leftover) -> player.getWorld().dropItemNaturally(player.getLocation(), leftover)); player.sendMessage(color("&6Found &e" + entry.getValue() + "x &6" + formatMaterial(entry.getKey()))); } vfx.xrayOreCollect(player); } // ── 3. FORCE FIELD ─────────────────────────────────────────────────────── private void activateForcefield(Player player, boolean buffed) { int baseCooldown = cfg("forcefield.cooldown", 60); int duration = cfg("forcefield.duration", 7); if (buffed) duration *= 2; setCooldown(player.getUniqueId(), FragmentType.FORCEFIELD, baseCooldown); UUID uuid = player.getUniqueId(); forcefieldActive.add(uuid); player.sendMessage(color("&b&lFORCE FIELD &7activated for &b" + duration + "s&7!")); vfx.forcefieldActivate(player); final int finalDuration = duration; XPotion.matchXPotion("DAMAGE_RESISTANCE").map(xp -> xp.buildPotionEffect(finalDuration * 20, 4)).ifPresent(player::addPotionEffect); new BukkitRunnable() { int ticks = 0; @Override public void run() { ticks += 10; if (ticks >= finalDuration * 20) { cancel(); return; } if (player.isOnline()) vfx.forcefieldPulse(player); } }.runTaskTimer(plugin, 10, 10); Bukkit.getScheduler().runTaskLater(plugin, () -> { forcefieldActive.remove(uuid); if (player.isOnline()) { player.sendMessage(color("&b&lFORCE FIELD &7has expired.")); vfx.forcefieldExpire(player); } }, duration * 20L); } // ── 4. CLONE ───────────────────────────────────────────────────────────── private void activateClone(Player player, boolean buffed) { int baseCooldown = cfg("clone.cooldown", 120); int count = cfg("clone.count", 5); int duration = cfg("clone.duration", 30); if (buffed) { count *= 2; duration *= 2; } setCooldown(player.getUniqueId(), FragmentType.CLONE, baseCooldown); player.sendMessage(color("&e&lCLONE FRAGMENT &7activated! Spawning &e" + count + " &7clones.")); vfx.cloneActivate(player); List clones = new ArrayList<>(); for (int i = 0; i < count; i++) { Zombie zombie = (Zombie) player.getWorld().spawnEntity(player.getLocation(), EntityType.ZOMBIE); zombie.setCustomName(color("&e" + player.getName() + "'s Clone")); zombie.setCustomNameVisible(true); zombie.setBaby(false); zombie.setAI(true); zombie.setSilent(true); zombie.setInvulnerable(true); zombie.addPotionEffect(new PotionEffect(PotionEffectType.SPEED, duration * 20, 2)); Vector dir = new Vector(Math.random() * 2 - 1, 0, Math.random() * 2 - 1).normalize(); zombie.setVelocity(dir.multiply(0.5)); clones.add(zombie); vfx.cloneSpawn(zombie.getLocation()); } Bukkit.getScheduler().runTaskLater(plugin, () -> { for (Zombie z : clones) { if (!z.isDead()) { vfx.cloneDespawn(z.getLocation()); z.remove(); } } }, duration * 20L); } // ── 5. RAGE ────────────────────────────────────────────────────────────── private void activateRage(Player player, boolean buffed) { int baseCooldown = cfg("rage.cooldown", 120); int duration = cfg("rage.duration", 15); if (buffed) duration *= 2; setCooldown(player.getUniqueId(), FragmentType.RAGE, baseCooldown); player.sendMessage(color("&c&lRAGE FRAGMENT &7activated!")); vfx.rageActivate(player); int ticks = duration * 20; XPotion.matchXPotion("STRENGTH").map(xp -> xp.buildPotionEffect(ticks, 2)).ifPresent(player::addPotionEffect); XPotion.matchXPotion("SPEED").map(xp -> xp.buildPotionEffect(ticks, 2)).ifPresent(player::addPotionEffect); XPotion.matchXPotion("REGENERATION").map(xp -> xp.buildPotionEffect(ticks, 1)).ifPresent(player::addPotionEffect); UUID uuid = player.getUniqueId(); rageBlastReduction.add(uuid); final int finalDuration = duration; new BukkitRunnable() { int elapsed = 0; @Override public void run() { elapsed += 5; if (elapsed >= finalDuration || !player.isOnline()) { cancel(); return; } vfx.ragePulse(player); } }.runTaskTimer(plugin, 5, 5); Bukkit.getScheduler().runTaskLater(plugin, () -> { rageBlastReduction.remove(uuid); if (player.isOnline()) { player.sendMessage(color("&c&lRAGE &7has worn off.")); vfx.rageExpire(player); } }, ticks); } // ── 6. BEAM ────────────────────────────────────────────────────────────── private void activateBeam(Player player, boolean buffed) { int baseCooldown = cfg("beam.cooldown", 30); double damage = cfgD("beam.damage", 4.0); if (buffed) damage *= 2; setCooldown(player.getUniqueId(), FragmentType.BEAM, baseCooldown); vfx.beamFire(player); Vector direction = player.getEyeLocation().getDirection().normalize(); Location loc = player.getEyeLocation().clone(); final double dmg = damage; new BukkitRunnable() { int steps = 0; @Override public void run() { if (steps > 60) { cancel(); return; } loc.add(direction); steps++; vfx.beamTrail(loc.clone()); for (Entity entity : loc.getWorld().getNearbyEntities(loc, 0.5, 0.5, 0.5)) { if (entity instanceof Player target && target != player) { double currentHp = target.getHealth(); target.setHealth(Math.max(0, currentHp - dmg)); target.sendMessage(color("&cYou were hit by a &e&lBEAM&c!")); vfx.beamHit(loc.clone()); cancel(); return; } } if (loc.getBlock().getType().isSolid()) cancel(); } }.runTaskTimer(plugin, 0, 1); player.sendMessage(color("&e&lBEAM FRAGMENT &7fired!")); } // ── 7. FURY ────────────────────────────────────────────────────────────── private void activateFury(Player player, boolean buffed) { int baseCooldown = cfg("fury.cooldown", 60); double radius = cfg("fury.radius", 6); int damageDuration = cfg("fury.damage-duration", 10); int slowFallDuration = cfg("fury.slow-fall-duration", 30); if (buffed) { radius *= 2; damageDuration *= 2; slowFallDuration *= 2; } setCooldown(player.getUniqueId(), FragmentType.FURY, baseCooldown); player.sendMessage(color("&d&lFURY FRAGMENT &7activated!")); vfx.furyActivate(player); final int finalSlowFallDuration = slowFallDuration; XPotion.matchXPotion("SLOW_FALLING").map(xp -> xp.buildPotionEffect(finalSlowFallDuration * 20, 0)).ifPresent(player::addPotionEffect); final double r = radius; final int finalDamageDuration = damageDuration; new BukkitRunnable() { int elapsed = 0; @Override public void run() { elapsed++; if (elapsed > finalDamageDuration) { cancel(); return; } vfx.furyAura(player); for (Player p : player.getWorld().getPlayers()) { if (p == player) continue; if (p.getLocation().distance(player.getLocation()) <= r) { double hp = p.getHealth(); p.setHealth(Math.max(0, hp - 2.0)); vfx.furyHit(p); } } } }.runTaskTimer(plugin, 20, 20); } // ── 8. ICE ─────────────────────────────────────────────────────────────── private void activateIce(Player player, boolean buffed) { int baseCooldown = cfg("ice.cooldown", 30); double radius = cfg("ice.radius", 10); int freezeDuration = cfg("ice.freeze-duration", 8); if (buffed) { radius *= 2; freezeDuration *= 2; } setCooldown(player.getUniqueId(), FragmentType.ICE, baseCooldown); player.sendMessage(color("&3&lICE FRAGMENT &7activated!")); vfx.iceActivate(player); final double r = radius; final int freezeTicks = freezeDuration * 20; for (Player p : player.getWorld().getPlayers()) { if (p == player) continue; if (p.getLocation().distance(player.getLocation()) <= r) { p.setFreezeTicks(freezeTicks); p.sendMessage(color("&3You have been &bfrozen&3!")); vfx.iceFreezeVictim(p); } } } // ── 9. COMBO ───────────────────────────────────────────────────────────── private final Set comboStunned = new HashSet<>(); public boolean isComboStunned(UUID uuid) { return comboStunned.contains(uuid); } private void activateCombo(Player player, boolean buffed) { int baseCooldown = cfg("combo.cooldown", 120); int maxUses = cfg("combo.uses", 7); if (buffed) maxUses *= 2; UUID uuid = player.getUniqueId(); // Check refill Long refillAt = comboRefillTime.get(uuid); if (refillAt != null && System.currentTimeMillis() >= refillAt) { comboUses.put(uuid, maxUses); comboRefillTime.remove(uuid); } int uses = comboUses.getOrDefault(uuid, maxUses); if (uses <= 0) { long rem = refillAt != null ? Math.max(0, (refillAt - System.currentTimeMillis()) / 1000) : 0; player.sendMessage(color("&aNo uses left! Refilling in &e" + rem + "s&a.")); return; } Player target = getTargetPlayer(player, 50); if (target == null) { player.sendMessage(color("&aNo player in your line of sight.")); return; } Location inFront = player.getLocation().clone().add(player.getLocation().getDirection().normalize().multiply(2)); inFront.setY(player.getLocation().getY()); vfx.comboActivate(player); target.teleport(inFront); target.sendMessage(color("&aYou were pulled by &e" + player.getName() + "&a's Combo Fragment!")); vfx.comboTeleportVictim(target); vfx.comboStun(target); UUID targetUUID = target.getUniqueId(); comboStunned.add(targetUUID); Bukkit.getScheduler().runTaskLater(plugin, () -> comboStunned.remove(targetUUID), 20L); int newUses = uses - 1; comboUses.put(uuid, newUses); player.sendMessage(color("&a&lCOMBO FRAGMENT &7used! &e" + newUses + "/" + maxUses + " &7uses remaining.")); if (newUses <= 0) { long refillMs = (long) baseCooldown * 1000L; comboRefillTime.put(uuid, System.currentTimeMillis() + refillMs); player.sendMessage(color("&aOut of uses! Refilling in &e" + baseCooldown + "s&a.")); setCooldown(uuid, FragmentType.COMBO, baseCooldown); } } private Player getTargetPlayer(Player player, double maxDist) { Location eye = player.getEyeLocation(); Vector dir = eye.getDirection().normalize(); Player closest = null; double closestDist = maxDist; for (Player p : player.getWorld().getPlayers()) { if (p == player) continue; Vector toPlayer = p.getEyeLocation().toVector().subtract(eye.toVector()); double dot = toPlayer.dot(dir); if (dot < 0) continue; Vector projected = eye.toVector().add(dir.clone().multiply(dot)); double dist = projected.distance(p.getEyeLocation().toVector()); if (dist < 1.5 && dot < closestDist) { closestDist = dot; closest = p; } } return closest; } // ── 10. FOOD ───────────────────────────────────────────────────────────── private void activateFood(Player player, boolean buffed) { int baseCooldown = cfg("food.cooldown", 30); double radius = cfg("food.radius", 10); if (buffed) radius *= 2; setCooldown(player.getUniqueId(), FragmentType.FOOD, baseCooldown); player.sendMessage(color("&2&lFOOD FRAGMENT &7activated!")); vfx.foodActivate(player); int totalFood = 0; final double r = radius; for (Player p : player.getWorld().getPlayers()) { if (p == player) continue; if (p.getLocation().distance(player.getLocation()) <= r) { totalFood += p.getFoodLevel(); p.setFoodLevel(0); p.setSaturation(0); p.sendMessage(color("&2Your hunger was drained by &a" + player.getName() + "&2!")); vfx.foodDrainVictim(p); } } player.setFoodLevel(20); player.setSaturation(20); player.sendMessage(color("&2Absorbed &a" + totalFood + " &2hunger points from nearby players!")); } private String formatMaterial(Material mat) { return mat.name().replace("_", " ").toLowerCase(); } private String color(String s) { return s.replace("&", "\u00a7"); } }