package com.wemmbus.orbital.manager; import com.cryptomorin.xseries.XMaterial; import com.wemmbus.orbital.WemmbusOrbitalPlugin; import com.wemmbus.orbital.data.TNTPlacement; import org.bukkit.Location; import org.bukkit.Material; import org.bukkit.World; import org.bukkit.block.Block; import org.bukkit.entity.TNTPrimed; import org.bukkit.scheduler.BukkitRunnable; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ThreadLocalRandom; public class TNTPlacementManager { private final WemmbusOrbitalPlugin plugin; private final List pendingPlacements; private final List placedBlocks; private BukkitRunnable placementTask; private BukkitRunnable primingTask; public TNTPlacementManager(WemmbusOrbitalPlugin plugin) { this.plugin = plugin; this.pendingPlacements = new ArrayList<>(); this.placedBlocks = new ArrayList<>(); } public void schedulePlacement(Location location, int fuseTicks, long delayTicks) { TNTPlacement placement = new TNTPlacement(location, fuseTicks, delayTicks); pendingPlacements.add(placement); } public void startBatchPlacement() { if (placementTask != null && !placementTask.isCancelled()) { return; } placementTask = new BukkitRunnable() { @Override public void run() { if (pendingPlacements.isEmpty()) { cancel(); return; } int cap = plugin.getConfigManager().getTNTPerTickCap(); int placed = 0; List toRemove = new ArrayList<>(); for (TNTPlacement placement : pendingPlacements) { if (placed >= cap) { break; } if (placement.getScheduledTime() <= 0) { Location loc = placement.getLocation(); Block block = loc.getBlock(); if (isValidPlacement(block)) { XMaterial.matchXMaterial("TNT").ifPresent(xMat -> { Material tnt = xMat.parseMaterial(); if (tnt != null) { block.setType(tnt); placedBlocks.add(loc.clone()); } }); placed++; } toRemove.add(placement); } else { placement.setScheduledTime(placement.getScheduledTime() - 1); } } pendingPlacements.removeAll(toRemove); } }; placementTask.runTaskTimer(plugin, 0L, 1L); } public void startBatchPriming(double minDelaySeconds, double maxDelaySeconds) { if (primingTask != null && !primingTask.isCancelled()) { return; } long minDelayTicks = (long) (minDelaySeconds * 20); long maxDelayTicks = (long) (maxDelaySeconds * 20); long delayTicks = ThreadLocalRandom.current().nextLong(minDelayTicks, maxDelayTicks + 1); primingTask = new BukkitRunnable() { @Override public void run() { if (placedBlocks.isEmpty()) { cancel(); return; } int cap = plugin.getConfigManager().getBatchPrimingLimitPerTick(); int primed = 0; List toRemove = new ArrayList<>(); for (Location loc : placedBlocks) { if (primed >= cap) { break; } Block block = loc.getBlock(); XMaterial tntMat = XMaterial.matchXMaterial(block.getType()); if (tntMat != null && tntMat.name().equals("TNT")) { block.setType(Material.AIR); World world = loc.getWorld(); if (world != null) { TNTPrimed tnt = world.spawn(loc.add(0.5, 0, 0.5), TNTPrimed.class); int fuseTicks = plugin.getConfigManager().getNukePrimedFuseTicks(); tnt.setFuseTicks(fuseTicks); } primed++; } toRemove.add(loc); } placedBlocks.removeAll(toRemove); } }; primingTask.runTaskLater(plugin, delayTicks); } public void startCascadePriming(double minDelaySeconds, double maxDelaySeconds, List> layers) { new BukkitRunnable() { int currentLayer = 0; @Override public void run() { if (currentLayer >= layers.size()) { cancel(); return; } List layer = layers.get(currentLayer); int cap = plugin.getConfigManager().getBatchPrimingLimitPerTick(); int primed = 0; for (Location loc : layer) { if (primed >= cap) { break; } Block block = loc.getBlock(); XMaterial tntMat = XMaterial.matchXMaterial(block.getType()); if (tntMat != null && tntMat.name().equals("TNT")) { block.setType(Material.AIR); World world = loc.getWorld(); if (world != null) { TNTPrimed tnt = world.spawn(loc.add(0.5, 0, 0.5), TNTPrimed.class); int fuseTicks = plugin.getConfigManager().getStabPrimedFuseTicks(); tnt.setFuseTicks(fuseTicks); } primed++; } } currentLayer++; long minDelayTicks = (long) (minDelaySeconds * 20); long maxDelayTicks = (long) (maxDelaySeconds * 20); long delayTicks = ThreadLocalRandom.current().nextLong(minDelayTicks, maxDelayTicks + 1); new BukkitRunnable() { @Override public void run() { } }.runTaskLater(plugin, delayTicks); } }.runTaskTimer(plugin, 0L, (long) (minDelaySeconds * 20)); } public boolean isValidPlacement(Block block) { if (block == null || block.getType().isSolid()) { return false; } return true; } public void clearPending() { pendingPlacements.clear(); placedBlocks.clear(); } public void shutdown() { if (placementTask != null) { placementTask.cancel(); } if (primingTask != null) { primingTask.cancel(); } clearPending(); } }