package com.turtlecore.manager; import com.turtlecore.TurtleCore; import com.turtlecore.config.ConfigManager; import com.turtlecore.inventory.impl.TPAMenuGUI; import com.turtlecore.model.TPARequest; import com.turtlecore.task.TeleportTask; import com.turtlecore.util.ColorUtil; import org.bukkit.Bukkit; import org.bukkit.entity.Player; import java.util.*; public class TPAManager { private final TurtleCore plugin; private final Map pendingRequests = new HashMap<>(); private final Map activeTasks = new HashMap<>(); private final Set tpaToggleOff = new HashSet<>(); private final Set tpaHereToggleOff = new HashSet<>(); private final Set tpaAutoOn = new HashSet<>(); public TPAManager(TurtleCore plugin) { this.plugin = plugin; } // ---- Toggle Methods ---- public void toggleTPA(Player player) { ConfigManager cfg = plugin.getConfigManager(); if (tpaToggleOff.contains(player.getUniqueId())) { tpaToggleOff.remove(player.getUniqueId()); player.sendMessage(ColorUtil.color(cfg.getString("tpa.tpatoggle-on", "&aTPA enabled."))); } else { tpaToggleOff.add(player.getUniqueId()); player.sendMessage(ColorUtil.color(cfg.getString("tpa.tpatoggle-off", "&cTPA disabled."))); } } public void toggleTPAHere(Player player) { ConfigManager cfg = plugin.getConfigManager(); if (tpaHereToggleOff.contains(player.getUniqueId())) { tpaHereToggleOff.remove(player.getUniqueId()); player.sendMessage(ColorUtil.color(cfg.getString("tpa.tpaheretoggle-on", "&aTPAHERE enabled."))); } else { tpaHereToggleOff.add(player.getUniqueId()); player.sendMessage(ColorUtil.color(cfg.getString("tpa.tpaheretoggle-off", "&cTPAHERE disabled."))); } } public void toggleTPAAuto(Player player) { ConfigManager cfg = plugin.getConfigManager(); if (tpaAutoOn.contains(player.getUniqueId())) { tpaAutoOn.remove(player.getUniqueId()); player.sendMessage(ColorUtil.color(cfg.getString("tpa.auto-off", "&cTPA auto-accept disabled."))); } else { tpaAutoOn.add(player.getUniqueId()); player.sendMessage(ColorUtil.color(cfg.getString("tpa.auto-on", "&aTPA auto-accept enabled."))); } } // ---- GUI Opening ---- public void openSendConfirmation(Player sender, Player target, boolean isTpaHere) { TPAMenuGUI gui = new TPAMenuGUI(plugin, target, isTpaHere, true); plugin.getGuiManager().openGUI(gui, sender); } public void openAcceptConfirmation(Player acceptor) { TPARequest request = findRequestForTarget(acceptor.getUniqueId()); if (request == null) { String msg = plugin.getConfigManager().getString("tpa.no-pending-request", "&cYou have no pending requests."); acceptor.sendMessage(ColorUtil.color(msg)); return; } Player requester = Bukkit.getPlayer(request.getRequesterUUID()); if (requester == null || !requester.isOnline()) { pendingRequests.remove(request.getRequesterUUID()); acceptor.sendMessage(ColorUtil.color("&cThe requester is no longer online.")); return; } TPAMenuGUI gui = new TPAMenuGUI(plugin, requester, request.isTpaHere(), false); plugin.getGuiManager().openGUI(gui, acceptor); } // ---- Request Logic ---- public void sendRequest(Player sender, Player target, boolean isTpaHere) { ConfigManager cfg = plugin.getConfigManager(); if (!isTpaHere && tpaToggleOff.contains(target.getUniqueId())) { String msg = cfg.getString("tpa.tpa-disabled-message", "&c%player% has disabled TPA requests.") .replace("%player%", target.getName()); sender.sendMessage(ColorUtil.color(msg)); return; } if (isTpaHere && tpaHereToggleOff.contains(target.getUniqueId())) { String msg = cfg.getString("tpa.tpahere-disabled-message", "&c%player% has disabled TPAHERE requests.") .replace("%player%", target.getName()); sender.sendMessage(ColorUtil.color(msg)); return; } // Remove old outgoing request from same sender TPARequest existing = pendingRequests.get(sender.getUniqueId()); if (existing != null) { Player oldTarget = Bukkit.getPlayer(existing.getTargetUUID()); if (oldTarget != null) { oldTarget.sendMessage(ColorUtil.color("&b[TPA] &e" + sender.getName() + " &7cancelled their previous request.")); } } TPARequest request = new TPARequest(sender.getUniqueId(), target.getUniqueId(), isTpaHere, System.currentTimeMillis()); pendingRequests.put(sender.getUniqueId(), request); // Notify target if (isTpaHere) { String msg = cfg.getString("tpa.request-received-tpahere", "&b[TPA] &e%player% &7wants you to teleport to them! Type &b/tpaccept &7to accept.") .replace("%player%", sender.getName()); target.sendMessage(ColorUtil.color(msg)); } else { String msg = cfg.getString("tpa.request-received-tpa", "&b[TPA] &e%player% &7wants to teleport to you! Type &b/tpaccept &7to accept.") .replace("%player%", sender.getName()); target.sendMessage(ColorUtil.color(msg)); } // Notify sender String sentMsg = cfg.getString("tpa.request-sent", "&b[TPA] &7Request sent to &e%player%&7.") .replace("%player%", target.getName()); sender.sendMessage(ColorUtil.color(sentMsg)); // Handle tpauto if (tpaAutoOn.contains(target.getUniqueId())) { UUID senderUUID = sender.getUniqueId(); Bukkit.getScheduler().runTaskLater(plugin, () -> { if (pendingRequests.containsKey(senderUUID)) { acceptRequest(target, senderUUID); } }, 1L); } } public void acceptRequest(Player acceptor, UUID requesterUUID) { TPARequest request = pendingRequests.remove(requesterUUID); if (request == null) { acceptor.sendMessage(ColorUtil.color("&cThat request is no longer valid.")); return; } Player requester = Bukkit.getPlayer(requesterUUID); ConfigManager cfg = plugin.getConfigManager(); int seconds = cfg.getInt("tpa.countdown-seconds", 5); if (request.isTpaHere()) { // TPAHERE accepted: acceptor teleports to requester if (requester != null && requester.isOnline()) { String msg = cfg.getString("tpa.request-accepted", "&b[TPA] &e%player% &7accepted your request!") .replace("%player%", acceptor.getName()); requester.sendMessage(ColorUtil.color(msg)); } plugin.cancelAllTeleportTasks(acceptor); final UUID reqUUID = requesterUUID; TeleportTask task = new TeleportTask( acceptor, () -> { Player req = Bukkit.getPlayer(reqUUID); return (req != null && req.isOnline()) ? req.getLocation() : null; }, seconds, cfg.getString("tpa.countdown-chat", "&eTeleporting in &c%seconds%"), cfg.getString("tpa.countdown-actionbar", "&eTeleporting in &c%seconds%"), cfg.getString("tpa.cancel-chat", "&cTeleport Cancelled!"), cfg.getString("tpa.cancel-actionbar", "&cTeleport Cancelled!"), null, null, () -> activeTasks.remove(acceptor.getUniqueId()), () -> activeTasks.remove(acceptor.getUniqueId()) ); activeTasks.put(acceptor.getUniqueId(), task); task.runTaskTimer(plugin, 0L, 20L); } else { // TPA accepted: requester teleports to acceptor if (requester != null && requester.isOnline()) { String msg = cfg.getString("tpa.request-accepted", "&b[TPA] &e%player% &7accepted your request!") .replace("%player%", acceptor.getName()); requester.sendMessage(ColorUtil.color(msg)); plugin.cancelAllTeleportTasks(requester); TeleportTask task = new TeleportTask( requester, () -> (acceptor.isOnline() ? acceptor.getLocation() : null), seconds, cfg.getString("tpa.countdown-chat", "&eTeleporting in &c%seconds%"), cfg.getString("tpa.countdown-actionbar", "&eTeleporting in &c%seconds%"), cfg.getString("tpa.cancel-chat", "&cTeleport Cancelled!"), cfg.getString("tpa.cancel-actionbar", "&cTeleport Cancelled!"), null, null, () -> activeTasks.remove(requester.getUniqueId()), () -> activeTasks.remove(requester.getUniqueId()) ); activeTasks.put(requester.getUniqueId(), task); task.runTaskTimer(plugin, 0L, 20L); } else { acceptor.sendMessage(ColorUtil.color("&cThe requester is no longer online.")); } } } public void denyRequest(Player denier) { TPARequest request = findRequestForTarget(denier.getUniqueId()); if (request == null) { denier.sendMessage(ColorUtil.color( plugin.getConfigManager().getString("tpa.no-pending-request", "&cYou have no pending requests."))); return; } pendingRequests.remove(request.getRequesterUUID()); Player requester = Bukkit.getPlayer(request.getRequesterUUID()); if (requester != null && requester.isOnline()) { String msg = plugin.getConfigManager().getString("tpa.request-denied", "&b[TPA] &e%player% &7denied your request.") .replace("%player%", denier.getName()); requester.sendMessage(ColorUtil.color(msg)); } denier.sendMessage(ColorUtil.color("&b[TPA] &7Request denied.")); } public void cancelRequest(Player canceller) { TPARequest request = pendingRequests.remove(canceller.getUniqueId()); if (request == null) { canceller.sendMessage(ColorUtil.color( plugin.getConfigManager().getString("tpa.no-outgoing-request", "&cYou have no outgoing request."))); return; } String targetName = Optional.ofNullable(Bukkit.getOfflinePlayer(request.getTargetUUID()).getName()) .orElse("Unknown"); String msg = plugin.getConfigManager().getString("tpa.request-cancelled", "&b[TPA] &7Your request to &e%player% &7has been cancelled.") .replace("%player%", targetName); canceller.sendMessage(ColorUtil.color(msg)); Player target = Bukkit.getPlayer(request.getTargetUUID()); if (target != null && target.isOnline()) { target.sendMessage(ColorUtil.color("&b[TPA] &e" + canceller.getName() + " &7cancelled their request.")); } } public void cancelTask(Player player) { TeleportTask task = activeTasks.remove(player.getUniqueId()); if (task != null && !task.isCancelled()) task.cancel(); } public TPARequest findRequestForTarget(UUID targetUUID) { TPARequest newest = null; for (TPARequest req : pendingRequests.values()) { if (req.getTargetUUID().equals(targetUUID)) { if (newest == null || req.getCreatedAt() > newest.getCreatedAt()) { newest = req; } } } return newest; } }