package com.yourname.miningcore.core; import com.cryptomorin.xseries.XSound; import com.cryptomorin.xseries.particles.XParticle; import com.yourname.miningcore.MiningCorePlugin; import com.yourname.miningcore.config.OreDefinition; import com.yourname.miningcore.util.FortuneUtil; import com.yourname.miningcore.util.MessageManager; import com.yourname.miningcore.util.ToolUtil; import org.bukkit.Bukkit; 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.inventory.ItemStack; import org.bukkit.scheduler.BukkitTask; import java.util.HashMap; import java.util.Iterator; import java.util.Map; import java.util.Random; import java.util.UUID; public class MiningManager { private final MiningCorePlugin plugin; private final Map sessions; private final Random random; private BukkitTask tickTask; public MiningManager(MiningCorePlugin plugin) { this.plugin = plugin; this.sessions = new HashMap<>(); this.random = new Random(); } public void startTickTask() { int tickInterval = plugin.getConfig().getInt("settings.tick-interval", 1); this.tickTask = Bukkit.getScheduler().runTaskTimer(plugin, () -> { Iterator iterator = sessions.values().iterator(); while (iterator.hasNext()) { MiningSession session = iterator.next(); if (!processMiningTick(session)) { iterator.remove(); } } }, 0L, tickInterval); } public void startMining(Player player, Block block) { UUID uuid = player.getUniqueId(); if (sessions.containsKey(uuid)) { MiningSession existing = sessions.get(uuid); if (existing.getBlock().equals(block)) { return; } stopMining(uuid); } OreDefinition ore = plugin.getBlockRegistry().getOre(block); if (ore == null) return; if (ore.getPermission() != null && !player.hasPermission(ore.getPermission())) { Map replacements = plugin.getMessageManager().createReplacements(); plugin.getMessageManager().send(player, "mining.no-permission", replacements); return; } if (ore.getToolRequirement() != null) { ItemStack tool = player.getInventory().getItemInMainHand(); String toolType = ToolUtil.getToolType(tool); int toolTier = ToolUtil.getToolTier(tool); if (!toolType.equals(ore.getToolRequirement().getToolType())) { Map replacements = plugin.getMessageManager().createReplacements(); replacements.put("tool", ore.getToolRequirement().getToolType()); plugin.getMessageManager().send(player, "mining.wrong-tool", replacements); return; } int requiredTier = ToolUtil.getTierFromName(ore.getToolRequirement().getMinTier()); if (toolTier < requiredTier) { Map replacements = plugin.getMessageManager().createReplacements(); replacements.put("tool", ToolUtil.getTierName(requiredTier) + " " + toolType); plugin.getMessageManager().send(player, "mining.wrong-tool", replacements); return; } } MiningSession session = new MiningSession(uuid, block, ore.getHealth()); sessions.put(uuid, session); if (plugin.getConfig().getBoolean("sounds.enabled", true)) { String soundName = plugin.getConfig().getString("sounds.mining-start", "BLOCK_STONE_HIT"); XSound.matchXSound(soundName).ifPresent(sound -> sound.play(player)); } Map replacements = plugin.getMessageManager().createReplacements(); plugin.getMessageManager().sendRaw(player, "mining.started", replacements); plugin.getPlayerDataManager().getData(player).updateLastMiningTime(); } private boolean processMiningTick(MiningSession session) { Player player = Bukkit.getPlayer(session.getPlayerUuid()); if (player == null || !player.isOnline()) { cleanupSession(session); return false; } Block block = session.getBlock(); if (block.getType() == Material.AIR) { cleanupSession(session); return false; } OreDefinition ore = plugin.getBlockRegistry().getOre(block); if (ore == null) { cleanupSession(session); return false; } if (!player.getWorld().equals(block.getWorld())) { cleanupSession(session); return false; } double maxDistance = plugin.getConfig().getDouble("settings.max-mining-distance", 6.0); Location playerLoc = player.getLocation(); Location blockLoc = block.getLocation().add(0.5, 0.5, 0.5); if (playerLoc.distance(blockLoc) > maxDistance) { Map replacements = plugin.getMessageManager().createReplacements(); plugin.getMessageManager().sendRaw(player, "mining.too-far", replacements); cleanupSession(session); return false; } double miningSpeed = plugin.getStatManager().getStat(player, StatType.MINING_SPEED); double damage = miningSpeed / ore.getStrength(); session.applyDamage(damage); int currentStage = session.getAnimationStage(); if (currentStage != session.getLastAnimationStage()) { plugin.getAnimationHandler().sendBlockBreakAnimation(player, block, currentStage); session.setLastAnimationStage(currentStage); } if (plugin.getConfig().getBoolean("sounds.enabled", true) && session.getTickCount() % 5 == 0) { String soundName = plugin.getConfig().getString("sounds.mining-progress", "BLOCK_STONE_HIT"); XSound.matchXSound(soundName).ifPresent(sound -> sound.play(player.getLocation())); } if (plugin.getConfig().getBoolean("particles.enabled", true) && session.getTickCount() % 3 == 0) { String particleName = plugin.getConfig().getString("particles.mining.type", "CRIT"); int count = plugin.getConfig().getInt("particles.mining.count", 5); double offset = plugin.getConfig().getDouble("particles.mining.offset", 0.5); XParticle.of(particleName).ifPresent(particle -> player.getWorld().spawnParticle(particle.get(), blockLoc, count, offset, offset, offset, 0.0) ); } double healthPercent = session.getHealthPercentage() * 100; Map replacements = plugin.getMessageManager().createReplacements(); replacements.put("percent", String.format("%.1f", healthPercent)); replacements.put("current", String.format("%.0f", session.getCurrentHealth())); replacements.put("max", String.format("%.0f", session.getMaxHealth())); ItemStack tool = player.getInventory().getItemInMainHand(); int fortuneLevel = FortuneUtil.getFortuneLevel(tool); if (fortuneLevel > 0) { replacements.put("fortune", String.valueOf(fortuneLevel)); plugin.getMessageManager().sendActionBar(player, "actionbar.fortune", replacements); } else { plugin.getMessageManager().sendActionBar(player, "actionbar.mining", replacements); } if (session.isBroken()) { breakBlock(player, session, ore); return false; } return true; } private void breakBlock(Player player, MiningSession session, OreDefinition ore) { Block block = session.getBlock(); plugin.getAnimationHandler().clearBlockBreakAnimation(player, block); block.setType(Material.AIR); int baseAmount = random.nextInt(ore.getDrops().getMax() - ore.getDrops().getMin() + 1) + ore.getDrops().getMin(); int fortuneBonus = 0; ItemStack tool = player.getInventory().getItemInMainHand(); int fortuneLevel = FortuneUtil.getFortuneLevel(tool); if (fortuneLevel > 0 && ore.getFortune() != null && ore.getFortune().isEnabled()) { if (player.hasPermission("miningcore.fortune")) { double baseChance = plugin.getConfig().getDouble("fortune.base-chance", 0.15); double perLevel = plugin.getConfig().getDouble("fortune.per-level-increase", 0.05); int maxBonus = ore.getFortune().getMaxBonus(); fortuneBonus = FortuneUtil.calculateBonus(fortuneLevel, baseChance, perLevel, maxBonus); } } int totalAmount = baseAmount + fortuneBonus; ItemStack drop = new ItemStack(ore.getDrops().getMaterial(), totalAmount); block.getWorld().dropItemNaturally(block.getLocation().add(0.5, 0.5, 0.5), drop); if (ore.getExperience() != null) { int xp = random.nextInt(ore.getExperience().getMax() - ore.getExperience().getMin() + 1) + ore.getExperience().getMin(); player.giveExp(xp); } Map replacements = plugin.getMessageManager().createReplacements(); replacements.put("amount", String.valueOf(totalAmount)); replacements.put("item", ore.getDrops().getMaterial().name()); plugin.getMessageManager().sendRaw(player, "mining.completed", replacements); if (plugin.getConfig().getBoolean("sounds.enabled", true)) { String soundName = plugin.getConfig().getString("sounds.mining-complete", "ENTITY_PLAYER_LEVELUP"); XSound.matchXSound(soundName).ifPresent(sound -> sound.play(player)); } if (plugin.getConfig().getBoolean("particles.enabled", true)) { String particleName = plugin.getConfig().getString("particles.complete.type", "EXPLOSION"); int count = plugin.getConfig().getInt("particles.complete.count", 20); double offset = plugin.getConfig().getDouble("particles.complete.offset", 0.5); Location particleLoc = block.getLocation().add(0.5, 0.5, 0.5); XParticle.of(particleName).ifPresent(particle -> player.getWorld().spawnParticle(particle.get(), particleLoc, count, offset, offset, offset, 0.1) ); } plugin.getPlayerDataManager().getData(player).incrementBlocksMined(); plugin.getPlayerDataManager().getData(player).addDrops(totalAmount); plugin.getPlayerDataManager().getData(player).addFortuneBonus(fortuneBonus); plugin.getPlayerDataManager().getData(player).addMiningTime(session.getElapsedMillis()); plugin.getOreRegenManager().scheduleRegen(block.getLocation(), ore); } private void cleanupSession(MiningSession session) { Player player = Bukkit.getPlayer(session.getPlayerUuid()); if (player != null && player.isOnline()) { plugin.getAnimationHandler().clearBlockBreakAnimation(player, session.getBlock()); } plugin.getPlayerDataManager().getData(session.getPlayerUuid()).addMiningTime(session.getElapsedMillis()); } public void stopMining(UUID uuid) { MiningSession session = sessions.remove(uuid); if (session != null) { cleanupSession(session); } } public boolean isMining(UUID uuid) { return sessions.containsKey(uuid); } public MiningSession getSession(UUID uuid) { return sessions.get(uuid); } public void shutdown() { if (tickTask != null) { tickTask.cancel(); } sessions.keySet().forEach(this::stopMining); sessions.clear(); } }