package com.coresystemx; import com.cryptomorin.xseries.XAttribute; import com.cryptomorin.xseries.XPotion; import com.cryptomorin.xseries.XSound; import com.cryptomorin.xseries.particles.XParticle; import org.bukkit.Bukkit; import org.bukkit.ChatColor; import org.bukkit.GameMode; import org.bukkit.Material; import org.bukkit.attribute.AttributeInstance; import org.bukkit.entity.Entity; import org.bukkit.entity.LivingEntity; import org.bukkit.entity.Player; import org.bukkit.potion.PotionEffect; import org.bukkit.scheduler.BukkitTask; import java.util.*; public class CoreManager { private final CoreSystemX plugin; private final Map playerCores = new HashMap<>(); private final Map> cooldowns = new HashMap<>(); private final Set voidFlight = new HashSet<>(); private final List tasks = new ArrayList<>(); public CoreManager(CoreSystemX plugin) { this.plugin = plugin; } // ------------------------------------------------------------------------- // Core assignment // ------------------------------------------------------------------------- public void setCore(Player player, CoreType core) { removeCore(player); playerCores.put(player.getUniqueId(), core); player.sendMessage(c("&8[&6Core&8] " + core.getDisplayName() + " &7activated!")); player.sendMessage(c("&8[&6Core&8] " + core.getDescription())); XSound.matchXSound("ENTITY_PLAYER_LEVELUP").ifPresent(s -> s.play(player)); applyInitialPassives(player, core); } public void removeCore(Player player) { CoreType old = playerCores.remove(player.getUniqueId()); if (old != null) cleanupPlayer(player); } public CoreType getCore(UUID uuid) { return playerCores.get(uuid); } public boolean hasCore(UUID uuid) { return playerCores.containsKey(uuid); } // ------------------------------------------------------------------------- // Void flight // ------------------------------------------------------------------------- public boolean isVoidFlying(UUID uuid) { return voidFlight.contains(uuid); } public void toggleVoidFlight(Player player) { UUID uuid = player.getUniqueId(); if (voidFlight.contains(uuid)) { voidFlight.remove(uuid); player.setAllowFlight(false); player.setFlying(false); player.sendMessage(c("&5[Void] &7Flight &cdisabled&7.")); XSound.matchXSound("ENTITY_ENDERMAN_TELEPORT").ifPresent(s -> s.play(player)); } else { voidFlight.add(uuid); player.setAllowFlight(true); player.setFlying(true); player.sendMessage(c("&5[Void] &7Flight &aenabled&7.")); XSound.matchXSound("ENTITY_ENDERMAN_TELEPORT").ifPresent(s -> s.play(player)); } } // ------------------------------------------------------------------------- // Cooldowns // ------------------------------------------------------------------------- public boolean isOnCooldown(UUID uuid, String ability) { Map map = cooldowns.get(uuid); if (map == null) return false; Long expiry = map.get(ability); return expiry != null && System.currentTimeMillis() < expiry; } public long getCooldownRemaining(UUID uuid, String ability) { Map map = cooldowns.getOrDefault(uuid, Collections.emptyMap()); Long expiry = map.get(ability); if (expiry == null) return 0; long remaining = expiry - System.currentTimeMillis(); return Math.max(0, remaining); } public void setCooldown(UUID uuid, String ability, int seconds) { cooldowns.computeIfAbsent(uuid, k -> new HashMap<>()) .put(ability, System.currentTimeMillis() + seconds * 1000L); } // ------------------------------------------------------------------------- // Passive tasks // ------------------------------------------------------------------------- public void startPassiveTasks() { // Re-apply permanent potion effects every 3 seconds (duration 15 sec) tasks.add(Bukkit.getScheduler().runTaskTimer(plugin, () -> { for (Player p : Bukkit.getOnlinePlayers()) { CoreType core = getCore(p.getUniqueId()); if (core != null) applyPermanentEffects(p, core); } }, 0L, 60L)); // Dynamic passives every 10 ticks (0.5 sec) tasks.add(Bukkit.getScheduler().runTaskTimer(plugin, () -> { for (Player p : Bukkit.getOnlinePlayers()) { CoreType core = getCore(p.getUniqueId()); if (core != null) applyDynamicPassives(p, core); } }, 0L, 10L)); // Walk‑on‑water physics every 2 ticks tasks.add(Bukkit.getScheduler().runTaskTimer(plugin, () -> { for (Player p : Bukkit.getOnlinePlayers()) { if (getCore(p.getUniqueId()) != CoreType.WATER) continue; if (p.isSneaking()) continue; if (p.getGameMode() != GameMode.SURVIVAL && p.getGameMode() != GameMode.ADVENTURE) continue; if (p.getLocation().getBlock().getType() == Material.WATER && p.getVelocity().getY() < 0.1) { p.setVelocity(p.getVelocity().setY(0.15)); } } }, 0L, 2L)); // VOID ambient particles every 5 ticks tasks.add(Bukkit.getScheduler().runTaskTimer(plugin, () -> { for (Player p : Bukkit.getOnlinePlayers()) { if (getCore(p.getUniqueId()) != CoreType.VOID) continue; XParticle.of("DRAGON_BREATH").ifPresent(xp -> p.getWorld().spawnParticle(xp.get(), p.getLocation().add(0, 0.5, 0), 8, 0.3, 0.3, 0.3, 0.01)); XParticle.of("PORTAL").ifPresent(xp -> p.getWorld().spawnParticle(xp.get(), p.getLocation().add(0, 1, 0), 5, 0.2, 0.4, 0.2, 0.05)); } }, 0L, 5L)); } private void applyInitialPassives(Player player, CoreType core) { switch (core) { case AIR: if (isSurvival(player)) player.setAllowFlight(true); break; case EARTH: setKnockbackResistance(player, 1.0); break; case GUARDIAN: setKnockbackResistance(player, 0.75); break; default: break; } } private void applyPermanentEffects(Player player, CoreType core) { final int dur = 400; // 20 sec duration, re-applied every 3 sec switch (core) { case LIGHTNING: applyFx(player, "SPEED", dur, 1); break; case WATER: applyFx(player, "WATER_BREATHING", dur, 0); break; case AIR: applyFx(player, "SPEED", dur, 2); if (isSurvival(player)) player.setAllowFlight(true); break; case GUARDIAN: applyFx(player, "RESISTANCE", dur, 0); break; case VOID: applyFx(player, "NIGHT_VISION", dur, 0); break; default: break; } } private void applyDynamicPassives(Player player, CoreType core) { switch (core) { case WATER: if (player.isInWater() && player.getHealth() < player.getMaxHealth()) { player.setHealth(Math.min(player.getMaxHealth(), player.getHealth() + 0.5)); } break; case ICE: for (Entity e : player.getNearbyEntities(5, 3, 5)) { if (e instanceof LivingEntity && !e.equals(player)) { applyFxToEntity((LivingEntity) e, "SLOWNESS", 30, 1); } } break; case POISON: for (Entity e : player.getNearbyEntities(4, 3, 4)) { if (e instanceof LivingEntity && !e.equals(player)) { applyFxToEntity((LivingEntity) e, "POISON", 40, 0); } } break; case GUARDIAN: for (Entity e : player.getNearbyEntities(8, 4, 8)) { if (e instanceof Player) { Player ally = (Player) e; if (ally.getHealth() < ally.getMaxHealth()) { ally.setHealth(Math.min(ally.getMaxHealth(), ally.getHealth() + 0.25)); } } } break; case BLOOD: { double pct = player.getHealth() / player.getMaxHealth(); if (pct <= 0.15) { applyFx(player, "STRENGTH", 30, 2); } else if (pct <= 0.30) { applyFx(player, "STRENGTH", 30, 1); } else { removeFx(player, "STRENGTH"); } break; } default: break; } } // ------------------------------------------------------------------------- // Helpers // ------------------------------------------------------------------------- public void applyFx(Player player, String name, int duration, int amplifier) { XPotion.matchXPotion(name) .map(xp -> xp.buildPotionEffect(duration, amplifier)) .ifPresent(e -> player.addPotionEffect(e, true)); } public void applyFxToEntity(LivingEntity entity, String name, int duration, int amplifier) { XPotion.matchXPotion(name) .map(xp -> xp.buildPotionEffect(duration, amplifier)) .ifPresent(e -> entity.addPotionEffect(e, true)); } public void removeFx(Player player, String name) { XPotion.matchXPotion(name) .map(xp -> xp.buildPotionEffect(1, 0).getType()) .ifPresent(player::removePotionEffect); } public void setKnockbackResistance(Player player, double value) { XAttribute.of("knockback_resistance").ifPresent(attr -> { AttributeInstance inst = player.getAttribute(attr.get()); if (inst != null) inst.setBaseValue(value); }); } private void cleanupPlayer(Player player) { if (isSurvival(player)) { player.setAllowFlight(false); player.setFlying(false); } voidFlight.remove(player.getUniqueId()); setKnockbackResistance(player, 0.0); for (String fx : new String[]{"SPEED", "WATER_BREATHING", "NIGHT_VISION", "STRENGTH", "SLOWNESS", "POISON", "RESISTANCE"}) { removeFx(player, fx); } } private boolean isSurvival(Player player) { return player.getGameMode() == GameMode.SURVIVAL || player.getGameMode() == GameMode.ADVENTURE; } private String c(String msg) { return ChatColor.translateAlternateColorCodes('&', msg); } public void cleanup() { tasks.forEach(BukkitTask::cancel); tasks.clear(); for (Player p : Bukkit.getOnlinePlayers()) cleanupPlayer(p); playerCores.clear(); } }