package com.cropbugdefense.manager; import com.cropbugdefense.CropBugDefense; import com.cropbugdefense.bug.BugType; import com.cropbugdefense.bug.CropBug; import com.cryptomorin.xseries.XMaterial; import org.bukkit.Chunk; import org.bukkit.Location; import org.bukkit.Material; import org.bukkit.World; import org.bukkit.block.Block; import org.bukkit.entity.Player; import org.bukkit.scheduler.BukkitRunnable; import java.util.*; import java.util.concurrent.ConcurrentLinkedQueue; public class SpawnManager { private final CropBugDefense plugin; private final Random random = new Random(); private BukkitRunnable spawnTask; private final Queue pendingSpawns = new ConcurrentLinkedQueue<>(); public SpawnManager(CropBugDefense plugin) { this.plugin = plugin; } public void startSpawnTask() { if (!plugin.getConfig().getBoolean("spawn.enabled", true)) { return; } int interval = plugin.getConfig().getInt("spawn.check-interval", 180) * 20; spawnTask = new BukkitRunnable() { @Override public void run() { scanAndQueueSpawnsAsync(); } }; spawnTask.runTaskTimer(plugin, interval, interval); startBatchSpawner(); } public void stopSpawnTask() { if (spawnTask != null) { spawnTask.cancel(); } } private void startBatchSpawner() { int batchSize = plugin.getConfig().getInt("spawn.batch-size", 5); int batchDelay = plugin.getConfig().getInt("spawn.batch-delay", 30) * 20; new BukkitRunnable() { @Override public void run() { if (!plugin.getConfig().getBoolean("spawn.enabled", true)) { return; } int spawned = 0; while (!pendingSpawns.isEmpty() && spawned < batchSize) { SpawnData data = pendingSpawns.poll(); if (data != null && canSpawnAt(data.location)) { spawnBugAtLocation(data.location, data.bugType); spawned++; } } } }.runTaskTimer(plugin, batchDelay, batchDelay); } private void scanAndQueueSpawnsAsync() { new BukkitRunnable() { @Override public void run() { List allowedWorlds = plugin.getConfig().getStringList("spawn.allowed-worlds"); List foundLocations = new ArrayList<>(); for (World world : plugin.getServer().getWorlds()) { if (!allowedWorlds.contains(world.getName())) { continue; } for (Chunk chunk : world.getLoadedChunks()) { if (!hasPlayerNearby(chunk)) { continue; } foundLocations.addAll(scanChunkForCrops(chunk)); } } new BukkitRunnable() { @Override public void run() { pendingSpawns.addAll(foundLocations); } }.runTask(plugin); } }.runTaskAsynchronously(plugin); } private List scanChunkForCrops(Chunk chunk) { List locations = new ArrayList<>(); int minY = chunk.getWorld().getMinHeight(); int maxY = chunk.getWorld().getMaxHeight(); for (int x = 0; x < 16; x++) { for (int z = 0; z < 16; z++) { for (int y = minY; y < maxY; y++) { Block block = chunk.getBlock(x, y, z); BugType bugType = getBugTypeForCrop(block.getType()); if (bugType != null) { double chance = plugin.getConfig().getDouble("spawn.chance", 0.15); if (random.nextDouble() < chance) { double offsetX = 0.3 + (random.nextDouble() * 0.4); double offsetZ = 0.3 + (random.nextDouble() * 0.4); Location spawnLoc = block.getLocation().add(offsetX, 1.0, offsetZ); locations.add(new SpawnData(spawnLoc, bugType)); } } } } } return locations; } private BugType getBugTypeForCrop(Material material) { String name = material.name(); if (name.contains("CARROT") || name.contains("POTATO")) { return BugType.RAT; } if (name.contains("WHEAT") || name.contains("NETHER_WART") || name.contains("BEETROOT")) { return BugType.WORM; } if (name.equals("CACTUS") || name.equals("MELON")) { return BugType.FLY; } return null; } private boolean hasPlayerNearby(Chunk chunk) { if (!plugin.getConfig().getBoolean("spawn.require-player-nearby", true)) { return true; } double radius = plugin.getConfig().getDouble("spawn.player-nearby-radius", 64.0); Location chunkCenter = chunk.getBlock(8, 64, 8).getLocation(); for (Player player : chunk.getWorld().getPlayers()) { if (player.getLocation().distance(chunkCenter) <= radius) { return true; } } return false; } private boolean canSpawnAt(Location location) { if (!location.getChunk().isLoaded()) { return false; } if (!plugin.getWorldGuardHelper().canSpawnAt(location)) { return false; } double spawnRadius = plugin.getConfig().getDouble("spawn.spawn-radius", 10.0); int maxBugsPerRadius = plugin.getConfig().getInt("spawn.max-bugs-per-radius", 4); int nearbyBugs = 0; for (CropBug bug : plugin.getBugManager().getActiveBugs().values()) { Location bugLoc = bug.getLocation(); if (bugLoc != null && bugLoc.getWorld().equals(location.getWorld())) { if (bugLoc.distance(location) <= spawnRadius) { nearbyBugs++; } } } return nearbyBugs < maxBugsPerRadius; } public void spawnBugOnCrop(Block cropBlock) { BugType bugType = getBugTypeForCrop(cropBlock.getType()); if (bugType == null) { return; } double offsetX = 0.3 + (random.nextDouble() * 0.4); double offsetZ = 0.3 + (random.nextDouble() * 0.4); Location spawnLoc = cropBlock.getLocation().add(offsetX, 1.0, offsetZ); if (!canSpawnAt(spawnLoc)) { return; } spawnBugAtLocation(spawnLoc, bugType); } private void spawnBugAtLocation(Location location, BugType bugType) { CropBug bug = plugin.getBugManager().spawnBug(location, bugType); if (bug != null) { playSpawnSound(bug); } } private void playSpawnSound(CropBug bug) { String soundName = plugin.getConfig().getString("bugs." + bug.getType().getConfigKey() + ".spawn-sound"); if (soundName == null || soundName.isEmpty()) { return; } Location loc = bug.getLocation(); if (loc == null) { return; } com.cryptomorin.xseries.XSound.matchXSound(soundName).ifPresent(sound -> { sound.play(loc, 1.0f, 1.0f); }); } private static class SpawnData { final Location location; final BugType bugType; SpawnData(Location location, BugType bugType) { this.location = location; this.bugType = bugType; } } }