package com.vanguard.deathrite.ritual; import com.vanguard.deathrite.VanguardPlugin; import com.vanguard.deathrite.config.ConfigManager; import com.vanguard.deathrite.model.RitualData; import com.vanguard.deathrite.storage.BanStorage; import com.vanguard.deathrite.storage.RitualStorage; import com.vanguard.deathrite.util.ColorUtil; import com.vanguard.deathrite.webhook.DiscordWebhook; import net.kyori.adventure.text.Component; import net.kyori.adventure.title.Title; import org.bukkit.*; import org.bukkit.attribute.Attribute; import org.bukkit.attribute.AttributeInstance; import org.bukkit.entity.Player; import org.bukkit.scheduler.BukkitRunnable; import org.bukkit.scheduler.BukkitTask; import java.util.*; import java.util.concurrent.ConcurrentHashMap; public class RitualManager { private final VanguardPlugin plugin; private final ConfigManager config; private final BanStorage banStorage; private final RitualStorage ritualStorage; private final DiscordWebhook discordWebhook; private final ConcurrentHashMap activeRituals = new ConcurrentHashMap<>(); private final Map chunkUnloadTimes = new HashMap<>(); public RitualManager(VanguardPlugin plugin, ConfigManager config, BanStorage banStorage, RitualStorage ritualStorage, DiscordWebhook discordWebhook) { this.plugin = plugin; this.config = config; this.banStorage = banStorage; this.ritualStorage = ritualStorage; this.discordWebhook = discordWebhook; } public void startRitual(UUID targetUuid, String targetName, UUID initiatorUuid, String initiatorName, Location altarCenter) { long now = System.currentTimeMillis(); int durationMinutes = config.getRitualDurationMinutes(); RitualData ritual = new RitualData(targetUuid, targetName, initiatorUuid, initiatorName, altarCenter, now, durationMinutes); // Build the 9 altar block locations List altarBlocks = new ArrayList<>(); Location center = altarCenter.getBlock().getLocation(); for (int dx = -1; dx <= 1; dx++) { for (int dz = -1; dz <= 1; dz++) { altarBlocks.add(center.clone().add(dx, 0, dz)); } } ritual.setAltarBlocks(altarBlocks); // Effects task if (config.hasParticles() || config.hasSounds()) { BukkitTask effectsTask = new BukkitRunnable() { int tick = 0; boolean firstBroadcastDone = false; @Override public void run() { if (!activeRituals.containsKey(targetUuid)) { this.cancel(); return; } tick++; if (config.hasParticles() && tick % 10 == 0) { Location loc = ritual.getAltarCenter().add(0, 1, 0); World world = loc.getWorld(); if (world != null) { world.spawnParticle(Particle.SOUL_FIRE_FLAME, loc, 8, 1.5, 0.5, 1.5, 0); } } if (config.hasSounds() && tick % 400 == 0) { Location loc = ritual.getAltarCenter(); World world = loc.getWorld(); if (world != null) { world.playSound(loc, Sound.BLOCK_BEACON_AMBIENT, 0.5f, 0.8f); } } if (config.hasElderGuardianOnStart() && !firstBroadcastDone && tick >= 1) { firstBroadcastDone = true; for (Player p : Bukkit.getOnlinePlayers()) { p.playSound(p.getLocation(), Sound.ENTITY_ELDER_GUARDIAN_CURSE, 1.0f, 1.0f); } } } }.runTaskTimer(plugin, 0L, 2L); // every 2 ticks (10 per second... actually want every 10 ticks for particles) // Wait, I need to rethink this. 2L is every 2 ticks = 10 times/sec. I want particles every 10 ticks. // Let me change: runTaskTimer(plugin, 0L, 2L) but check tick % 5 for particle (2*5=10 ticks) // Actually let me just use runTaskTimer(plugin, 0L, 2L) and adjust my modulo checks. // With 2-tick interval: tick%5 for 10-tick particles, tick%200 for 400-tick sounds ritual.setEffectsTask(effectsTask); } // Broadcast task int broadcastIntervalTicks = config.getBroadcastIntervalMinutes() * 60 * 20; BukkitTask broadcastTask = new BukkitRunnable() { @Override public void run() { if (!activeRituals.containsKey(targetUuid)) { this.cancel(); return; } broadcastCoordinate(ritual); checkChunkUnload(ritual); } }.runTaskTimer(plugin, broadcastIntervalTicks, broadcastIntervalTicks); ritual.setBroadcastTask(broadcastTask); // Completion task long completionDelay = durationMinutes * 60L * 20L; BukkitTask completionTask = new BukkitRunnable() { @Override public void run() { completeRitual(ritual); } }.runTaskLater(plugin, completionDelay); ritual.setCompletionTask(completionTask); activeRituals.put(targetUuid, ritual); ritualStorage.saveRitual(ritual); // Broadcast start broadcastRitualStart(ritual); // Title to initiator Player initiator = Bukkit.getPlayer(initiatorUuid); if (initiator != null && initiator.isOnline()) { initiator.showTitle(Title.title( ColorUtil.colorize(config.getMessage("ritual_start_title")), ColorUtil.colorize(config.getMessage("ritual_start_subtitle") .replace("{duration}", String.valueOf(durationMinutes))) )); } // Discord webhook Location loc = ritual.getAltarCenter(); discordWebhook.sendRitualStart(targetName, targetUuid.toString(), initiatorName, loc.getBlockX(), loc.getBlockY(), loc.getBlockZ(), loc.getWorld().getName(), durationMinutes); } private void broadcastRitualStart(RitualData ritual) { Location loc = ritual.getAltarCenter(); String message = config.getMessage("ritual_start_broadcast") .replace("{target_name}", ritual.getTargetName()) .replace("{initiator_name}", ritual.getInitiatorName()) .replace("{x}", String.valueOf(loc.getBlockX())) .replace("{y}", String.valueOf(loc.getBlockY())) .replace("{z}", String.valueOf(loc.getBlockZ())) .replace("{world}", loc.getWorld().getName()) .replace("{duration}", String.valueOf(ritual.getDurationMinutes())); Component component = ColorUtil.colorize(message); for (Player p : Bukkit.getOnlinePlayers()) { p.sendMessage(component); } } private void broadcastCoordinate(RitualData ritual) { Location loc = ritual.getAltarCenter(); long remaining = ritual.getRemainingSeconds(); String timeStr = formatTime(remaining); String message = config.getMessage("coordinate_broadcast") .replace("{target_name}", ritual.getTargetName()) .replace("{x}", String.valueOf(loc.getBlockX())) .replace("{y}", String.valueOf(loc.getBlockY())) .replace("{z}", String.valueOf(loc.getBlockZ())) .replace("{world}", loc.getWorld().getName()) .replace("{time_remaining}", timeStr); Component component = ColorUtil.colorize(message); for (Player p : Bukkit.getOnlinePlayers()) { p.sendMessage(component); } } private String formatTime(long seconds) { long mins = seconds / 60; long secs = seconds % 60; return mins + "m " + secs + "s"; } public void failRitual(UUID targetUuid, String reason) { RitualData ritual = activeRituals.remove(targetUuid); if (ritual == null) return; // Cancel tasks cancelTasks(ritual); // Remove from storage ritualStorage.removeRitual(targetUuid); // Broadcast failure Location loc = ritual.getAltarCenter(); String message = config.getMessage("ritual_failure_broadcast") .replace("{target_name}", ritual.getTargetName()) .replace("{x}", String.valueOf(loc.getBlockX())) .replace("{y}", String.valueOf(loc.getBlockY())) .replace("{z}", String.valueOf(loc.getBlockZ())); Component component = ColorUtil.colorize(message); for (Player p : Bukkit.getOnlinePlayers()) { p.sendMessage(component); } // Discord webhook discordWebhook.sendRitualFailure(ritual.getTargetName(), loc.getBlockX(), loc.getBlockY(), loc.getBlockZ()); } public void completeRitual(RitualData ritual) { UUID targetUuid = ritual.getTargetUuid(); // Double-check ritual is still active (might have been failed) if (!activeRituals.containsKey(targetUuid)) return; activeRituals.remove(targetUuid); // Cancel tasks cancelTasks(ritual); // Remove from storage ritualStorage.removeRitual(targetUuid); // Unban banStorage.unban(targetUuid); // Apply HP penalty and teleport Player target = Bukkit.getPlayer(targetUuid); if (target != null && target.isOnline()) { applyHpPenalty(target); teleportPlayer(target, ritual); target.showTitle(Title.title( ColorUtil.colorize(config.getMessage("revival_title")), ColorUtil.colorize(config.getMessage("revival_subtitle")) )); } else { // Offline revival - store pending banStorage.setPendingRevival(targetUuid, config.getHpPenalty()); } banStorage.incrementRevivals(targetUuid); // Broadcast success Location loc = ritual.getAltarCenter(); String message = config.getMessage("revival_success_broadcast") .replace("{target_name}", ritual.getTargetName()) .replace("{initiator_name}", ritual.getInitiatorName()); Component component = ColorUtil.colorize(message); for (Player p : Bukkit.getOnlinePlayers()) { p.sendMessage(component); } // Discord webhook discordWebhook.sendRevivalSuccess(ritual.getTargetName(), targetUuid.toString(), ritual.getInitiatorName()); } private void applyHpPenalty(Player player) { AttributeInstance attr = player.getAttribute(Attribute.MAX_HEALTH); if (attr == null) return; double currentMax = attr.getBaseValue(); double penalty = config.getHpPenalty(); double floor = config.getMinMaxHealth(); double newMax = Math.max(floor, currentMax - penalty); attr.setBaseValue(newMax); if (player.getHealth() > newMax) { player.setHealth(newMax); } } private void teleportPlayer(Player player, RitualData ritual) { String spawnType = config.getSpawnLocation(); Location target; switch (spawnType) { case "ALTAR": target = ritual.getAltarCenter().add(0, 1, 0); target.setYaw(player.getLocation().getYaw()); target.setPitch(player.getLocation().getPitch()); break; case "LAST_DEATH": { Location deathLoc = banStorage.getDeathLocation(ritual.getTargetUuid()); target = deathLoc != null ? deathLoc : player.getWorld().getSpawnLocation(); break; } case "SPAWN": default: target = player.getWorld().getSpawnLocation(); break; } player.teleport(target); } private void cancelTasks(RitualData ritual) { if (ritual.getBroadcastTask() != null) ritual.getBroadcastTask().cancel(); if (ritual.getCompletionTask() != null) ritual.getCompletionTask().cancel(); if (ritual.getEffectsTask() != null) ritual.getEffectsTask().cancel(); } public boolean isActive(UUID targetUuid) { return activeRituals.containsKey(targetUuid); } public RitualData getRitual(UUID targetUuid) { return activeRituals.get(targetUuid); } public Collection getActiveRituals() { return activeRituals.values(); } // Chunk unload tracking public void markChunkUnloaded(String world, int chunkX, int chunkZ) { String key = world + ":" + chunkX + ":" + chunkZ; chunkUnloadTimes.put(key, System.currentTimeMillis()); } public void clearChunkUnloaded(String world, int chunkX, int chunkZ) { String key = world + ":" + chunkX + ":" + chunkZ; chunkUnloadTimes.remove(key); } private void checkChunkUnload(RitualData ritual) { Location center = ritual.getAltarCenter(); String worldName = center.getWorld().getName(); int chunkX = center.getBlockX() >> 4; int chunkZ = center.getBlockZ() >> 4; String key = worldName + ":" + chunkX + ":" + chunkZ; Long unloadTime = chunkUnloadTimes.get(key); if (unloadTime != null) { long elapsed = System.currentTimeMillis() - unloadTime; long graceMillis = config.getChunkUnloadGraceSeconds() * 1000L; if (elapsed > graceMillis) { failRitual(ritual.getTargetUuid(), "chunk_unloaded"); } } } // Load rituals from storage (on server restart) public void loadFromStorage() { Map saved = ritualStorage.loadAllRituals(); for (Map.Entry entry : saved.entrySet()) { RitualData ritual = entry.getValue(); long elapsed = System.currentTimeMillis() - ritual.getStartMillis(); long durationMs = ritual.getDurationMillis(); if (elapsed >= durationMs) { // Ritual expired while server was down - fail it ritualStorage.removeRitual(ritual.getTargetUuid()); plugin.getLogger().info("Ritual for " + ritual.getTargetName() + " expired during server downtime."); continue; } long remainingTicks = (durationMs - elapsed) / 50L; // Rebuild altar blocks List altarBlocks = new ArrayList<>(); Location center = ritual.getAltarCenter().getBlock().getLocation(); for (int dx = -1; dx <= 1; dx++) { for (int dz = -1; dz <= 1; dz++) { altarBlocks.add(center.clone().add(dx, 0, dz)); } } ritual.setAltarBlocks(altarBlocks); // Effects task if (config.hasParticles() || config.hasSounds()) { BukkitTask effectsTask = new BukkitRunnable() { int tick = 0; @Override public void run() { if (!activeRituals.containsKey(ritual.getTargetUuid())) { this.cancel(); return; } tick++; if (config.hasParticles() && tick % 5 == 0) { Location loc = ritual.getAltarCenter().add(0, 1, 0); World world = loc.getWorld(); if (world != null) { world.spawnParticle(Particle.SOUL_FIRE_FLAME, loc, 8, 1.5, 0.5, 1.5, 0); } } if (config.hasSounds() && tick % 200 == 0) { Location loc = ritual.getAltarCenter(); World world = loc.getWorld(); if (world != null) { world.playSound(loc, Sound.BLOCK_BEACON_AMBIENT, 0.5f, 0.8f); } } } }.runTaskTimer(plugin, 0L, 2L); ritual.setEffectsTask(effectsTask); } // Broadcast task int broadcastIntervalTicks = config.getBroadcastIntervalMinutes() * 60 * 20; BukkitTask broadcastTask = new BukkitRunnable() { @Override public void run() { if (!activeRituals.containsKey(ritual.getTargetUuid())) { this.cancel(); return; } broadcastCoordinate(ritual); checkChunkUnload(ritual); } }.runTaskTimer(plugin, broadcastIntervalTicks, broadcastIntervalTicks); ritual.setBroadcastTask(broadcastTask); // Completion task BukkitTask completionTask = new BukkitRunnable() { @Override public void run() { completeRitual(ritual); } }.runTaskLater(plugin, remainingTicks); ritual.setCompletionTask(completionTask); activeRituals.put(ritual.getTargetUuid(), ritual); plugin.getLogger().info("Restored ritual for " + ritual.getTargetName() + " with " + (remainingTicks / 20 / 60) + " minutes remaining."); } } public void shutdown() { for (RitualData ritual : activeRituals.values()) { cancelTasks(ritual); ritualStorage.saveRitual(ritual); } activeRituals.clear(); chunkUnloadTimes.clear(); } }