package com.rebelrp.plugin.listeners; import com.cryptomorin.xseries.XPotion; import com.cryptomorin.xseries.XSound; import com.cryptomorin.xseries.particles.XParticle; import com.rebelrp.plugin.Origin; import com.rebelrp.plugin.RebelRPPlugin; import com.rebelrp.plugin.items.ItemFactory; import net.md_5.bungee.api.ChatMessageType; import net.md_5.bungee.api.chat.TextComponent; import org.bukkit.Bukkit; import org.bukkit.Location; import org.bukkit.Material; import org.bukkit.World; import org.bukkit.entity.Entity; import org.bukkit.entity.LivingEntity; import org.bukkit.entity.Player; import org.bukkit.event.EventHandler; import org.bukkit.event.Listener; import org.bukkit.event.block.Action; import org.bukkit.event.player.PlayerInteractEvent; import org.bukkit.inventory.EquipmentSlot; import org.bukkit.inventory.ItemStack; import org.bukkit.scheduler.BukkitRunnable; import org.bukkit.scheduler.BukkitTask; import org.bukkit.util.Vector; import java.util.*; public class AbilityListener implements Listener { private final RebelRPPlugin plugin; private final Map> cooldowns = new HashMap<>(); private final Map activeJets = new HashMap<>(); public AbilityListener(RebelRPPlugin plugin) { this.plugin = plugin; } @EventHandler public void onInteract(PlayerInteractEvent event) { if (event.getHand() != EquipmentSlot.HAND) return; Player player = event.getPlayer(); ItemStack item = event.getItem(); if (item == null) return; String itemType = plugin.getItemFactory().getItemType(item); if (itemType == null) return; event.setCancelled(true); Action action = event.getAction(); boolean leftClick = action == Action.LEFT_CLICK_AIR || action == Action.LEFT_CLICK_BLOCK; boolean rightClick = action == Action.RIGHT_CLICK_AIR || action == Action.RIGHT_CLICK_BLOCK; if (!leftClick && !rightClick) return; Origin origin = plugin.getOriginOf(player); String wrongItemMsg = plugin.prefix() + plugin.color( plugin.getConfig().getString("messages.wrong_origin_item", "&cThat ability isn't yours to use.")); switch (itemType) { case ItemFactory.DEMON_BYFROST -> { if (origin != Origin.DEMON) { player.sendMessage(wrongItemMsg); return; } if (leftClick) activateJet(player, false); else teleportHome(player, origin); } case ItemFactory.DEVIGOD_BYFROST -> { if (origin != Origin.DEVIGOD) { player.sendMessage(wrongItemMsg); return; } if (leftClick) activateJet(player, true); else teleportHome(player, origin); } case ItemFactory.HELLBRINGER -> { if (origin != Origin.DEMON) { player.sendMessage(wrongItemMsg); return; } if (leftClick) hellbringerBlast(player); else hellbringerFire(player); } case ItemFactory.ZEUS_EYE -> { if (origin != Origin.DEVIGOD) { player.sendMessage(wrongItemMsg); return; } if (leftClick) zeusLightning(player); else zeusLevitate(player); } } } // ─────── JET ─────── private void activateJet(Player player, boolean isAirJet) { String cfgPath = isAirJet ? "air_jet" : "fire_jet"; int cooldownSecs = plugin.getConfig().getInt(cfgPath + ".cooldown_seconds", 3); String cooldownKey = cfgPath + "_jet"; if (!checkCooldown(player, cooldownKey, cooldownSecs, true)) return; setCooldown(player, cooldownKey); int baseSecs = plugin.getConfig().getInt(cfgPath + ".base_flight_seconds", 4); int secsPerHour = plugin.getConfig().getInt(cfgPath + ".flight_seconds_per_hour", 2); double playHours = getDataManager(player).getTotalPlayTimeHours(); int durationSecs = baseSecs + (int) (playHours * secsPerHour); UUID id = player.getUniqueId(); BukkitTask existing = activeJets.remove(id); if (existing != null) existing.cancel(); double speed = plugin.getConfig().getDouble(cfgPath + ".flight_speed", 16.0); String particleName = plugin.getConfig().getString(cfgPath + ".particle", isAirJet ? "CLOUD" : "FLAME"); int particleCount = plugin.getConfig().getInt(cfgPath + ".particle_count", 10); double particleSpread = plugin.getConfig().getDouble(cfgPath + ".particle_spread", 0.25); String soundName = plugin.getConfig().getString(cfgPath + ".launch_sound", "ENTITY_BLAZE_SHOOT"); float soundVol = (float) plugin.getConfig().getDouble(cfgPath + ".launch_sound_volume", 1.0); float soundPitch = (float) plugin.getConfig().getDouble(cfgPath + ".launch_sound_pitch", 1.0); String startMsg = plugin.getConfig().getString(cfgPath + ".start_message", ""); String endMsg = plugin.getConfig().getString(cfgPath + ".end_message", ""); boolean showActionBar = plugin.getConfig().getBoolean(cfgPath + ".show_action_bar", true); XSound.matchXSound(soundName).ifPresent(s -> s.play(player, soundVol, soundPitch)); if (!startMsg.isEmpty()) { String msg = plugin.color(startMsg.replace("{seconds}", String.valueOf(durationSecs))); if (showActionBar) sendActionBar(player, msg); else player.sendMessage(plugin.prefix() + msg); } int[] ticksLeft = {durationSecs * 20}; BukkitRunnable runnable = new BukkitRunnable() { @Override public void run() { if (!player.isOnline() || ticksLeft[0] <= 0) { cancel(); activeJets.remove(id); if (!endMsg.isEmpty() && player.isOnline()) { String msg = plugin.color(endMsg); if (showActionBar) sendActionBar(player, msg); else player.sendMessage(plugin.prefix() + msg); } return; } Vector dir = player.getLocation().getDirection().clone().normalize(); player.setVelocity(dir.multiply(speed / 20.0)); player.setFallDistance(0); XParticle.of(particleName).ifPresent(xp -> player.getWorld().spawnParticle(xp.get(), player.getLocation(), particleCount, particleSpread, particleSpread, particleSpread, 0)); ticksLeft[0]--; } }; activeJets.put(id, runnable.runTaskTimer(plugin, 0L, 1L)); } // ─────── HOME TELEPORT ─────── private void teleportHome(Player player, Origin origin) { String cfgPath = switch (origin) { case DEMON -> "fire_jet"; case DEVIGOD -> "air_jet"; case HUMAN -> "fire_jet"; }; int homeCooldown = plugin.getConfig().getInt(cfgPath + ".home_cooldown_seconds", 30); if (!checkCooldown(player, "home_tp", homeCooldown, true)) return; setCooldown(player, "home_tp"); String spawnPath = switch (origin) { case DEMON -> "respawn.home_spawn.demons"; case DEVIGOD -> "respawn.home_spawn.devigods"; case HUMAN -> "respawn.home_spawn.humans"; }; String worldName = plugin.getConfig().getString(spawnPath + ".world", "world"); double x = plugin.getConfig().getDouble(spawnPath + ".x", 0.5); double y = plugin.getConfig().getDouble(spawnPath + ".y", 65.0); double z = plugin.getConfig().getDouble(spawnPath + ".z", 0.5); World world = Bukkit.getWorld(worldName); if (world == null) { player.sendMessage(plugin.prefix() + "§cHome world not available."); return; } player.sendMessage(plugin.prefix() + plugin.color( plugin.getConfig().getString("messages.teleporting_home", "&eTeleporting to home realm..."))); player.teleport(new Location(world, x, y, z)); XSound.matchXSound("ENTITY_ENDERMAN_TELEPORT").ifPresent(s -> s.play(player)); } // ─────── HELLBRINGER BLAST ─────── @SuppressWarnings("deprecation") private void hellbringerBlast(Player player) { int cooldown = plugin.getConfig().getInt("hellbringer.blast.cooldown_seconds", 20); if (!checkCooldown(player, "hellbringer_blast", cooldown, false)) return; setCooldown(player, "hellbringer_blast"); double range = plugin.getConfig().getDouble("hellbringer.blast.range", 20); Optional nearestTarget = player.getWorld() .getNearbyEntities(player.getLocation(), range, range, range).stream() .filter(e -> e instanceof LivingEntity && !e.equals(player)) .filter(player::hasLineOfSight) .min(Comparator.comparingDouble(e -> e.getLocation().distanceSquared(player.getLocation()))); Location explodeLoc; if (nearestTarget.isPresent()) { explodeLoc = nearestTarget.get().getLocation(); } else { explodeLoc = player.getTargetBlock((Set) null, (int) range) .getLocation().add(0.5, 0.5, 0.5); } float power = (float) plugin.getConfig().getDouble("hellbringer.blast.power", 6.0); boolean createFire = plugin.getConfig().getBoolean("hellbringer.blast.create_fire", false); boolean breakBlocks = plugin.getConfig().getBoolean("hellbringer.blast.break_blocks", false); player.getWorld().createExplosion( explodeLoc.getX(), explodeLoc.getY(), explodeLoc.getZ(), power, createFire, breakBlocks); player.sendMessage(plugin.prefix() + plugin.color( plugin.getConfig().getString("hellbringer.blast.message", "&4💥 Hellbringer — BOOM!"))); } // ─────── HELLBRINGER FIRE AURA ─────── private void hellbringerFire(Player player) { int cooldown = plugin.getConfig().getInt("hellbringer.fire_aura.cooldown_seconds", 10); if (!checkCooldown(player, "hellbringer_fire", cooldown, false)) return; setCooldown(player, "hellbringer_fire"); double radius = plugin.getConfig().getDouble("hellbringer.fire_aura.radius", 20); int fireTicks = plugin.getConfig().getInt("hellbringer.fire_aura.fire_duration_seconds", 5) * 20; player.getWorld().getNearbyEntities(player.getLocation(), radius, radius, radius).stream() .filter(e -> e instanceof LivingEntity && !e.equals(player)) .forEach(e -> ((LivingEntity) e).setFireTicks(fireTicks)); player.sendMessage(plugin.prefix() + plugin.color( plugin.getConfig().getString("hellbringer.fire_aura.message", "&4🔥 Hellbringer — everything burns!"))); XSound.matchXSound("ITEM_FIRECHARGE_USE").ifPresent(s -> s.play(player)); } // ─────── ZEUS LIGHTNING ─────── private void zeusLightning(Player player) { int cooldown = plugin.getConfig().getInt("zeus_eye.lightning.cooldown_seconds", 20); if (!checkCooldown(player, "zeus_lightning", cooldown, false)) return; double range = plugin.getConfig().getDouble("zeus_eye.lightning.range", 20); double bonusDmg = plugin.getConfig().getDouble("zeus_eye.lightning.bonus_damage", 4.0); Optional target = player.getWorld() .getNearbyEntities(player.getLocation(), range, range, range).stream() .filter(e -> e instanceof LivingEntity && !e.equals(player)) .filter(player::hasLineOfSight) .min(Comparator.comparingDouble(e -> e.getLocation().distanceSquared(player.getLocation()))); if (target.isEmpty()) { player.sendMessage(plugin.prefix() + "§cNo target in range."); return; } setCooldown(player, "zeus_lightning"); Entity t = target.get(); player.getWorld().strikeLightning(t.getLocation()); ((LivingEntity) t).damage(bonusDmg, player); player.sendMessage(plugin.prefix() + plugin.color( plugin.getConfig().getString("zeus_eye.lightning.message", "&e⚡ Zeus Eye — lightning unleashed!"))); String soundName = plugin.getConfig().getString("zeus_eye.lightning.sound", "ENTITY_LIGHTNING_BOLT_THUNDER"); XSound.matchXSound(soundName).ifPresent(s -> s.play(player)); } // ─────── ZEUS LEVITATE ─────── private void zeusLevitate(Player player) { int cooldown = plugin.getConfig().getInt("zeus_eye.levitation.cooldown_seconds", 10); if (!checkCooldown(player, "zeus_levitate", cooldown, false)) return; setCooldown(player, "zeus_levitate"); double radius = plugin.getConfig().getDouble("zeus_eye.levitation.radius", 15); int durationTicks = plugin.getConfig().getInt("zeus_eye.levitation.duration_seconds", 5) * 20; List targets = new ArrayList<>( player.getWorld().getNearbyEntities(player.getLocation(), radius, radius, radius)); targets.removeIf(e -> !(e instanceof LivingEntity) || e.equals(player)); if (targets.isEmpty()) { player.sendMessage(plugin.prefix() + "§cNo targets nearby."); return; } for (Entity e : targets) { XPotion.matchXPotion("LEVITATION").ifPresent(xp -> ((LivingEntity) e).addPotionEffect(xp.buildPotionEffect(durationTicks, 1))); } player.sendMessage(plugin.prefix() + plugin.color( plugin.getConfig().getString("zeus_eye.levitation.message", "&e☁ Zeus Eye — foes suspended!"))); } // ─────── COOLDOWN HELPERS ─────── private boolean checkCooldown(Player player, String ability, int seconds, boolean isJet) { long cooldownMs = seconds * 1000L; Map map = cooldowns.getOrDefault(player.getUniqueId(), Map.of()); long last = map.getOrDefault(ability, 0L); long remaining = (last + cooldownMs) - System.currentTimeMillis(); if (remaining <= 0) return true; String msgKey = isJet ? "messages.jet_on_cooldown" : "messages.ability_on_cooldown"; String msg = plugin.color( plugin.getConfig().getString(msgKey, "&cCooldown: {seconds}s remaining") .replace("{seconds}", String.valueOf(remaining / 1000 + 1))); player.sendMessage(plugin.prefix() + msg); return false; } private void setCooldown(Player player, String ability) { cooldowns.computeIfAbsent(player.getUniqueId(), k -> new HashMap<>()) .put(ability, System.currentTimeMillis()); } private void sendActionBar(Player player, String message) { player.spigot().sendMessage(ChatMessageType.ACTION_BAR, new TextComponent(message)); } private com.rebelrp.plugin.data.PlayerData getDataManager(Player player) { return plugin.getDataManager().getData(player.getUniqueId()); } }