package com.blackmarket.drugs.manager; import com.blackmarket.drugs.BlackMarketDrugs; import com.blackmarket.drugs.model.ActiveEffect; import com.blackmarket.drugs.model.Drug; import com.blackmarket.drugs.model.DrugEffect; import com.blackmarket.drugs.model.DrugType; import com.cryptomorin.xseries.XSound; import com.cryptomorin.xseries.particles.XParticle; import org.bukkit.Bukkit; import org.bukkit.GameMode; import org.bukkit.entity.Player; import org.bukkit.scheduler.BukkitTask; import java.util.*; public class DrugEffectManager { private final BlackMarketDrugs plugin; private final Map> activeEffects; private final PlayerDataManager dataManager; private final ToleranceManager toleranceManager; private BukkitTask effectTask; public DrugEffectManager(BlackMarketDrugs plugin, PlayerDataManager dataManager, ToleranceManager toleranceManager) { this.plugin = plugin; this.dataManager = dataManager; this.toleranceManager = toleranceManager; this.activeEffects = new HashMap<>(); this.startEffectTask(); } private void startEffectTask() { this.effectTask = Bukkit.getScheduler().runTaskTimer(this.plugin, () -> { for (Player player : Bukkit.getOnlinePlayers()) { this.applyEffects(player); } }, 20L, 20L); } public void consumeDrug(Player player, Drug drug) { UUID playerId = player.getUniqueId(); double tolerance = this.toleranceManager.getTolerance(playerId, drug.getType()); if (this.checkOverdose(player, drug)) { this.handleOverdose(player, drug); return; } int duration = drug.getEffectiveDuration(tolerance); double effectMultiplier = drug.getEffectiveStrength(tolerance); ActiveEffect effect = new ActiveEffect(drug, System.currentTimeMillis(), duration, effectMultiplier); this.activeEffects.computeIfAbsent(playerId, k -> new ArrayList<>()).add(effect); this.toleranceManager.increaseTolerance(playerId, drug.getType()); this.dataManager.getPlayerData(playerId).incrementUsageCount(drug.getType()); this.dataManager.getPlayerData(playerId).setLastUsage(drug.getType(), System.currentTimeMillis()); player.sendMessage("§a§lDRUGS §8» §7You consumed " + drug.getType().getColor() + drug.getType().getDisplayName()); player.sendMessage("§8» §7Duration: §e" + duration + "s §8| §7Potency: §e" + String.format("%.0f", effectMultiplier * 100) + "%"); XSound.matchXSound("ENTITY_PLAYER_BURP").ifPresent(sound -> sound.play(player)); } private boolean checkOverdose(Player player, Drug drug) { int overdoseThreshold = this.plugin.getConfig().getInt("overdose.threshold", 3); long overdoseWindow = this.plugin.getConfig().getLong("overdose.window-seconds", 60) * 1000L; int recentUse = this.dataManager.getPlayerData(player.getUniqueId()).getRecentUsageCount(drug.getType(), overdoseWindow); List effects = this.activeEffects.get(player.getUniqueId()); if (effects != null) { long sameTypeCount = effects.stream() .filter(e -> e.getDrug().getType() == drug.getType()) .filter(e -> !e.isExpired()) .count(); return sameTypeCount + 1 >= overdoseThreshold; } return recentUse >= overdoseThreshold; } private void handleOverdose(Player player, Drug drug) { player.sendMessage("§c§lOVERDOSE! §7You took too much " + drug.getType().getDisplayName() + "!"); double damage = this.plugin.getConfig().getDouble("overdose.damage", 15.0); player.damage(damage); XSound.matchXSound("ENTITY_PLAYER_DEATH").ifPresent(sound -> sound.play(player)); Bukkit.getScheduler().runTaskLater(this.plugin, () -> { if (player.isOnline()) { player.setWalkSpeed(0.05f); Bukkit.getScheduler().runTaskLater(this.plugin, () -> { if (player.isOnline()) { player.setWalkSpeed(0.2f); } }, 100L); } }, 20L); } private void applyEffects(Player player) { UUID playerId = player.getUniqueId(); List effects = this.activeEffects.get(playerId); if (effects == null || effects.isEmpty()) { return; } effects.removeIf(ActiveEffect::isExpired); if (effects.isEmpty()) { this.activeEffects.remove(playerId); this.resetPlayerState(player); return; } double totalSpeedBonus = 0; double totalMiningBoost = 0; boolean hasDamageOverTime = false; boolean hasRegeneration = false; boolean hasConfusion = false; boolean hasVisualDistortion = false; for (ActiveEffect activeEffect : effects) { Drug drug = activeEffect.getDrug(); double multiplier = activeEffect.getEffectMultiplier(); double tolerance = this.toleranceManager.getTolerance(playerId, drug.getType()); for (DrugEffect effect : drug.getEffects()) { double strength = effect.getStrength() * multiplier; if (!effect.isPositive()) { strength *= (1.0 + tolerance); } switch (effect.getType()) { case SPEED: totalSpeedBonus += strength * 0.1; break; case MINING_BOOST: totalMiningBoost += strength; break; case DAMAGE_OVER_TIME: hasDamageOverTime = true; if (Math.random() < 0.1) { player.damage(strength * 0.5); } break; case REGENERATION: hasRegeneration = true; if (player.getHealth() < player.getMaxHealth() && Math.random() < 0.2) { player.setHealth(Math.min(player.getMaxHealth(), player.getHealth() + strength * 0.5)); } break; case CONFUSION: hasConfusion = true; break; case VISUAL_DISTORTION: hasVisualDistortion = true; this.spawnParticles(player); break; case JUMP_BOOST: break; case WEAKNESS: break; } } } float newSpeed = (float) Math.max(0.05, Math.min(1.0, 0.2 + totalSpeedBonus)); player.setWalkSpeed(newSpeed); if (hasVisualDistortion && Math.random() < 0.3) { this.spawnParticles(player); } } private void spawnParticles(Player player) { XParticle.of("PORTAL").ifPresent(particle -> { for (int i = 0; i < 5; i++) { double offsetX = (Math.random() - 0.5) * 2; double offsetY = Math.random() * 2; double offsetZ = (Math.random() - 0.5) * 2; player.getWorld().spawnParticle(particle.get(), player.getLocation().add(offsetX, offsetY, offsetZ), 1); } }); } private void resetPlayerState(Player player) { player.setWalkSpeed(0.2f); } public List getActiveEffects(UUID playerId) { return this.activeEffects.getOrDefault(playerId, new ArrayList<>()); } public double getMiningBoostMultiplier(Player player) { double boost = 0; List effects = this.activeEffects.get(player.getUniqueId()); if (effects == null) { return 1.0; } for (ActiveEffect activeEffect : effects) { if (activeEffect.isExpired()) { continue; } for (DrugEffect effect : activeEffect.getDrug().getEffects()) { if (effect.getType() == DrugEffect.EffectType.MINING_BOOST) { boost += effect.getStrength() * activeEffect.getEffectMultiplier(); } } } return 1.0 + boost; } public void clearEffects(UUID playerId) { this.activeEffects.remove(playerId); Player player = Bukkit.getPlayer(playerId); if (player != null) { this.resetPlayerState(player); } } public void shutdown() { if (this.effectTask != null) { this.effectTask.cancel(); } for (Player player : Bukkit.getOnlinePlayers()) { this.resetPlayerState(player); } } }