package com.jovanstar.donuttpa; import com.cryptomorin.xseries.XSound; import java.util.Collections; import java.util.Map; import java.util.Set; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; import net.md_5.bungee.api.ChatMessageType; import net.md_5.bungee.api.chat.ClickEvent; import net.md_5.bungee.api.chat.ComponentBuilder; import net.md_5.bungee.api.chat.HoverEvent; import net.md_5.bungee.api.chat.TextComponent; import net.md_5.bungee.api.chat.HoverEvent.Action; import org.bukkit.Bukkit; import org.bukkit.Location; import org.bukkit.entity.Player; import org.bukkit.inventory.Inventory; import org.bukkit.scheduler.BukkitRunnable; import org.bukkit.scheduler.BukkitTask; public class TeleportRequestManager { public static final Map pendingRequests = new ConcurrentHashMap<>(); private static final Map targetToRequest = new ConcurrentHashMap<>(); public static final Set tpaDisabled = Collections.newSetFromMap(new ConcurrentHashMap<>()); public static final Set tpahereDisabled = Collections.newSetFromMap(new ConcurrentHashMap<>()); private static final Map teleportTasks = new ConcurrentHashMap<>(); private static final Map teleportStartLocations = new ConcurrentHashMap<>(); public static final Map pendingSends = new ConcurrentHashMap<>(); public static final Set autoAccept = Collections.newSetFromMap(new ConcurrentHashMap<>()); private static int REQUEST_TIMEOUT; private static int COUNTDOWN_SECONDS; private static boolean WORLD_ICONS_ENABLED; public static Set getAutoAcceptList() { return Collections.unmodifiableSet(autoAccept); } private TeleportRequestManager() { } public static void initialize() { REQUEST_TIMEOUT = main.getInstance().getConfig().getInt("request-timeout", 60); COUNTDOWN_SECONDS = main.getInstance().getConfig().getInt("countdown-seconds", 5); WORLD_ICONS_ENABLED = main.getInstance().getConfig().getBoolean("world-icons-enabled", true); } public static void shutdown() { for (BukkitTask task : teleportTasks.values()) { task.cancel(); } pendingRequests.clear(); targetToRequest.clear(); tpaDisabled.clear(); tpahereDisabled.clear(); teleportTasks.clear(); teleportStartLocations.clear(); pendingSends.clear(); } private static String key(UUID requester, UUID target) { String var10000 = requester.toString(); return var10000 + ":" + target.toString(); } private static void removePendingRequest(String mapKey) { TeleportRequest tr = pendingRequests.remove(mapKey); if (tr != null) { if (tr.getTimeoutTask() != null) { tr.getTimeoutTask().cancel(); } targetToRequest.remove(tr.getTargetUUID()); } } public static boolean isRequestPending(UUID requester, UUID target) { return pendingRequests.containsKey(key(requester, target)); } public static boolean isTpaDisabled(UUID player) { return tpaDisabled.contains(player); } public static boolean isTpahereDisabled(UUID player) { return tpahereDisabled.contains(player); } public static void toggleTpa(UUID player) { if (!tpaDisabled.add(player)) { tpaDisabled.remove(player); } } public static void toggleTpahere(UUID player) { if (!tpahereDisabled.add(player)) { tpahereDisabled.remove(player); } } public static void cleanupPlayer(UUID playerUUID) { if (teleportTasks.containsKey(playerUUID)) { teleportTasks.get(playerUUID).cancel(); teleportTasks.remove(playerUUID); teleportStartLocations.remove(playerUUID); } pendingRequests.keySet().removeIf(k -> { String[] parts = k.split(":"); if (parts.length != 2) { return false; } else { boolean isReq = parts[0].equals(playerUUID.toString()); boolean isTgt = parts[1].equals(playerUUID.toString()); if (!isReq && !isTgt) { return false; } else { TeleportRequest tr = pendingRequests.get(k); if (tr != null) { targetToRequest.remove(tr.getTargetUUID()); } return true; } } }); pendingSends.remove(playerUUID); } public static TeleportRequest getPendingRequest(UUID requester, UUID target) { return pendingRequests.get(key(requester, target)); } public static TeleportRequest getRequestForTarget(UUID target) { return targetToRequest.get(target); } public static boolean createRequest(Player requester, Player target, TeleportRequestManager.TeleportType type) { if (requester.getUniqueId().equals(target.getUniqueId())) { requester.sendMessage(Messages.get("no-self-request")); return false; } else if (type == TeleportRequestManager.TeleportType.TO && isTpaDisabled(target.getUniqueId())) { requester.sendMessage(Messages.format("tpa-disabled", "target", target.getName())); return false; } else if (type == TeleportRequestManager.TeleportType.HERE && isTpahereDisabled(target.getUniqueId())) { requester.sendMessage(Messages.format("tpahere-disabled", "target", target.getName())); XSound.matchXSound("ENTITY_VILLAGER_NO").ifPresent(s -> s.play(requester)); return false; } else { String mapKey = key(requester.getUniqueId(), target.getUniqueId()); if (pendingRequests.containsKey(mapKey)) { requester.sendMessage(Messages.get("on-cooldown")); XSound.matchXSound("ENTITY_VILLAGER_NO").ifPresent(s -> s.play(requester)); return false; } else { TeleportRequest tr = new TeleportRequest(requester.getUniqueId(), target.getUniqueId(), type, null); BukkitTask to = new TeleportRequestManager.TimeoutTask(mapKey, target, requester).runTaskLater(main.getInstance(), 20L * REQUEST_TIMEOUT); tr.setTimeoutTask(to); pendingRequests.put(mapKey, tr); targetToRequest.put(target.getUniqueId(), tr); if (type == TeleportRequestManager.TeleportType.TO) { requester.sendMessage(Messages.format("tpa-sent", "target", target.getName())); } else { requester.sendMessage(Messages.format("tpahere-sent", "target", target.getName())); } XSound.matchXSound("ENTITY_EXPERIENCE_ORB_PICKUP").ifPresent(s -> s.play(requester)); TextComponent base = new TextComponent(Messages.format("request-from", "requester", requester.getName())); TextComponent click = new TextComponent("§a[CLICK TO ACCEPT]"); click.setHoverEvent(new HoverEvent(Action.SHOW_TEXT, new ComponentBuilder("§7Click to accept").create())); net.md_5.bungee.api.chat.ClickEvent.Action var10003 = net.md_5.bungee.api.chat.ClickEvent.Action.RUN_COMMAND; String var10004 = requester.getName(); click.setClickEvent(new ClickEvent(var10003, "/tpaccept " + var10004)); base.addExtra(" "); base.addExtra(click); target.spigot().sendMessage(base); String barKey = type == TeleportRequestManager.TeleportType.TO ? "receive-request-actionbar" : "receive-tpahere-actionbar"; XSound.matchXSound("BLOCK_NOTE_BLOCK_PLING").ifPresent(s -> s.play(target)); String receiveBar = Messages.format(barKey, "requester", requester.getName()); target.spigot().sendMessage(ChatMessageType.ACTION_BAR, new TextComponent(receiveBar)); target.spigot().sendMessage(ChatMessageType.ACTION_BAR, new TextComponent(receiveBar)); if (isAutoAccept(target.getUniqueId())) { acceptRequest(null, target); return true; } else { return true; } } } } public static void acceptRequest(Inventory clickedInventory, Player clicker) { TeleportRequest tr = getRequestForTarget(clicker.getUniqueId()); if (tr == null) { clicker.closeInventory(); } else { String var10000 = tr.getRequesterId(); String mapKey = var10000 + ":" + tr.getTargetId(); removePendingRequest(mapKey); Player req = Bukkit.getPlayer(tr.getRequesterUUID()); Player tgt = Bukkit.getPlayer(tr.getTargetUUID()); if (req != null && req.isOnline() && tgt != null && tgt.isOnline()) { clicker.closeInventory(); String msg = Messages.get("accepted-title"); req.sendMessage(msg); XSound.matchXSound("ENTITY_EXPERIENCE_ORB_PICKUP").ifPresent(s -> s.play(req)); tgt.sendMessage(msg); XSound.matchXSound("ENTITY_EXPERIENCE_ORB_PICKUP").ifPresent(s -> s.play(tgt)); if (tr.getType() == TeleportRequestManager.TeleportType.TO) { startCountdown(req, tgt, TeleportRequestManager.TeleportType.TO); } else { startCountdown(tgt, req, TeleportRequestManager.TeleportType.HERE); } } else { clicker.sendMessage(Messages.get("not-online")); XSound.matchXSound("ENTITY_VILLAGER_NO").ifPresent(s -> s.play(clicker)); clicker.closeInventory(); } } } public static void cancelRequest(Inventory clickedInventory, Player clicker) { TeleportRequest tr = getRequestForTarget(clicker.getUniqueId()); if (tr != null) { String var10000 = tr.getRequesterId(); String mapKey = var10000 + ":" + tr.getTargetId(); removePendingRequest(mapKey); Player req = Bukkit.getPlayer(tr.getRequesterUUID()); Player tgt = Bukkit.getPlayer(tr.getTargetUUID()); if (tgt != null && tgt.isOnline()) { tgt.sendMessage(Messages.format("deny-notification-target", "requester", req.getName())); XSound.matchXSound("ENTITY_VILLAGER_NO").ifPresent(s -> s.play(tgt)); tgt.closeInventory(); } if (req != null && req.isOnline()) { req.sendMessage(Messages.format("deny-notification-sender", "target", tgt.getName())); XSound.matchXSound("ENTITY_VILLAGER_NO").ifPresent(s -> s.play(req)); } } } private static void startCountdown(Player who, Player destination, TeleportRequestManager.TeleportType type) { UUID uuid = who.getUniqueId(); teleportStartLocations.put(uuid, who.getLocation().clone()); boolean safeTpa = main.getInstance().getConfig().getBoolean("safe-tpa", false); double cancelRadius = main.getInstance().getConfig().getDouble("cancel-move-radius", 0.5); int[] secs = new int[]{COUNTDOWN_SECONDS}; BukkitTask task = new TeleportRequestManager.CountdownTask(who, destination, uuid, cancelRadius, secs, safeTpa).runTaskTimer(main.getInstance(), 0L, 20L); teleportTasks.put(uuid, task); } public static boolean isTeleporting(UUID player) { return teleportTasks.containsKey(player); } public static Location getStartLocation(UUID player) { return teleportStartLocations.get(player); } public static void cancelTeleport(UUID player) { BukkitTask task = teleportTasks.remove(player); if (task != null) { task.cancel(); } teleportStartLocations.remove(player); } public static boolean toggleAutoAccept(UUID player) { if (autoAccept.contains(player)) { autoAccept.remove(player); return false; } else { autoAccept.add(player); return true; } } public static boolean isAutoAccept(UUID player) { return autoAccept.contains(player); } private static class CountdownTask extends BukkitRunnable { private final Player who; private final Player destination; private final UUID uuid; private final double cancelRadius; private final int[] secs; private final boolean safeTpa; CountdownTask(Player who, Player destination, UUID uuid, double cancelRadius, int[] secs, boolean safeTpa) { this.who = who; this.destination = destination; this.uuid = uuid; this.cancelRadius = cancelRadius; this.secs = secs; this.safeTpa = safeTpa; } public void run() { if (this.who.isOnline() && this.destination.isOnline()) { Location now = this.who.getLocation(); Location start = TeleportRequestManager.teleportStartLocations.get(this.uuid); if (start != null && now.distance(start) > this.cancelRadius) { this.sendCancel(this.who, "cancelled-moved-actionbar"); this.cancelTask(); } else if (this.secs[0] != 1 || !this.safeTpa || !this.who.isFlying() && !this.destination.isFlying()) { this.secs[0]--; if (this.secs[0] > 0) { String bar = Messages.format("countdown-message", "seconds", String.valueOf(this.secs[0])); this.who.spigot().sendMessage(ChatMessageType.ACTION_BAR, new TextComponent(bar)); XSound.matchXSound("ENTITY_ENDERMAN_TELEPORT").ifPresent(s -> s.play(this.who)); } else { this.who.teleport(this.destination.getLocation()); this.who.spigot().sendMessage(ChatMessageType.ACTION_BAR, new TextComponent(Messages.get("teleported-message"))); XSound.matchXSound("ENTITY_EXPERIENCE_ORB_PICKUP").ifPresent(s -> s.play(this.who)); this.cancelTask(); } } else { this.sendCancel(this.who, "cancelled-flying-actionbar"); this.sendCancel(this.destination, "cancelled-flying-actionbar"); this.cancelTask(); } } else { this.cancelTask(); } } private void sendCancel(Player p, String key) { p.spigot().sendMessage(ChatMessageType.ACTION_BAR, new TextComponent(Messages.get(key))); XSound.matchXSound("ENTITY_VILLAGER_NO").ifPresent(s -> s.play(p)); } private void cancelTask() { this.cancel(); TeleportRequestManager.teleportTasks.remove(this.uuid); TeleportRequestManager.teleportStartLocations.remove(this.uuid); } } public static class PendingSendInfo { public final UUID requesterId; public final UUID targetId; public final TeleportRequestManager.TeleportType type; public final Inventory sendGUI; public PendingSendInfo(UUID req, UUID tgt, TeleportRequestManager.TeleportType t, Inventory gui) { this.requesterId = req; this.targetId = tgt; this.type = t; this.sendGUI = gui; } } public static enum TeleportType { TO, HERE; } private static class TimeoutTask extends BukkitRunnable { private final String mapKey; private final Player target; private final Player requester; TimeoutTask(String mapKey, Player target, Player requester) { this.mapKey = mapKey; this.target = target; this.requester = requester; } public void run() { if (TeleportRequestManager.pendingRequests.containsKey(this.mapKey)) { TeleportRequestManager.pendingRequests.remove(this.mapKey); TeleportRequestManager.targetToRequest.remove(this.target.getUniqueId()); if (this.requester.isOnline()) { this.requester.sendMessage(Messages.format("request-expired-sender", "target", this.target.getName())); XSound.matchXSound("ENTITY_VILLAGER_NO").ifPresent(s -> s.play(this.requester)); } if (this.target.isOnline()) { this.target.sendMessage(Messages.format("request-expired-target", "requester", this.requester.getName())); XSound.matchXSound("ENTITY_VILLAGER_NO").ifPresent(s -> s.play(this.target)); } } } } }