package zena.tpa.manager; import net.md_5.bungee.api.ChatMessageType; import net.md_5.bungee.api.chat.TextComponent; import org.bukkit.Bukkit; import org.bukkit.Location; import org.bukkit.entity.Player; import org.bukkit.plugin.java.JavaPlugin; import org.bukkit.scheduler.BukkitRunnable; import org.bukkit.scheduler.BukkitTask; import zena.tpa.config.ConfigManager; import zena.tpa.model.PlayerData; import zena.tpa.model.RequestType; import zena.tpa.model.TPARequest; import zena.tpa.utils.ColorUtil; import zena.tpa.utils.SoundUtil; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; public class TPAManager { private final JavaPlugin plugin; private final ConfigManager configManager; private final PlayerDataManager playerDataManager; private final SoundUtil soundUtil; private final Map> pendingRequests = new ConcurrentHashMap<>(); private final Map cooldowns = new ConcurrentHashMap<>(); private final Map countdownTasks = new ConcurrentHashMap<>(); public TPAManager(JavaPlugin plugin, ConfigManager configManager, PlayerDataManager playerDataManager, SoundUtil soundUtil) { this.plugin = plugin; this.configManager = configManager; this.playerDataManager = playerDataManager; this.soundUtil = soundUtil; } public boolean hasCooldown(Player player) { if (player.hasPermission("zenatpa.bypass.cooldown")) return false; Long lastTime = cooldowns.get(player.getUniqueId()); if (lastTime == null) return false; int cooldownSeconds = configManager.getCooldown(); return (System.currentTimeMillis() - lastTime) < (cooldownSeconds * 1000L); } public long getRemainingCooldown(Player player) { Long lastTime = cooldowns.get(player.getUniqueId()); if (lastTime == null) return 0; long elapsed = System.currentTimeMillis() - lastTime; long remaining = (configManager.getCooldown() * 1000L) - elapsed; return Math.max(0, (remaining + 999) / 1000); } public void sendRequest(Player sender, Player target, RequestType type) { cooldowns.put(sender.getUniqueId(), System.currentTimeMillis()); TPARequest request = new TPARequest( sender.getUniqueId(), sender.getName(), target.getUniqueId(), target.getName(), type, System.currentTimeMillis() ); pendingRequests.computeIfAbsent(target.getUniqueId(), k -> new ArrayList<>()).add(request); scheduleExpiry(request); soundUtil.play(target, "request-received"); String line1 = configManager.getRawMessage("request-received-line1").replace("{player}", sender.getName()); String line2 = configManager.getRawMessage("request-received-line2"); String acceptBtn = configManager.getRawMessage("request-received-accept"); String denyBtn = configManager.getRawMessage("request-received-deny"); String tip = configManager.getRawMessage("request-received-tip"); target.sendMessage(ColorUtil.color(line1)); target.sendMessage(ColorUtil.color(line2)); net.md_5.bungee.api.chat.TextComponent accept = new net.md_5.bungee.api.chat.TextComponent(ColorUtil.color(acceptBtn)); accept.setClickEvent(new net.md_5.bungee.api.chat.ClickEvent( net.md_5.bungee.api.chat.ClickEvent.Action.RUN_COMMAND, "/yes")); accept.setHoverEvent(new net.md_5.bungee.api.chat.HoverEvent( net.md_5.bungee.api.chat.HoverEvent.Action.SHOW_TEXT, new net.md_5.bungee.api.chat.BaseComponent[]{new net.md_5.bungee.api.chat.TextComponent(ColorUtil.color("&aChấp nhận yêu cầu TPA"))})); net.md_5.bungee.api.chat.TextComponent space = new net.md_5.bungee.api.chat.TextComponent(" "); net.md_5.bungee.api.chat.TextComponent deny = new net.md_5.bungee.api.chat.TextComponent(ColorUtil.color(denyBtn)); deny.setClickEvent(new net.md_5.bungee.api.chat.ClickEvent( net.md_5.bungee.api.chat.ClickEvent.Action.RUN_COMMAND, "/no")); deny.setHoverEvent(new net.md_5.bungee.api.chat.HoverEvent( net.md_5.bungee.api.chat.HoverEvent.Action.SHOW_TEXT, new net.md_5.bungee.api.chat.BaseComponent[]{new net.md_5.bungee.api.chat.TextComponent(ColorUtil.color("&cTừ chối yêu cầu TPA"))})); net.md_5.bungee.api.chat.TextComponent row = new net.md_5.bungee.api.chat.TextComponent(); row.addExtra(accept); row.addExtra(space); row.addExtra(deny); target.spigot().sendMessage(row); target.sendMessage(ColorUtil.color(tip)); String hudMsg = configManager.getHud("request-action-bar").replace("{player}", sender.getName()); target.spigot().sendMessage(ChatMessageType.ACTION_BAR, new TextComponent(ColorUtil.color(hudMsg))); } private void scheduleExpiry(TPARequest request) { Bukkit.getScheduler().runTaskLaterAsynchronously(plugin, () -> { List requests = pendingRequests.get(request.getTargetUUID()); if (requests == null) return; boolean removed = requests.removeIf(r -> r.getSenderUUID().equals(request.getSenderUUID()) && r.getCreatedAt() == request.getCreatedAt()); if (removed) { Player sender = Bukkit.getPlayer(request.getSenderUUID()); if (sender != null) { sender.sendMessage(ColorUtil.color(configManager.getMessage("request-expired"))); } Player target = Bukkit.getPlayer(request.getTargetUUID()); if (target != null) { target.sendMessage(ColorUtil.color(configManager.getMessage("request-expired"))); } } }, configManager.getRequestExpire() * 20L); } public TPARequest getLatestRequest(Player target) { List requests = pendingRequests.get(target.getUniqueId()); if (requests == null || requests.isEmpty()) return null; for (int i = requests.size() - 1; i >= 0; i--) { TPARequest req = requests.get(i); if (!req.isExpired(configManager.getRequestExpire())) return req; } return null; } public void clearRequestsForTarget(UUID targetUUID) { pendingRequests.remove(targetUUID); } public void clearRequestsBySender(UUID senderUUID) { for (List list : pendingRequests.values()) { list.removeIf(r -> r.getSenderUUID().equals(senderUUID)); } } public void acceptRequest(Player target, TPARequest request) { clearRequestsForTarget(target.getUniqueId()); Player teleportPlayer; Player destinationPlayer; if (request.getType() == RequestType.TPA) { teleportPlayer = Bukkit.getPlayer(request.getSenderUUID()); destinationPlayer = target; } else { teleportPlayer = target; destinationPlayer = Bukkit.getPlayer(request.getSenderUUID()); } if (teleportPlayer == null || destinationPlayer == null) return; Player sender = Bukkit.getPlayer(request.getSenderUUID()); if (sender != null) { String msg = configManager.getMessage("request-accepted-sender") .replace("{player}", target.getName()); String countMsg = configManager.getMessage("request-accepted-countdown") .replace("{time}", String.valueOf(configManager.getTeleportCountdown())); sender.sendMessage(ColorUtil.color(msg)); sender.sendMessage(ColorUtil.color(countMsg)); } String denyMsg = configManager.getMessage("request-accepted-countdown") .replace("{time}", String.valueOf(configManager.getTeleportCountdown())); target.sendMessage(ColorUtil.color(denyMsg)); startCountdown(teleportPlayer, destinationPlayer, request); } private void startCountdown(Player mover, Player destination, TPARequest request) { cancelCountdown(mover.getUniqueId()); Location startLocation = mover.getLocation().clone(); int totalSeconds = configManager.getTeleportCountdown(); BukkitTask task = new BukkitRunnable() { int secondsLeft = totalSeconds; @Override public void run() { if (!mover.isOnline()) { cancel(); countdownTasks.remove(mover.getUniqueId()); return; } if (hasMoved(startLocation, mover.getLocation())) { cancel(); countdownTasks.remove(mover.getUniqueId()); mover.sendMessage(ColorUtil.color(configManager.getMessage("teleport-cancelled-move"))); soundUtil.play(mover, "teleport-cancelled"); return; } if (secondsLeft <= 0) { cancel(); countdownTasks.remove(mover.getUniqueId()); if (!destination.isOnline()) { mover.sendMessage(ColorUtil.color(configManager.getMessage("player-not-found") .replace("{player}", request.getTargetName()))); return; } mover.teleport(destination.getLocation()); mover.sendMessage(ColorUtil.color(configManager.getMessage("teleport-success"))); soundUtil.play(mover, "teleport-success"); String historyEntry = "→ " + destination.getName() + " (" + destination.getWorld().getName() + ")"; PlayerData moverData = playerDataManager.getData(mover); if (moverData != null) { moverData.addHistory(historyEntry); playerDataManager.savePlayer(mover.getUniqueId()); } return; } String hudText = configManager.getHud("countdown-action-bar") .replace("{time}", String.valueOf(secondsLeft)); mover.spigot().sendMessage(ChatMessageType.ACTION_BAR, new TextComponent(ColorUtil.color(hudText))); soundUtil.play(mover, "teleport-countdown"); secondsLeft--; } }.runTaskTimer(plugin, 0L, 20L); countdownTasks.put(mover.getUniqueId(), task); } private boolean hasMoved(Location from, Location to) { if (!from.getWorld().equals(to.getWorld())) return true; double dx = Math.abs(from.getX() - to.getX()); double dy = Math.abs(from.getY() - to.getY()); double dz = Math.abs(from.getZ() - to.getZ()); return dx > 0.15 || dy > 0.15 || dz > 0.15; } public void cancelCountdown(UUID playerUUID) { BukkitTask task = countdownTasks.remove(playerUUID); if (task != null) task.cancel(); } public boolean hasActiveCountdown(UUID playerUUID) { return countdownTasks.containsKey(playerUUID); } public List getSentRequests(UUID senderUUID) { List result = new ArrayList<>(); for (List list : pendingRequests.values()) { for (TPARequest req : list) { if (req.getSenderUUID().equals(senderUUID)) { result.add(req); } } } return result; } public void shutdown() { for (BukkitTask task : countdownTasks.values()) { task.cancel(); } countdownTasks.clear(); pendingRequests.clear(); cooldowns.clear(); } }