package com.invincibleflight.manager; import com.cryptomorin.xseries.XSound; import com.cryptomorin.xseries.particles.XParticle; import com.invincibleflight.InvincibleFlight; import lombok.Getter; import org.bukkit.Bukkit; import org.bukkit.Location; import org.bukkit.Material; import org.bukkit.block.Block; import org.bukkit.block.data.BlockData; import org.bukkit.entity.Player; import org.bukkit.scheduler.BukkitTask; import org.bukkit.util.Vector; import java.util.*; public class FlightManager { private final InvincibleFlight plugin; @Getter private final Set flyingPlayers; @Getter private final Set supersonicPlayers; private final Map flightTasks; private final Map playerVelocities; public FlightManager(InvincibleFlight plugin) { this.plugin = plugin; this.flyingPlayers = new HashSet<>(); this.supersonicPlayers = new HashSet<>(); this.flightTasks = new HashMap<>(); this.playerVelocities = new HashMap<>(); } public void enableFlight(Player player) { if (flyingPlayers.contains(player.getUniqueId())) { return; } if (!plugin.getConfigManager().isWorldAllowed(player.getWorld())) { return; } flyingPlayers.add(player.getUniqueId()); player.setAllowFlight(true); playerVelocities.put(player.getUniqueId(), new Vector(0, 0, 0)); startFlightTask(player); } public void disableFlight(Player player) { UUID uuid = player.getUniqueId(); if (!flyingPlayers.contains(uuid)) { return; } flyingPlayers.remove(uuid); supersonicPlayers.remove(uuid); playerVelocities.remove(uuid); if (flightTasks.containsKey(uuid)) { flightTasks.get(uuid).cancel(); flightTasks.remove(uuid); } player.setAllowFlight(false); player.setFlying(false); } private void startFlightTask(Player player) { UUID uuid = player.getUniqueId(); if (flightTasks.containsKey(uuid)) { flightTasks.get(uuid).cancel(); } int interval = plugin.getConfigManager().getSpeedUpdateInterval(); BukkitTask task = Bukkit.getScheduler().runTaskTimer(plugin, () -> { if (!player.isOnline() || !flyingPlayers.contains(uuid)) { disableFlight(player); return; } if (!player.isFlying()) { return; } boolean isSneaking = player.isSneaking(); if (isSneaking && !supersonicPlayers.contains(uuid)) { activateSupersonic(player); } else if (!isSneaking && supersonicPlayers.contains(uuid)) { deactivateSupersonic(player); } if (isSneaking) { applySupersonicFlight(player); } else { applyNormalFlight(player); } if (plugin.getConfigManager().isRealisticRotation()) { updatePlayerRotation(player); } }, 0L, interval); flightTasks.put(uuid, task); } private void activateSupersonic(Player player) { UUID uuid = player.getUniqueId(); if (!player.hasPermission("invincibleflight.destruction")) { return; } supersonicPlayers.add(uuid); String message = plugin.getConfigManager().getMessage("supersonic-activated"); player.sendMessage(message); if (plugin.getConfigManager().isSoundsEnabled()) { XSound.matchXSound("ENTITY_DRAGON_FIREBALL_EXPLODE").ifPresent(sound -> sound.play(player)); XSound.matchXSound("ENTITY_LIGHTNING_BOLT_THUNDER").ifPresent(sound -> sound.play(player, 0.5f, 1.5f)); } } private void deactivateSupersonic(Player player) { supersonicPlayers.remove(player.getUniqueId()); } private void applyNormalFlight(Player player) { UUID uuid = player.getUniqueId(); Vector currentVel = playerVelocities.getOrDefault(uuid, new Vector(0, 0, 0)); Location loc = player.getLocation(); Vector direction = loc.getDirection(); double baseSpeed = plugin.getConfigManager().getNormalSpeed(); Vector inputVelocity = player.getVelocity(); boolean hasInput = inputVelocity.length() > 0.15; Vector newVelocity; if (hasInput) { newVelocity = direction.clone().multiply(baseSpeed); } else if (plugin.getConfigManager().isHoverMode()) { newVelocity = currentVel.clone().multiply(plugin.getConfigManager().getFriction()); if (newVelocity.length() < 0.05) { newVelocity = new Vector(0, 0, 0); } } else { newVelocity = direction.clone().multiply(baseSpeed); } playerVelocities.put(uuid, newVelocity); player.setVelocity(newVelocity); } private void applySupersonicFlight(Player player) { UUID uuid = player.getUniqueId(); Location loc = player.getLocation(); Vector direction = loc.getDirection(); double speed = plugin.getConfigManager().getSupersonicSpeed(); Vector velocity = direction.multiply(speed); playerVelocities.put(uuid, velocity); player.setVelocity(velocity); if (plugin.getConfigManager().isSoundBarrierEnabled()) { destroyNearbyBlocks(player); } if (plugin.getConfigManager().isParticlesEnabled()) { spawnSupersonicParticles(player); } if (plugin.getConfigManager().isSoundsEnabled()) { XSound.matchXSound("ENTITY_GENERIC_EXPLODE").ifPresent(sound -> sound.play(player.getLocation(), 0.3f, 2.0f)); } } private void updatePlayerRotation(Player player) { Vector velocity = player.getVelocity(); if (velocity.length() < 0.1) { return; } Location loc = player.getLocation().clone(); double horizontalLength = Math.sqrt(velocity.getX() * velocity.getX() + velocity.getZ() * velocity.getZ()); if (horizontalLength < 0.01) { return; } double pitch = -Math.toDegrees(Math.atan2(velocity.getY(), horizontalLength)); pitch = Math.max(-90, Math.min(90, pitch)); loc.setPitch((float) pitch); player.teleport(loc); } private void destroyNearbyBlocks(Player player) { if (!player.hasPermission("invincibleflight.destruction")) { return; } Location loc = player.getLocation(); int minRadius = plugin.getConfigManager().getMinRadius(); int maxRadius = plugin.getConfigManager().getMaxRadius(); int radius = minRadius + new Random().nextInt(maxRadius - minRadius + 1); Set protectedBlocks = plugin.getConfigManager().getProtectedBlocks(); List newBlocks = new ArrayList<>(); for (int x = -radius; x <= radius; x++) { for (int y = -radius; y <= radius; y++) { for (int z = -radius; z <= radius; z++) { Location blockLoc = loc.clone().add(x, y, z); if (blockLoc.distance(loc) > radius) { continue; } Block block = blockLoc.getBlock(); Material type = block.getType(); if (type == Material.AIR || type == Material.BEDROCK) { continue; } if (protectedBlocks.contains(type)) { continue; } BlockData blockData = block.getBlockData().clone(); newBlocks.add(new BlockRegenData(block.getLocation().clone(), blockData)); block.setType(Material.AIR, false); } } } if (plugin.getConfigManager().isRegenerationEnabled() && !newBlocks.isEmpty()) { scheduleRegeneration(newBlocks); } } private void scheduleRegeneration(List blocks) { int delaySeconds = plugin.getConfigManager().getRegenerationDelay(); long delayTicks = delaySeconds * 20L; if (plugin.getConfigManager().isGradualRegeneration()) { Bukkit.getScheduler().runTaskLater(plugin, () -> { regenerateBlocksGradually(new ArrayList<>(blocks)); }, delayTicks); } else { Bukkit.getScheduler().runTaskLater(plugin, () -> { for (BlockRegenData data : blocks) { data.regenerate(); } }, delayTicks); } } private void regenerateBlocksGradually(List blocks) { if (blocks.isEmpty()) { return; } int speed = plugin.getConfigManager().getRegenerationSpeed(); int blocksPerTick = Math.max(1, blocks.size() / 100); Bukkit.getScheduler().runTaskTimer(plugin, new org.bukkit.scheduler.BukkitRunnable() { private int index = 0; @Override public void run() { if (index >= blocks.size()) { cancel(); return; } for (int i = 0; i < blocksPerTick && index < blocks.size(); i++, index++) { blocks.get(index).regenerate(); } } }, 0L, speed); } private void spawnSupersonicParticles(Player player) { Location loc = player.getLocation(); XParticle.of("EXPLOSION_LARGE").ifPresent(particle -> { loc.getWorld().spawnParticle(particle.get(), loc, 2, 0.5, 0.5, 0.5, 0.1); }); XParticle.of("CLOUD").ifPresent(particle -> { loc.getWorld().spawnParticle(particle.get(), loc, 10, 1.0, 1.0, 1.0, 0.1); }); XParticle.of("SONIC_BOOM").ifPresent(particle -> { loc.getWorld().spawnParticle(particle.get(), loc, 1); }); } public boolean isFlying(Player player) { return flyingPlayers.contains(player.getUniqueId()); } public boolean isSupersonic(Player player) { return supersonicPlayers.contains(player.getUniqueId()); } public void shutdown() { for (BukkitTask task : flightTasks.values()) { task.cancel(); } flightTasks.clear(); for (UUID uuid : new HashSet<>(flyingPlayers)) { Player player = Bukkit.getPlayer(uuid); if (player != null && player.isOnline()) { disableFlight(player); } } flyingPlayers.clear(); supersonicPlayers.clear(); playerVelocities.clear(); } private static class BlockRegenData { private final Location location; private final BlockData blockData; public BlockRegenData(Location location, BlockData blockData) { this.location = location; this.blockData = blockData; } public void regenerate() { Block block = location.getBlock(); if (block.getType() == Material.AIR) { block.setBlockData(blockData, false); } } } }