package com.soulsmp.ritual; import com.soulsmp.SoulSMP; import com.soulsmp.items.SoulArmour; import com.soulsmp.items.WeaponManager; import org.bukkit.*; import org.bukkit.boss.BarColor; import org.bukkit.boss.BarStyle; import org.bukkit.boss.BossBar; import org.bukkit.entity.*; import org.bukkit.inventory.ItemStack; import org.bukkit.potion.PotionEffect; import org.bukkit.potion.PotionEffectType; import org.bukkit.scheduler.BukkitRunnable; import org.bukkit.scheduler.BukkitTask; import java.util.*; public class RitualManager { // ── Constants ──────────────────────────────────────────────────────────── public static final long RITUAL_DURATION_TICKS = 18000L; // 15 minutes public static final int RADIUS = 40; // boundary for both players and mobs public static final int TOTAL_PHASES = 10; private final SoulSMP plugin; private final WeaponManager weaponManager; /** Tracks both crafted weapons AND armour pieces (one unique copy each). */ private final Set craftedItems = new HashSet<>(); private final Map activeRituals = new HashMap<>(); public RitualManager(SoulSMP plugin, WeaponManager weaponManager) { this.plugin = plugin; this.weaponManager = weaponManager; } public boolean isWeaponCrafted(String id) { return craftedItems.contains(id); } public boolean isInRitual(UUID uuid) { return activeRituals.containsKey(uuid); } public Set getCraftedWeapons() { return Collections.unmodifiableSet(craftedItems); } public void markWeaponCrafted(String id) { craftedItems.add(id); } /** * Forcibly removes an item (weapon OR armour) from the crafted set so it can be * reforged. Called by /destroyitem. Also broadcasts the "can be reforged" message. * Previously armour pieces were NOT removed because onWeaponDestroyed used * weaponManager.getWeaponId which returns null for armour — fixed here. */ public void markItemDestroyed(String itemId) { boolean wasCrafted = craftedItems.remove(itemId); String display = weaponDisplayName(itemId); // Only broadcast if it was actually tracked (cmd-given weapons are marked crafted, // so this will fire. If it wasn't tracked at all, silently allow re-craft.) if (wasCrafted) { Bukkit.broadcastMessage("§5[SoulSMP] §7" + display + " §4has been DESTROYED §7— it can be reforged."); for (Player p : Bukkit.getOnlinePlayers()) p.sendTitle("§4ITEM DESTROYED", "§7" + display + " can be reforged!", 10, 60, 20); } } /** Returns true if the given location is within RADIUS of any active ritual. */ public boolean isNearAnyRitual(Location loc) { if (loc.getWorld() == null) return false; // FIX: null-check world before equals() for (RitualState s : activeRituals.values()) { if (s.tableLocation.getWorld() == null) continue; // FIX: guard table world too if (loc.getWorld().equals(s.tableLocation.getWorld()) && loc.distanceSquared(s.tableLocation) <= (RADIUS * 2.0) * (RADIUS * 2.0)) return true; } return false; } // ── Public API ─────────────────────────────────────────────────────────── public void resetAllWeapons() { for (RitualState s : new ArrayList<>(activeRituals.values())) failRitual(s, "§cThe SMP has been reset by an admin."); activeRituals.clear(); craftedItems.clear(); int removed = 0; // 1. Online player inventories + ender chests for (Player p : Bukkit.getOnlinePlayers()) { removed += purgeInventory(p.getInventory()); removed += purgeInventory(p.getEnderChest()); p.updateInventory(); } // 2. World item-entity drops for (World w : Bukkit.getWorlds()) { for (Entity e : w.getEntities()) { if (e instanceof Item item && (weaponManager.isCustomWeapon(item.getItemStack()) || plugin.getSoulArmour().isAnySoulArmour(item.getItemStack()))) { e.remove(); removed++; } } } // 3. All loaded containers (chests, barrels, shulkers, hoppers, etc.) for (World w : Bukkit.getWorlds()) { for (var chunk : w.getLoadedChunks()) { for (org.bukkit.block.BlockState bs : chunk.getTileEntities()) { if (bs instanceof org.bukkit.inventory.InventoryHolder holder) { removed += purgeInventory(holder.getInventory()); } } } } // 4. Queue offline player cleanup on next login for (String id : WeaponManager.WEAPON_IDS) plugin.addPendingDestroy(id); for (String id : new String[]{"soul_helmet","soul_chestplate","soul_leggings","soul_boots", "end_helmet","end_chestplate","end_leggings","end_boots"}) plugin.addPendingDestroy(id); plugin.saveData(); Bukkit.broadcastMessage("§5[SoulSMP] §7All items reset. §a" + removed + " §7removed from inventories, containers, and world."); } private int purgeInventory(org.bukkit.inventory.Inventory inv) { if (inv == null) return 0; int count = 0; ItemStack[] contents = inv.getContents(); boolean dirty = false; for (int i = 0; i < contents.length; i++) { ItemStack item = contents[i]; if (item == null || item.getType() == org.bukkit.Material.AIR) continue; if (weaponManager.isCustomWeapon(item) || plugin.getSoulArmour().isAnySoulArmour(item)) { contents[i] = null; count++; dirty = true; } } if (dirty) inv.setContents(contents); return count; } public void onWeaponDestroyed(ItemStack stack) { // Works for weapons AND armour pieces String id = weaponManager.getWeaponId(stack); if (id == null) id = SoulArmour.getArmourId(stack); if (id == null) return; craftedItems.remove(id); String display = weaponDisplayName(id); Bukkit.broadcastMessage("§5[SoulSMP] §7" + display + " §4has been DESTROYED §7— it can be reforged."); for (Player p : Bukkit.getOnlinePlayers()) p.sendTitle("§4ITEM DESTROYED", "§7" + display + " can be reforged!", 10, 60, 20); } /** Safely returns consumed items to a player. Any overflow is dropped at their feet. */ private void returnItems(Player crafter, List consumed) { for (ItemStack s : consumed) { var leftover = crafter.getInventory().addItem(s); if (!leftover.isEmpty()) { leftover.values().forEach(item -> crafter.getWorld().dropItemNaturally(crafter.getLocation(), item)); } } } public boolean startRitual(Player crafter, Location tableLoc, String itemId, List consumed) { UUID uuid = crafter.getUniqueId(); if (activeRituals.containsKey(uuid)) { crafter.sendMessage("§5[SoulSMP] §cYou already have an active ritual."); returnItems(crafter, consumed); // FIX: use safe return helper return false; } if (isWeaponCrafted(itemId)) { crafter.sendMessage("§5[SoulSMP] §c" + weaponDisplayName(itemId) + " already exists in the world."); returnItems(crafter, consumed); // FIX: use safe return helper return false; } RitualState state = new RitualState(uuid, tableLoc, itemId, consumed); activeRituals.put(uuid, state); BossBar bar = Bukkit.createBossBar( "§5Ritual: " + weaponDisplayName(itemId) + " §7— §e" + formatTime(RITUAL_DURATION_TICKS / 20) + " §7remaining", BarColor.PURPLE, BarStyle.SEGMENTED_10); bar.setProgress(1.0); bar.addPlayer(crafter); bar.setVisible(true); state.ritualBar = bar; broadcastRitualStart(crafter, tableLoc, itemId); startCountdown(state); startBoundaryEnforcer(state); startAmbientParticles(state); spawnPhase(state); return true; } public void onCrafterDeath(UUID uuid) { RitualState state = activeRituals.get(uuid); if (state == null) return; failRitual(state, "§cThe crafter was slain! The ritual has failed."); } // ── Internal ───────────────────────────────────────────────────────────── private void broadcastRitualStart(Player crafter, Location loc, String itemId) { String display = weaponDisplayName(itemId); String bar = "§5§m "; Bukkit.broadcastMessage(bar); Bukkit.broadcastMessage("§5 ☠ §l§5RITUAL HAS BEGUN §r§5☠"); Bukkit.broadcastMessage("§f " + crafter.getName() + " §7is forging §5§l" + display); Bukkit.broadcastMessage("§7 Location: §e" + formatLoc(loc)); Bukkit.broadcastMessage("§c Hunt them down. Stop the ritual."); Bukkit.broadcastMessage(bar); for (Player p : Bukkit.getOnlinePlayers()) { p.sendTitle("§5☠ RITUAL BEGUN ☠", "§7" + crafter.getName() + " §7forges §5" + display, 10, 90, 25); p.playSound(p.getLocation(), Sound.ENTITY_WITHER_SPAWN, 1.2f, 0.4f); p.playSound(p.getLocation(), Sound.ENTITY_ENDER_DRAGON_GROWL, 0.6f, 0.5f); } // Visual burst at the crafting table if (loc != null && loc.getWorld() != null) { World w = loc.getWorld(); w.spawnParticle(Particle.SOUL, loc.clone().add(0,1,0), 20, 1.5, 1.0, 1.5, 0.05); w.spawnParticle(Particle.SOUL_FIRE_FLAME, loc.clone().add(0,1,0), 10, 1.0, 0.5, 1.0, 0.04); // Vertical pillar of souls for (int y = 0; y <= 3; y++) { Location pillar = loc.clone().add(0, y * 0.6, 0); w.spawnParticle(Particle.SOUL, pillar, 3, 0.3, 0.1, 0.3, 0.02); } } } private void startCountdown(RitualState state) { state.countdownTask = new BukkitRunnable() { long ticks = 0; @Override public void run() { if (!activeRituals.containsKey(state.crafterUUID)) { cancel(); return; } // FIX: O(1) key lookup instead of O(n) containsValue ticks += 20; if (state.ritualBar != null) { double progress = Math.max(0.0, 1.0 - ((double) ticks / RITUAL_DURATION_TICKS)); state.ritualBar.setProgress(progress); long remaining = Math.max(0, RITUAL_DURATION_TICKS - ticks); BarColor colour = progress > 0.5 ? BarColor.PURPLE : progress > 0.25 ? BarColor.YELLOW : BarColor.RED; state.ritualBar.setColor(colour); state.ritualBar.setTitle("§5Ritual: " + weaponDisplayName(state.itemId) + " §7— §e" + formatTime(remaining / 20) + " §7remaining"); Player c = Bukkit.getPlayer(state.crafterUUID); if (c != null && !state.ritualBar.getPlayers().contains(c)) state.ritualBar.addPlayer(c); } if (ticks % 1800 == 0) { long remaining = RITUAL_DURATION_TICKS - ticks; if (remaining > 0) broadcastMilestone(state, formatTime(remaining / 20)); } if (ticks >= RITUAL_DURATION_TICKS) { cancel(); // Timer expired — fail ONLY if phases aren't all done yet if (!state.allPhasesComplete) { failRitual(state, "§cTime's up! The ritual expired before all phases were cleared."); } // If allPhasesComplete, completeRitual was already called } } }.runTaskTimer(plugin, 20L, 20L); } private void startAmbientParticles(RitualState state) { state.ambientTask = new BukkitRunnable() { double angle = 0; double angle2 = 0; int tick = 0; @Override public void run() { if (!activeRituals.containsKey(state.crafterUUID)) { cancel(); return; } // FIX: O(1) key lookup instead of O(n) containsValue World world = state.tableLocation.getWorld(); if (world == null) return; Location base = state.tableLocation; // ── Layer 1: tight inner soul ring (breathing radius) ────────── double innerR = 1.8 + Math.sin(tick * 0.12) * 0.4; for (int i = 0; i < 10; i++) { double a = angle + (2 * Math.PI / 10) * i; Location p = base.clone().add( Math.cos(a) * innerR, 1.1 + Math.sin(tick * 0.18) * 0.35, Math.sin(a) * innerR); world.spawnParticle(Particle.SOUL, p, 1, 0.04, 0.04, 0.04, 0.005); } // ── Layer 2: outer dragon-breath halo (counter-rotating) ─────── double outerR = 3.5 + Math.cos(tick * 0.07) * 0.6; for (int i = 0; i < 8; i++) { double a = -angle2 + (2 * Math.PI / 8) * i; Location p = base.clone().add( Math.cos(a) * outerR, 0.8 + Math.sin(tick * 0.1 + i) * 0.3, Math.sin(a) * outerR); world.spawnParticle(Particle.DRAGON_BREATH, p, 1, 0.05, 0.05, 0.05, 0.01); } // ── Layer 3: rising soul wisps every 3 ticks ────────────────── if (tick % 3 == 0) { double wx = (Math.random() - 0.5) * 5; double wz = (Math.random() - 0.5) * 5; Location wisp = base.clone().add(wx, 0.3, wz); world.spawnParticle(Particle.SOUL_FIRE_FLAME, wisp, 4, 0.15, 0.5, 0.15, 0.015); } // ── Layer 4: smoke column (removed - particle not compatible with 1.21.x) ── // ── Layer 5: phase-based intensifier every 40 ticks ────────── if (tick % 40 == 0) { world.spawnParticle(Particle.SOUL, base.clone().add(0,1.5,0), 5, 1.0, 0.5, 1.0, 0.04); world.spawnParticle(Particle.SOUL_FIRE_FLAME, base.clone().add(0,0.5,0), 3, 0.8, 0.3, 0.8, 0.03); world.playSound(base, Sound.BLOCK_SOUL_SAND_BREAK, 0.4f, 0.5f); } // ── Layer 6: lightning rod pulse every 100 ticks (5s) ───────── if (tick % 100 == 0) { world.spawnParticle(Particle.ELECTRIC_SPARK, base.clone().add(0,2,0), 5, 0.8, 1.0, 0.8, 0.06); world.playSound(base, Sound.ENTITY_LIGHTNING_BOLT_THUNDER, 0.3f, 1.8f); } angle += 0.07; angle2 += 0.05; tick++; } }.runTaskTimer(plugin, 5L, 2L); } /** * Enforces the player boundary every second. * If the crafter steps outside RADIUS, they are immediately teleported * back inside with a warning. No grace period — no escape. */ private void startBoundaryEnforcer(RitualState state) { state.boundaryTask = new BukkitRunnable() { @Override public void run() { if (!activeRituals.containsKey(state.crafterUUID)) { cancel(); return; } // FIX: O(1) key lookup instead of O(n) containsValue Player crafter = Bukkit.getPlayer(state.crafterUUID); if (crafter == null) { failRitual(state, "§cThe crafter disconnected. Ritual failed."); cancel(); return; } if (!isInBounds(crafter.getLocation(), state.tableLocation)) { // Teleport crafter to just inside the boundary (toward center) Location center = state.tableLocation.clone().add(0, 0, 0); Location cloc = crafter.getLocation(); double dx = cloc.getX() - center.getX(); double dz = cloc.getZ() - center.getZ(); double dist = Math.sqrt(dx * dx + dz * dz); // Pull to 80% of radius so they land well inside double scale = (RADIUS * 0.75) / dist; Location pullBack = center.clone().add(dx * scale, 0, dz * scale); pullBack.setY(cloc.getY()); pullBack.setYaw(cloc.getYaw()); pullBack.setPitch(cloc.getPitch()); // Find safe Y pullBack = safeSurface(pullBack); crafter.teleport(pullBack); crafter.sendTitle("§c§lSTAY IN THE RITUAL AREA", "§7You cannot leave!", 0, 30, 10); crafter.playSound(crafter.getLocation(), Sound.BLOCK_NOTE_BLOCK_BASS, 1f, 0.5f); } } }.runTaskTimer(plugin, 20L, 20L); } // ── Phase system ───────────────────────────────────────────────────────── private static final EntityType[][] PHASE_MOB_TYPES = { { EntityType.ZOMBIE, EntityType.SKELETON }, { EntityType.ZOMBIE, EntityType.SKELETON, EntityType.CAVE_SPIDER }, { EntityType.WITHER_SKELETON, EntityType.HUSK }, { EntityType.VINDICATOR, EntityType.PILLAGER }, { EntityType.EVOKER, EntityType.VINDICATOR }, { EntityType.RAVAGER, EntityType.WITCH }, { EntityType.WITHER_SKELETON, EntityType.EVOKER, EntityType.RAVAGER }, { EntityType.ILLUSIONER, EntityType.RAVAGER, EntityType.VINDICATOR }, { EntityType.ILLUSIONER, EntityType.EVOKER, EntityType.WITHER_SKELETON, EntityType.RAVAGER }, { EntityType.ILLUSIONER, EntityType.EVOKER, EntityType.RAVAGER, EntityType.WITHER_SKELETON, EntityType.WITCH } }; private static final String[] PHASE_NAMES = { "§ePhase 1 §7— The Dead Awaken", "§ePhase 2 §7— Skittering Shadows", "§6Phase 3 §7— Wither's Kin", "§6Phase 4 §7— Pillager Vanguard", "§cPhase 5 §7— The Evokers Arrive", "§cPhase 6 §7— Ravager Stampede", "§cPhase 7 §7— Dark Convergence", "§4Phase 8 §7— §lILLUSIONERS UNLEASHED", "§4Phase 9 §7— §lFINAL HORDE", "§4§lPhase 10 §c§l— THE RITUAL FINALE" }; private void spawnPhase(RitualState state) { if (state.currentPhase >= TOTAL_PHASES) return; int phaseIndex = state.currentPhase; state.currentPhase++; EntityType[] types = PHASE_MOB_TYPES[phaseIndex]; Location base = state.tableLocation.clone(); // Mob count stays the same as original int count = 8 + phaseIndex * 3; // Health: low — roughly 40-80% of vanilla double healthMult = 0.4 + phaseIndex * 0.04; // Speed amp: ramps up like original int speedAmp = Math.min(phaseIndex / 2, 3); // Strength amp: restored to original scaling int strengthAmp = Math.min((phaseIndex + 1) / 3, 3); for (int i = 0; i < count; i++) { EntityType type = types[i % types.length]; Location spread = spreadLocation(base, RADIUS); Entity e = spawnBoosted(spread, type, healthMult, speedAmp, strengthAmp); if (e != null) state.phaseEntityIds.add(e.getEntityId()); // FIX: null-guard spawnBoosted return } String phaseName = PHASE_NAMES[phaseIndex]; Bukkit.broadcastMessage("§5[SoulSMP] " + phaseName + " §8(×" + count + " mobs, §a" + String.format("%.0f", healthMult * 100) + "% HP§8)"); Player crafter = Bukkit.getPlayer(state.crafterUUID); if (crafter != null) { crafter.sendTitle(phaseName, "§7Survive the onslaught!", 10, 70, 20); // Phase-scaled sounds for crafter Sound phaseSound = phaseIndex < 3 ? Sound.ENTITY_WITHER_AMBIENT : phaseIndex < 6 ? Sound.ENTITY_RAVAGER_ROAR : Sound.ENTITY_ENDER_DRAGON_GROWL; crafter.playSound(crafter.getLocation(), phaseSound, 1.2f, 0.7f + phaseIndex * 0.03f); } // Visual burst at ritual table on each phase spawn if (state.tableLocation.getWorld() != null) { World tableWorld = state.tableLocation.getWorld(); Location tl = state.tableLocation; // Scale intensity with phase int particleScale = 20 + phaseIndex * 8; tableWorld.spawnParticle(Particle.SOUL, tl.clone().add(0,1,0), Math.max(1, particleScale/4), 1.5, 0.8, 1.5, 0.05); tableWorld.spawnParticle(Particle.SOUL_FIRE_FLAME, tl.clone().add(0,1,0), Math.max(1, particleScale/8), 1.0, 0.5, 1.0, 0.03); if (phaseIndex >= 5) tableWorld.spawnParticle(Particle.FLAME, tl.clone().add(0,1.5,0), 8, 1.0, 0.5, 1.0, 0.05); if (phaseIndex >= 8) tableWorld.spawnParticle(Particle.ELECTRIC_SPARK, tl.clone().add(0,2,0), 12, 1.0, 1.0, 1.0, 0.08); tableWorld.playSound(tl, Sound.BLOCK_SOUL_SAND_BREAK, 0.8f + phaseIndex * 0.05f, 0.5f); } // Watch for wave clear, then trigger next phase (after 3 s delay) state.phaseWatcher = new BukkitRunnable() { @Override public void run() { if (!activeRituals.containsKey(state.crafterUUID)) { cancel(); return; } // FIX: O(1) key lookup instead of O(n) containsValue World world = state.tableLocation.getWorld(); if (world == null) return; // Kill any Vexes near the ritual (evokers summon them) killNearbyVexes(state); boolean allDead = state.phaseEntityIds.stream() .noneMatch(id -> world.getEntities().stream() .anyMatch(e -> e.getEntityId() == id && e.isValid())); if (allDead) { cancel(); state.phaseEntityIds.clear(); if (state.currentPhase < TOTAL_PHASES) { Player c = Bukkit.getPlayer(state.crafterUUID); if (c != null) { c.sendTitle("§a✔ Wave Cleared!", "§7Next wave in §c3 seconds§7...", 5, 50, 15); c.playSound(c.getLocation(), Sound.UI_TOAST_CHALLENGE_COMPLETE, 1.4f, 1.3f); c.playSound(c.getLocation(), Sound.ENTITY_PLAYER_LEVELUP, 0.8f, 1.6f); } // Broadcast wave clear to all players Bukkit.broadcastMessage("§5[SoulSMP] §a✔ Wave §e" + (state.currentPhase) + "§a cleared at §e" + formatLoc(state.tableLocation) + "§a! Next wave in 3s..."); // Green burst + spiral at table if (state.tableLocation.getWorld() != null) { World tw = state.tableLocation.getWorld(); Location tl = state.tableLocation.clone().add(0, 1, 0); tw.spawnParticle(Particle.TOTEM_OF_UNDYING, tl, 60, 2.0, 1.5, 2.0, 0.14); tw.spawnParticle(Particle.HAPPY_VILLAGER, tl, 30, 2.5, 1.0, 2.5, 0); tw.spawnParticle(Particle.SOUL, tl, 20, 1.5, 0.8, 1.5, 0.06); // Upward green pillar for (int yy = 0; yy <= 8; yy++) { tw.spawnParticle(Particle.TOTEM_OF_UNDYING, tl.clone().add(0, yy * 0.6, 0), 3, 0.2, 0.05, 0.2, 0.03); } // Ring of totem particles for (int ii = 0; ii < 20; ii++) { double ra = (2 * Math.PI / 20) * ii; Location rp = tl.clone().add(Math.cos(ra) * 3.0, 0, Math.sin(ra) * 3.0); tw.spawnParticle(Particle.TOTEM_OF_UNDYING, rp, 3, 0.1, 0.3, 0.1, 0.05); } tw.playSound(state.tableLocation, Sound.ENTITY_LIGHTNING_BOLT_THUNDER, 0.4f, 1.8f); } plugin.getServer().getScheduler().runTaskLater(plugin, () -> spawnPhase(state), 60L); } else { // ALL 10 PHASES DONE — give the reward immediately state.allPhasesComplete = true; if (activeRituals.containsKey(state.crafterUUID)) completeRitual(state); } } } }.runTaskTimer(plugin, 40L, 40L); // Leash task — every 3 s, pull wanderers back inside RADIUS BukkitTask leashTask = new BukkitRunnable() { @Override public void run() { if (!activeRituals.containsKey(state.crafterUUID)) { cancel(); return; } // FIX: O(1) key lookup instead of O(n) containsValue World world = state.tableLocation.getWorld(); if (world == null) return; Location center = state.tableLocation; for (Entity e : world.getEntities()) { if (!state.phaseEntityIds.contains(e.getEntityId())) continue; if (!e.isValid()) continue; double dx = e.getLocation().getX() - center.getX(); double dz = e.getLocation().getZ() - center.getZ(); double dist = Math.sqrt(dx * dx + dz * dz); if (dist > RADIUS) { Location pullBack = spreadLocation(center, (int)(RADIUS * 0.7)); e.teleport(pullBack); } } } }.runTaskTimer(plugin, 60L, 60L); state.leashTasks.add(leashTask); } /** Kills all Vex entities within 2× RADIUS of the ritual table. */ private void killNearbyVexes(RitualState state) { World world = state.tableLocation.getWorld(); if (world == null) return; for (Entity e : world.getNearbyEntities(state.tableLocation, RADIUS * 2.0, 64, RADIUS * 2.0)) { if (e instanceof Vex) e.remove(); } } private Entity spawnBoosted(Location loc, EntityType type, double healthMult, int speedAmp, int strengthAmp) { // FIX: guard against null world — spreadLocation() can return a location with a null world // if the chunk is unloaded or the ritual table world was unloaded mid-ritual. if (loc.getWorld() == null) { plugin.getLogger().warning("[SoulSMP] spawnBoosted: null world for loc " + loc + ", skipping spawn."); return null; // caller (spawnPhase) discards the return value except for entityId — handled below } Entity e = loc.getWorld().spawnEntity(loc, type); if (e instanceof LivingEntity living) { // Health scaling (way lower now) var healthAttr = living.getAttribute(org.bukkit.attribute.Attribute.GENERIC_MAX_HEALTH); if (healthAttr != null) { double newHp = Math.max(2.0, healthAttr.getBaseValue() * healthMult); healthAttr.setBaseValue(newHp); living.setHealth(newHp); } // Speed (only late phases) if (speedAmp > 0) { var speedAttr = living.getAttribute(org.bukkit.attribute.Attribute.GENERIC_MOVEMENT_SPEED); if (speedAttr != null) { double bonus = speedAmp * 0.03; // very small // FIX: Use NamespacedKey constructor (UUID-based removed in 1.21) org.bukkit.NamespacedKey speedKey = new org.bukkit.NamespacedKey("soulsmp", "ritual_speed_" + living.getEntityId()); speedAttr.addModifier(new org.bukkit.attribute.AttributeModifier( speedKey, bonus, org.bukkit.attribute.AttributeModifier.Operation.ADD_NUMBER)); } } // Strength — restored (keeps mobs hitting hard) if (strengthAmp > 0) { living.addPotionEffect(new PotionEffect( PotionEffectType.STRENGTH, Integer.MAX_VALUE, strengthAmp - 1)); } // Glowing — both the direct flag and the potion effect for reliability living.setGlowing(true); living.addPotionEffect(new PotionEffect(PotionEffectType.GLOWING, Integer.MAX_VALUE, 0, false, false)); living.setCustomName("§cRitual Guardian"); living.setCustomNameVisible(true); living.setRemoveWhenFarAway(false); } return e; } // ── Completion & failure ────────────────────────────────────────────────── private void completeRitual(RitualState state) { if (!activeRituals.containsKey(state.crafterUUID)) return; // already processed activeRituals.remove(state.crafterUUID); cancelTasks(state); craftedItems.add(state.itemId); // Kill any remaining vexes before dropping the reward killNearbyVexes(state); Player crafter = Bukkit.getPlayer(state.crafterUUID); ItemStack reward = buildItem(state.itemId); // Resolve drop location with fallback chain so the item is never silently lost. // Priority: (1) crafting table location, (2) crafter's current position. final Location dropLoc; if (state.tableLocation != null && state.tableLocation.getWorld() != null) { dropLoc = state.tableLocation; } else if (crafter != null) { dropLoc = crafter.getLocation(); } else { dropLoc = null; } if (dropLoc != null && dropLoc.getWorld() != null) { final World dw = dropLoc.getWorld(); dw.dropItemNaturally(dropLoc, reward); // Victory sounds — layered for impact dw.playSound(dropLoc, Sound.UI_TOAST_CHALLENGE_COMPLETE, 2.2f, 0.9f); dw.playSound(dropLoc, Sound.ENTITY_ENDER_DRAGON_DEATH, 1.0f, 1.4f); dw.playSound(dropLoc, Sound.ENTITY_PLAYER_LEVELUP, 1.8f, 0.7f); dw.playSound(dropLoc, Sound.ENTITY_LIGHTNING_BOLT_THUNDER,1.5f, 0.5f); // Initial ground burst dw.spawnParticle(Particle.SOUL, dropLoc.clone().add(0,1,0), 50, 3.0, 1.5, 3.0, 0.08); dw.spawnParticle(Particle.SOUL_FIRE_FLAME, dropLoc.clone().add(0,1,0), 30, 2.5, 1.0, 2.5, 0.07); dw.spawnParticle(Particle.ELECTRIC_SPARK, dropLoc.clone().add(0,2,0), 25, 2.0, 1.5, 2.0, 0.10); dw.spawnParticle(Particle.TOTEM_OF_UNDYING, dropLoc.clone().add(0,1,0), 40, 2.5, 1.2, 2.5, 0.12); dw.spawnParticle(Particle.DRAGON_BREATH, dropLoc.clone().add(0,1,0), 20, 2.0, 0.8, 2.0, 0.06); // Expanding rings at ground level for (int ri = 0; ri < 3; ri++) { final int ring = ri; plugin.getServer().getScheduler().runTaskLater(plugin, () -> { double r = 2.0 + ring * 2.5; for (int ii = 0; ii < 32; ii++) { double a = (2 * Math.PI / 32) * ii; Location rp = dropLoc.clone().add(Math.cos(a) * r, 0.2, Math.sin(a) * r); dw.spawnParticle(Particle.TOTEM_OF_UNDYING, rp, 4, 0.1, 0.5, 0.1, 0.06); dw.spawnParticle(Particle.SOUL, rp, 2, 0.1, 0.3, 0.1, 0.03); } dw.playSound(dropLoc, Sound.ENTITY_WITHER_SHOOT, 0.8f, 1.8f); }, ring * 5L); } // Tall rising soul pillar over 2 seconds — very visible from a distance final Location finalDropLoc = dropLoc.clone(); final World finalDw = dw; new BukkitRunnable() { int py = 0; @Override public void run() { if (py > 50) { cancel(); return; } Location pillar = finalDropLoc.clone().add(0, py * 0.4, 0); finalDw.spawnParticle(Particle.SOUL, pillar, 3, 0.3, 0.05, 0.3, 0.03); finalDw.spawnParticle(Particle.SOUL_FIRE_FLAME, pillar, 2, 0.2, 0.05, 0.2, 0.02); finalDw.spawnParticle(Particle.TOTEM_OF_UNDYING, pillar, 2, 0.25, 0.05, 0.25, 0.04); py++; } }.runTaskTimer(plugin, 3L, 1L); // Crafter gets a visible golden glow + title if (crafter != null) { crafter.addPotionEffect(new PotionEffect(PotionEffectType.GLOWING, 200, 0, false, false)); crafter.addPotionEffect(new PotionEffect(PotionEffectType.ABSORPTION, 300, 3)); // 15HP shield crafter.playSound(crafter.getLocation(), Sound.UI_TOAST_CHALLENGE_COMPLETE, 2f, 1.1f); crafter.sendTitle("§6§l☠ RITUAL COMPLETE ☠", "§7Your weapon awaits at the altar!", 10, 120, 25); } // Strike lightning at the altar for dramatic effect (no damage version) plugin.getServer().getScheduler().runTaskLater(plugin, () -> { if (dropLoc.getWorld() != null) dropLoc.getWorld().strikeLightningEffect(dropLoc); // effect only }, 10L); } else { // Last resort: give directly to crafter, or log so it is never silently lost. if (crafter != null) { crafter.getInventory().addItem(reward); crafter.sendMessage("§5[SoulSMP] §eYour " + weaponDisplayName(state.itemId) + " §ehas been added directly to your inventory."); } else { plugin.getLogger().severe("completeRitual: could not drop " + state.itemId + " — no valid world or online crafter for UUID " + state.crafterUUID); } } String name = crafter != null ? crafter.getName() : "A brave soul"; String display = weaponDisplayName(state.itemId); String bar = "§5§m══════════════════════════════════════════"; Bukkit.broadcastMessage(bar); Bukkit.broadcastMessage("§6§l ☠ RITUAL COMPLETE ☠"); Bukkit.broadcastMessage("§f " + name + " §7has forged the legendary §5§l" + display + "§7!"); Bukkit.broadcastMessage("§7 Location: §e" + formatLoc(state.tableLocation)); Bukkit.broadcastMessage(bar); for (Player p : Bukkit.getOnlinePlayers()) { p.sendTitle("§6☠ RITUAL COMPLETE ☠", "§7" + name + " §7forged §5" + display, 10, 120, 25); p.playSound(p.getLocation(), Sound.UI_TOAST_CHALLENGE_COMPLETE, 1.0f, 0.8f); } } private void failRitual(RitualState state, String reason) { activeRituals.remove(state.crafterUUID); cancelTasks(state); // Kill vexes on fail too killNearbyVexes(state); Player crafter = Bukkit.getPlayer(state.crafterUUID); if (crafter != null) { crafter.sendMessage("§5[SoulSMP] " + reason); if (!state.consumed.isEmpty()) { crafter.sendMessage("§5[SoulSMP] §eYour materials have been returned."); returnItems(crafter, state.consumed); // FIX: safe return, drop overflow at feet } } Bukkit.broadcastMessage("§5[SoulSMP] §cRitual FAILED at " + formatLoc(state.tableLocation)); for (Player p : Bukkit.getOnlinePlayers()) p.sendTitle("§4RITUAL FAILED", reason, 10, 60, 20); } private void cancelTasks(RitualState state) { if (state.countdownTask != null) state.countdownTask.cancel(); if (state.boundaryTask != null) state.boundaryTask.cancel(); if (state.phaseWatcher != null) state.phaseWatcher.cancel(); if (state.ambientTask != null) state.ambientTask.cancel(); state.leashTasks.forEach(t -> { try { t.cancel(); } catch (Exception ignored) {} }); state.leashTasks.clear(); if (state.ritualBar != null) { state.ritualBar.setVisible(false); state.ritualBar.removeAll(); state.ritualBar = null; } } private void broadcastMilestone(RitualState state, String timeLeft) { Player crafter = Bukkit.getPlayer(state.crafterUUID); String name = crafter != null ? crafter.getName() : "Someone"; Bukkit.broadcastMessage("§5[SoulSMP] §7Ritual at §e" + formatLoc(state.tableLocation) + " §7— §c" + timeLeft + " §7remaining. (§f" + name + " §7forging " + weaponDisplayName(state.itemId) + ")"); } // ── Item helpers (weapons + armour) ─────────────────────────────────────── public String weaponDisplayName(String id) { return switch (id) { // ── original weapons ── case "soul_scythe" -> "§5Soul Scythe"; case "poseidons_spear" -> "§bPoseidon's Spear"; case "soul_fork" -> "§bThe Fork"; case "miners_pickaxe" -> "§6Miner's Pickaxe"; case "beavers_axe" -> "§aBeaver's Axe"; case "remembrance_mace" -> "§cRemembrance Mace"; case "soul_shield" -> "§5Soul Shield"; // ── new weapons ── case "void_blade" -> "§8Void Blade"; case "storm_bow" -> "§eStorm Bow"; case "glacial_hammer" -> "§bGlacial Hammer"; case "phantom_dagger" -> "§5Phantom Dagger"; case "netherbane_axe" -> "§cNetherbane Axe"; case "soul_cannon" -> "§5Soul Cannon"; case "reaper_scythe" -> "§4Reaper Scythe"; case "titan_fist" -> "§6Titan Fist"; // ── soul armour ── case "soul_helmet" -> "§5Soul Helm"; case "soul_chestplate" -> "§5Soul Chestplate"; case "soul_leggings" -> "§5Soul Leggings"; case "soul_boots" -> "§5Soul Boots"; // ── end armour ── case "end_helmet" -> "§dEnd Helm"; case "end_chestplate" -> "§dEnd Chestplate"; case "end_leggings" -> "§dEnd Leggings"; case "end_boots" -> "§dEnd Boots"; default -> id; }; } public ItemStack buildItem(String id) { SoulArmour sa = plugin.getSoulArmour(); return switch (id) { // ── original weapons ── case "soul_scythe" -> weaponManager.createScythe(); case "poseidons_spear" -> weaponManager.createPoseidonsSpear(); case "soul_fork" -> weaponManager.createFork(); case "miners_pickaxe" -> weaponManager.createMinersPickaxe(); case "beavers_axe" -> weaponManager.createBeaversAxe(); case "remembrance_mace" -> weaponManager.createRemembranceMace(); case "soul_shield" -> weaponManager.createSoulShield(); // ── new weapons ── case "void_blade" -> weaponManager.createVoidBlade(); case "storm_bow" -> weaponManager.createStormBow(); case "glacial_hammer" -> weaponManager.createGlacialHammer(); case "phantom_dagger" -> weaponManager.createPhantomDagger(); case "netherbane_axe" -> weaponManager.createNetherbaneAxe(); case "soul_cannon" -> weaponManager.createSoulCannon(); case "reaper_scythe" -> weaponManager.createReaperScythe(); case "titan_fist" -> weaponManager.createTitanFist(); // ── soul armour ── case "soul_helmet" -> sa.createHelmet(); case "soul_chestplate" -> sa.createChestplate(); case "soul_leggings" -> sa.createLeggings(); case "soul_boots" -> sa.createBoots(); // ── end armour ── case "end_helmet" -> sa.createEndHelmet(); case "end_chestplate" -> sa.createEndChestplate(); case "end_leggings" -> sa.createEndLeggings(); case "end_boots" -> sa.createEndBoots(); default -> { plugin.getLogger().severe("buildItem: unknown id '" + id + "'"); yield new ItemStack(org.bukkit.Material.STICK); } }; } /** Legacy alias so existing callers still compile. */ public ItemStack buildWeapon(String id) { return buildItem(id); } // ── Util ───────────────────────────────────────────────────────────────── private boolean isInBounds(Location loc, Location center) { // FIX: null-check both worlds before equals() to avoid NPE on cross-world teleports if (loc.getWorld() == null || center.getWorld() == null) return false; if (!loc.getWorld().equals(center.getWorld())) return false; return Math.abs(loc.getX() - center.getX()) <= RADIUS && Math.abs(loc.getZ() - center.getZ()) <= RADIUS; } private Location safeSurface(Location loc) { World world = loc.getWorld(); if (world == null) return loc; int x = loc.getBlockX(), z = loc.getBlockZ(); int startY = Math.min(loc.getBlockY() + 5, world.getMaxHeight() - 2); for (int y = startY; y >= world.getMinHeight(); y--) { if (world.getBlockAt(x, y, z).getType().isSolid() && !world.getBlockAt(x, y + 1, z).getType().isSolid() && !world.getBlockAt(x, y + 2, z).getType().isSolid()) { return new Location(world, loc.getX(), y + 1, loc.getZ(), loc.getYaw(), loc.getPitch()); } } return loc; } private Location spreadLocation(Location base, int radius) { Random rand = new Random(); World world = base.getWorld(); for (int attempt = 0; attempt < 10; attempt++) { double angle = rand.nextDouble() * Math.PI * 2; double dist = 8 + rand.nextDouble() * (radius - 8); double x = base.getX() + Math.cos(angle) * dist; double z = base.getZ() + Math.sin(angle) * dist; int startY = Math.min(base.getBlockY() + 10, world.getMaxHeight() - 2); for (int y = startY; y >= world.getMinHeight(); y--) { org.bukkit.block.Block block = world.getBlockAt((int) x, y, (int) z); org.bukkit.block.Block above = world.getBlockAt((int) x, y + 1, (int) z); org.bukkit.block.Block above2 = world.getBlockAt((int) x, y + 2, (int) z); if (block.getType().isSolid() && !above.getType().isSolid() && !above2.getType().isSolid()) { return new Location(world, x, y + 1, z, base.getYaw(), 0); } } } double angle = rand.nextDouble() * Math.PI * 2; double dist = 8 + rand.nextDouble() * (radius - 8); int x = (int)(base.getX() + Math.cos(angle) * dist); int z = (int)(base.getZ() + Math.sin(angle) * dist); return world.getHighestBlockAt(x, z).getLocation().add(0, 1, 0); } private String formatLoc(Location loc) { if (loc == null) return "unknown"; return loc.getBlockX() + ", " + loc.getBlockY() + ", " + loc.getBlockZ(); } private String formatTime(long seconds) { return String.format("%d:%02d", seconds / 60, seconds % 60); } // ── Inner state class ───────────────────────────────────────────────────── public static class RitualState { public final UUID crafterUUID; public final Location tableLocation; public final String itemId; public final List consumed; public int currentPhase = 0; /** Set to true when the final wave is cleared — prevents timer from failing after reward. */ public boolean allPhasesComplete = false; public final List phaseEntityIds = new ArrayList<>(); public BukkitTask countdownTask, boundaryTask, phaseWatcher, ambientTask; public final List leashTasks = new ArrayList<>(); public BossBar ritualBar = null; public RitualState(UUID crafterUUID, Location tableLocation, String itemId, List consumed) { this.crafterUUID = crafterUUID; this.tableLocation = tableLocation; this.itemId = itemId; this.consumed = new ArrayList<>(consumed); } } }