package com.donut.tpa.request; import com.donut.tpa.DonutTPAPlugin; import com.donut.tpa.util.MessageManager; import org.bukkit.Bukkit; import org.bukkit.entity.Player; import org.bukkit.scheduler.BukkitRunnable; import java.util.*; public class TPARequestManager { private final DonutTPAPlugin plugin; private final MessageManager messages; private final Map> pendingByTarget = new HashMap<>(); private final Map lastRequest = new HashMap<>(); private final long timeoutSeconds; private final long cooldownSeconds; public TPARequestManager(DonutTPAPlugin plugin, MessageManager messages) { this.plugin = plugin; this.messages = messages; this.timeoutSeconds = plugin.getConfig().getLong("settings.request-timeout-seconds", 60L); this.cooldownSeconds = plugin.getConfig().getLong("settings.cooldown-seconds", 30L); new BukkitRunnable() { @Override public void run() { cleanupExpired(); } }.runTaskTimer(plugin, 20L, 20L); } public boolean isOnCooldown(UUID requester) { if (cooldownSeconds <= 0) return false; if (Bukkit.getPlayer(requester) != null && Bukkit.getPlayer(requester).hasPermission("donut.tpa.bypass.cooldown")) return false; Long last = lastRequest.get(requester); if (last == null) return false; long elapsed = (System.currentTimeMillis() - last) / 1000L; return elapsed < cooldownSeconds; } public long getCooldownRemaining(UUID requester) { Long last = lastRequest.get(requester); if (last == null) return 0L; long elapsed = (System.currentTimeMillis() - last) / 1000L; long remain = cooldownSeconds - elapsed; return Math.max(0L, remain); } public boolean hasExistingRequest(UUID requester, UUID target) { Map map = pendingByTarget.get(target); if (map == null) return false; return map.containsKey(requester); } public TPARequest createRequest(Player requester, Player target) { long now = System.currentTimeMillis(); long exp = now + timeoutSeconds * 1000L; TPARequest req = new TPARequest(requester.getUniqueId(), target.getUniqueId(), now, exp); Map map = pendingByTarget.computeIfAbsent(target.getUniqueId(), k -> new HashMap<>()); map.put(requester.getUniqueId(), req); lastRequest.put(requester.getUniqueId(), now); return req; } public List getRequestsForTarget(UUID target) { Map map = pendingByTarget.get(target); if (map == null) return Collections.emptyList(); return new ArrayList<>(map.values()); } public TPARequest getRequest(UUID target, UUID requester) { Map map = pendingByTarget.get(target); if (map == null) return null; return map.get(requester); } public void accept(Player target, TPARequest req) { Player requester = Bukkit.getPlayer(req.getRequester()); removeRequest(req); if (requester == null || !requester.isOnline()) { messages.send(target, "requester-offline"); return; } requester.teleport(target.getLocation()); messages.send(target, "tpaccept-accepted-sender", "requester", requester.getName()); messages.send(requester, "tpaccept-accepted-requester", "target", target.getName()); messages.send(requester, "teleporting"); } public void deny(Player target, TPARequest req) { Player requester = Bukkit.getPlayer(req.getRequester()); removeRequest(req); if (requester != null && requester.isOnline()) { messages.send(requester, "tpdeny-denied-requester", "target", target.getName()); } messages.send(target, "tpdeny-denied-sender", "requester", requester == null ? "Unknown" : requester.getName()); } public void removeRequest(TPARequest req) { Map map = pendingByTarget.get(req.getTarget()); if (map != null) { map.remove(req.getRequester()); if (map.isEmpty()) pendingByTarget.remove(req.getTarget()); } } private void cleanupExpired() { long now = System.currentTimeMillis(); List expired = new ArrayList<>(); for (Map.Entry> entry : pendingByTarget.entrySet()) { for (TPARequest req : entry.getValue().values()) { if (now >= req.getExpiresAt()) { expired.add(req); } } } for (TPARequest req : expired) { Player target = Bukkit.getPlayer(req.getTarget()); Player requester = Bukkit.getPlayer(req.getRequester()); removeRequest(req); if (target != null && target.isOnline()) { messages.send(target, "request-expired-target", "requester", requester == null ? "Unknown" : requester.getName()); } if (requester != null && requester.isOnline()) { messages.send(requester, "request-expired-requester", "target", target == null ? "Unknown" : target.getName()); } } } }