package com.worldhatesme.manager; import com.worldhatesme.WorldHatesMe; import com.worldhatesme.event.GameEvent; import com.worldhatesme.event.negative.*; import com.worldhatesme.event.positive.*; import org.bukkit.Bukkit; import org.bukkit.entity.Player; import org.bukkit.scheduler.BukkitTask; import java.util.ArrayList; import java.util.LinkedList; import java.util.List; import java.util.Queue; import java.util.Random; public class EventManager { private final WorldHatesMe plugin; private final Random random = new Random(); private BukkitTask eventTask; private boolean running = false; private final List negativeEvents = new ArrayList<>(); private final List positiveEvents = new ArrayList<>(); private final Queue eventHistory = new LinkedList<>(); private int consecutiveNegativeEvents = 0; public EventManager(WorldHatesMe plugin) { this.plugin = plugin; initializeEvents(); } private void initializeEvents() { negativeEvents.add(new LightningStrikeEvent(plugin)); negativeEvents.add(new SafeTeleportEvent(plugin)); negativeEvents.add(new MobAmbushEvent(plugin)); negativeEvents.add(new ChargedCreeperEvent(plugin)); negativeEvents.add(new NegativePotionEvent(plugin)); negativeEvents.add(new GroundCollapseEvent(plugin)); negativeEvents.add(new LavaHazardEvent(plugin)); negativeEvents.add(new InventoryShuffleEvent(plugin)); negativeEvents.add(new MobRageEvent(plugin)); negativeEvents.add(new DarknessScareEvent(plugin)); negativeEvents.add(new ExplosionEvent(plugin)); negativeEvents.add(new CursedArmorEvent(plugin)); negativeEvents.add(new HungerDrainEvent(plugin)); negativeEvents.add(new ItemDropEvent(plugin)); negativeEvents.add(new SlownessFieldEvent(plugin)); negativeEvents.add(new WeaknessSurgeEvent(plugin)); negativeEvents.add(new SkeletonSniperEvent(plugin)); negativeEvents.add(new CobwebTrapEvent(plugin)); negativeEvents.add(new FireBurstEvent(plugin)); negativeEvents.add(new InventoryScrambleEvent(plugin)); negativeEvents.add(new PhantomScreechEvent(plugin)); negativeEvents.add(new GravityJoltEvent(plugin)); negativeEvents.add(new InventoryFullDropEvent(plugin)); negativeEvents.add(new InventorySwapEvent(plugin)); negativeEvents.add(new AnvilRainEvent(plugin)); negativeEvents.add(new FallingBlockStormEvent(plugin)); negativeEvents.add(new GravityShiftEvent(plugin)); positiveEvents.add(new ResourceGiftEvent(plugin)); positiveEvents.add(new FoodDropEvent(plugin)); positiveEvents.add(new ArrowBundleEvent(plugin)); positiveEvents.add(new GearAssistanceEvent(plugin)); positiveEvents.add(new HealingPulseEvent(plugin)); positiveEvents.add(new ProtectiveBlessingEvent(plugin)); positiveEvents.add(new SwiftEscapeEvent(plugin)); positiveEvents.add(new RepairTouchEvent(plugin)); positiveEvents.add(new LuckyChestEvent(plugin)); positiveEvents.add(new OreDropEvent(plugin)); positiveEvents.add(new JackpotEvent(plugin)); positiveEvents.add(new PotionSupplyEvent(plugin)); } public void start() { if (running) { return; } running = true; int intervalTicks = plugin.getConfigManager().getEventInterval() * 20; plugin.getBossBarManager().startCountdown(); eventTask = Bukkit.getScheduler().runTaskTimer(plugin, () -> { for (Player player : Bukkit.getOnlinePlayers()) { triggerRandomEvent(player); } plugin.getBossBarManager().resetCountdown(); }, intervalTicks, intervalTicks); } public void stop() { if (!running) { return; } running = false; if (eventTask != null) { eventTask.cancel(); eventTask = null; } plugin.getBossBarManager().removeAll(); } public void restart() { stop(); eventHistory.clear(); consecutiveNegativeEvents = 0; start(); } private void triggerRandomEvent(Player player) { boolean forcePositive = false; if (plugin.getConfigManager().isPositiveGuaranteeEnabled()) { int guaranteeWindow = plugin.getConfigManager().getPositiveGuaranteeWithinEvents(); if (consecutiveNegativeEvents >= guaranteeWindow) { forcePositive = true; } } boolean isPositive = forcePositive; GameEvent selectedEvent = selectEventWithAntiRepeat(isPositive); if (selectedEvent == null) { return; } boolean success = executeWithReroll(selectedEvent, player, isPositive); if (success) { trackEventHistory(selectedEvent.getEventName()); if (isPositive) { consecutiveNegativeEvents = 0; } else { consecutiveNegativeEvents++; } } } private GameEvent selectEventWithAntiRepeat(boolean isPositive) { List eventPool = isPositive ? positiveEvents : negativeEvents; List enabledEvents = new ArrayList<>(); for (GameEvent event : eventPool) { if (event.isEnabled() && !isEventBlocked(event.getEventName())) { enabledEvents.add(event); } } if (enabledEvents.isEmpty()) { return null; } return enabledEvents.get(random.nextInt(enabledEvents.size())); } private boolean isEventBlocked(String eventName) { if (eventHistory.isEmpty()) { return false; } List historyList = new ArrayList<>(eventHistory); if (!historyList.isEmpty() && historyList.get(historyList.size() - 1).equals(eventName)) { return true; } int startIndex = Math.max(0, historyList.size() - 4); for (int i = startIndex; i < historyList.size(); i++) { if (historyList.get(i).equals(eventName)) { return true; } } return false; } private void trackEventHistory(String eventName) { eventHistory.add(eventName); if (eventHistory.size() > 4) { eventHistory.poll(); } } private boolean executeWithReroll(GameEvent event, Player player, boolean isPositive) { int maxAttempts = 3; for (int attempt = 0; attempt < maxAttempts; attempt++) { try { event.execute(player); return true; } catch (Exception e) { plugin.getLogger().warning("Event " + event.getEventName() + " failed on attempt " + (attempt + 1)); if (attempt < maxAttempts - 1) { GameEvent rerollEvent = selectEventWithAntiRepeat(isPositive); if (rerollEvent != null && !rerollEvent.getEventName().equals(event.getEventName())) { event = rerollEvent; } } } } return false; } public boolean isRunning() { return running; } }