package com.mrnaruto.teleportplugin; import com.google.common.io.ByteArrayDataInput; import com.google.common.io.ByteArrayDataOutput; import com.google.common.io.ByteStreams; 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 org.bukkit.*; import org.bukkit.command.Command; import org.bukkit.command.CommandSender; import org.bukkit.configuration.file.FileConfiguration; import org.bukkit.entity.Player; import org.bukkit.event.EventHandler; import org.bukkit.event.Listener; import org.bukkit.event.inventory.InventoryClickEvent; import org.bukkit.event.player.PlayerJoinEvent; import org.bukkit.event.player.PlayerMoveEvent; import org.bukkit.event.player.PlayerQuitEvent; import org.bukkit.inventory.Inventory; import org.bukkit.inventory.ItemStack; import org.bukkit.inventory.meta.ItemMeta; import org.bukkit.inventory.meta.SkullMeta; import org.bukkit.plugin.java.JavaPlugin; import org.bukkit.plugin.messaging.PluginMessageListener; import org.bukkit.scheduler.BukkitRunnable; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.function.Consumer; import java.util.regex.Matcher; import java.util.regex.Pattern; public class TeleportPlugin extends JavaPlugin implements Listener, PluginMessageListener { private FileConfiguration config; private final Pattern hexPattern = Pattern.compile("&#([A-Fa-f0-9]{6})"); // Data storage private final Map teleportRequests = new HashMap<>(); private final Map teleportPositions = new HashMap<>(); private final Map teleportingPlayers = new HashMap<>(); private final Map tpaToggle = new HashMap<>(); private final Map tpaHereToggle = new HashMap<>(); private final Map tpAutoPlayers = new HashMap<>(); private final Map guiPlayers = new HashMap<>(); private final Map guiRequestTypes = new HashMap<>(); private final Map lastRequestSenders = new HashMap<>(); private final Map actionBarTasks = new HashMap<>(); // Cross-server (optional) private boolean crossServerEnabled = false; private final Map crossServerRequests = new ConcurrentHashMap<>(); private final Map pendingTeleportLocations = new ConcurrentHashMap<>(); // For async player server lookup – key = requestId (UUID random) private final Map> pendingServerRequests = new ConcurrentHashMap<>(); private static class CrossServerRequest { String senderName; UUID senderUUID; String targetName; UUID targetUUID; String type; // "To" or "Here" String sourceServer; long expiry; CrossServerRequest(String senderName, UUID senderUUID, String targetName, UUID targetUUID, String type, String sourceServer) { this.senderName = senderName; this.senderUUID = senderUUID; this.targetName = targetName; this.targetUUID = targetUUID; this.type = type; this.sourceServer = sourceServer; this.expiry = System.currentTimeMillis() + 30000; } boolean isExpired() { return System.currentTimeMillis() > expiry; } } @Override public void onEnable() { saveDefaultConfig(); reloadConfig(); crossServerEnabled = config.getBoolean("cross-server.enabled", false); if (crossServerEnabled) { getServer().getMessenger().registerOutgoingPluginChannel(this, "BungeeCord"); getServer().getMessenger().registerIncomingPluginChannel(this, "BungeeCord", this); getServer().getMessenger().registerOutgoingPluginChannel(this, "teleport:cross"); getServer().getMessenger().registerIncomingPluginChannel(this, "teleport:cross", this); getLogger().info("Cross-server mode ENABLED"); } else { getLogger().info("Cross-server mode DISABLED"); } getServer().getPluginManager().registerEvents(this, this); getLogger().info("TeleportPlugin enabled!"); } @Override public void onDisable() { teleportRequests.clear(); teleportPositions.clear(); teleportingPlayers.clear(); tpaToggle.clear(); tpaHereToggle.clear(); tpAutoPlayers.clear(); guiPlayers.clear(); guiRequestTypes.clear(); lastRequestSenders.clear(); if (crossServerEnabled) { crossServerRequests.clear(); pendingTeleportLocations.clear(); pendingServerRequests.clear(); } for (BukkitRunnable task : actionBarTasks.values()) { if (task != null) task.cancel(); } actionBarTasks.clear(); getLogger().info("TeleportPlugin disabled!"); } @Override public void reloadConfig() { super.reloadConfig(); config = getConfig(); } @Override public boolean onCommand(CommandSender sender, Command command, String label, String[] args) { if (!(sender instanceof Player)) { sender.sendMessage("This command can only be used by players!"); return true; } Player player = (Player) sender; if (!player.hasPermission("teleportplugin.use")) { sendMessage(player, "&cYou don't have permission!"); return true; } switch (command.getName().toLowerCase()) { case "tpa": if (args.length == 0) { sendMessage(player, "&cUsage: /tpa "); return true; } handleTpaCommand(player, args[0]); break; case "tpahere": if (args.length == 0) { sendMessage(player, "&cUsage: /tpahere "); return true; } handleTpaHereCommand(player, args[0]); break; case "tpaccept": if (args.length == 0) handleTpAcceptRecent(player); else handleTpAcceptCommand(player, args[0]); break; case "tpacancel": if (args.length == 0) { sendMessage(player, config.getString("messages.request-not-exist")); playSound(player, config.getString("sounds.error")); return true; } handleTpaCancelCommand(player, args[0]); break; case "tpatoggle": handleTpaToggleCommand(player); break; case "tpaheretoggle": handleTpaHereToggleCommand(player); break; case "tpauto": handleTpAutoCommand(player); break; } return true; } // ------------------------------------------------------------------------- // COMMAND HANDLERS (with cross-server lookup) // ------------------------------------------------------------------------- private void handleTpaCommand(Player sender, String targetName) { Player target = Bukkit.getPlayer(targetName); if (target != null) { handleSameServerTpa(sender, target); } else if (crossServerEnabled) { requestPlayerServer(sender, targetName, server -> { if (server == null) { sendMessage(sender, config.getString("messages.player-not-found")); playSound(sender, config.getString("sounds.error")); } else { sendCrossServerRequest(sender, targetName, "To", server); } }); } else { sendMessage(sender, config.getString("messages.player-not-found")); playSound(sender, config.getString("sounds.error")); } } private void handleTpaHereCommand(Player sender, String targetName) { Player target = Bukkit.getPlayer(targetName); if (target != null) { handleSameServerTpaHere(sender, target); } else if (crossServerEnabled) { requestPlayerServer(sender, targetName, server -> { if (server == null) { sendMessage(sender, config.getString("messages.player-not-found")); playSound(sender, config.getString("sounds.error")); } else { sendCrossServerRequest(sender, targetName, "Here", server); } }); } else { sendMessage(sender, config.getString("messages.player-not-found")); playSound(sender, config.getString("sounds.error")); } } private void handleSameServerTpa(Player sender, Player target) { if (sender.equals(target)) { playSound(sender, config.getString("sounds.error")); return; } if (tpaToggle.getOrDefault(target.getUniqueId().toString(), false)) { sendMessage(sender, config.getString("messages.user-disabled-tpa")); playSound(sender, config.getString("sounds.error")); return; } String key = sender.getUniqueId() + target.getUniqueId().toString(); if (teleportRequests.containsKey(key)) { sendMessage(sender, config.getString("messages.on-cooldown")); playSound(sender, config.getString("sounds.error")); return; } if (tpAutoPlayers.getOrDefault(target.getUniqueId().toString(), false)) { handleAutoAccept(sender, target, "To"); return; } openTpaConfirmationGUI(sender, target); } private void handleSameServerTpaHere(Player sender, Player target) { if (sender.equals(target)) { playSound(sender, config.getString("sounds.error")); return; } if (tpaHereToggle.getOrDefault(target.getUniqueId().toString(), false)) { sendMessage(sender, config.getString("messages.user-disabled-tpahere")); playSound(sender, config.getString("sounds.error")); return; } String key = sender.getUniqueId() + target.getUniqueId().toString(); if (teleportRequests.containsKey(key)) { sendMessage(sender, config.getString("messages.on-cooldown")); playSound(sender, config.getString("sounds.error")); return; } if (tpAutoPlayers.getOrDefault(target.getUniqueId().toString(), false)) { handleAutoAccept(sender, target, "Here"); return; } openTpaHereConfirmationGUI(sender, target); } // ------------------------------------------------------------------------- // PROPER PLAYER SERVER LOOKUP (async using request ID) // ------------------------------------------------------------------------- private void requestPlayerServer(Player sender, String playerName, Consumer callback) { String requestId = UUID.randomUUID().toString(); pendingServerRequests.put(requestId, callback); // We need to send a custom "GetServerWithId" because BungeeCord's GetServer doesn't return an ID. // Instead, we'll send a "Forward" to the proxy with a custom "GetServerRequest" subchannel. // Simpler approach: use the existing "teleport:cross" channel to ask the proxy. // But to keep it compatible with both Bungee and Velocity, we'll use the built-in "GetServer" // and match the response by player name (not perfect but works if no two lookups for same player at once). // However, we need the sender to send the message. So we use the provided sender parameter. // We'll send a "GetServer" via BungeeCord and match the response by player name. // The response will come on "BungeeCord" with subchannel "PlayerServer" – no ID. // To avoid conflicts, we store the callback keyed by playerName.toLowerCase() and assume only one lookup per player at a time. pendingServerRequests.remove(playerName.toLowerCase()); // cleanup old pendingServerRequests.put(playerName.toLowerCase(), callback); ByteArrayDataOutput out = ByteStreams.newDataOutput(); out.writeUTF("GetServer"); out.writeUTF(playerName); sender.sendPluginMessage(this, "BungeeCord", out.toByteArray()); // Timeout after 3 seconds new BukkitRunnable() { @Override public void run() { Consumer cb = pendingServerRequests.remove(playerName.toLowerCase()); if (cb != null) { cb.accept(null); } } }.runTaskLater(this, 60L); } // ------------------------------------------------------------------------- // CROSS-SERVER REQUEST SENDING // ------------------------------------------------------------------------- private void sendCrossServerRequest(Player sender, String targetName, String type, String targetServer) { String requestId = UUID.randomUUID().toString(); CrossServerRequest req = new CrossServerRequest( sender.getName(), sender.getUniqueId(), targetName, null, type, getCurrentServerName() ); crossServerRequests.put(requestId, req); ByteArrayDataOutput out = ByteStreams.newDataOutput(); out.writeUTF("REQUEST"); out.writeUTF(requestId); out.writeUTF(sender.getName()); out.writeUTF(sender.getUniqueId().toString()); out.writeUTF(targetName); out.writeUTF(type); out.writeUTF(getCurrentServerName()); sendPluginMessageToServer(targetServer, out.toByteArray()); String sentMsg = type.equals("To") ? config.getString("messages.request-sent-tpa") : config.getString("messages.request-sent-tpahere"); sendMessage(sender, sentMsg.replace("%player%", targetName)); playSound(sender, config.getString("sounds.success")); new BukkitRunnable() { @Override public void run() { CrossServerRequest r = crossServerRequests.remove(requestId); if (r != null) { Player p = Bukkit.getPlayer(r.senderUUID); if (p != null) { sendMessage(p, config.getString("messages.request-not-exist")); } } } }.runTaskLater(this, config.getInt("teleport.request-timeout") * 20L); } private void handleCrossServerRequest(String requestId, String senderName, String senderUUID, String targetName, String type, String sourceServer) { Player targetPlayer = Bukkit.getPlayer(targetName); if (targetPlayer == null) return; UUID targetUUID = targetPlayer.getUniqueId(); if (("To".equals(type) && tpaToggle.getOrDefault(targetUUID.toString(), false)) || ("Here".equals(type) && tpaHereToggle.getOrDefault(targetUUID.toString(), false))) { sendCrossServerResponse(requestId, "DENY", null, sourceServer, "toggles_disabled"); return; } String key = senderUUID + targetUUID.toString(); teleportRequests.put(key, type); lastRequestSenders.put(targetUUID, senderName); CrossServerRequest req = new CrossServerRequest(senderName, UUID.fromString(senderUUID), targetName, targetUUID, type, sourceServer); crossServerRequests.put(requestId, req); String receivedMsg = type.equals("To") ? config.getString("messages.request-received-tpa") : config.getString("messages.request-received-tpahere"); sendMessage(targetPlayer, receivedMsg.replace("%player%", senderName)); sendClickableAcceptMessage(targetPlayer, senderName); sendMessage(targetPlayer, config.getString("messages.tp-trap-warning")); playSound(targetPlayer, config.getString("sounds.success")); } private void handleCrossServerAccept(String requestId, Player accepter) { CrossServerRequest req = crossServerRequests.get(requestId); if (req == null || req.isExpired()) { sendMessage(accepter, config.getString("messages.request-not-exist")); playSound(accepter, config.getString("sounds.error")); return; } crossServerRequests.remove(requestId); String key = req.senderUUID.toString() + accepter.getUniqueId().toString(); teleportRequests.remove(key); lastRequestSenders.remove(accepter.getUniqueId()); sendCrossServerResponse(requestId, "ACCEPT", accepter.getLocation(), req.sourceServer, null); } private void sendCrossServerResponse(String requestId, String status, Location location, String targetServer, String reason) { ByteArrayDataOutput out = ByteStreams.newDataOutput(); out.writeUTF("RESPONSE"); out.writeUTF(requestId); out.writeUTF(status); if (location != null) { out.writeUTF(location.getWorld().getName()); out.writeDouble(location.getX()); out.writeDouble(location.getY()); out.writeDouble(location.getZ()); out.writeFloat(location.getYaw()); out.writeFloat(location.getPitch()); } else { out.writeUTF(""); } out.writeUTF(reason != null ? reason : ""); sendPluginMessageToServer(targetServer, out.toByteArray()); } private void handleCrossServerResponse(String requestId, String status, Location location, String reason) { CrossServerRequest req = crossServerRequests.remove(requestId); if (req == null) return; if ("ACCEPT".equals(status) && location != null) { if ("To".equals(req.type)) { pendingTeleportLocations.put(req.senderUUID, location); Player sender = Bukkit.getPlayer(req.senderUUID); if (sender != null) { connectPlayerToServer(sender, req.sourceServer); } } else if ("Here".equals(req.type)) { pendingTeleportLocations.put(req.targetUUID, location); Player target = Bukkit.getPlayer(req.targetUUID); if (target != null) { connectPlayerToServer(target, getCurrentServerName()); } } } else if ("DENY".equals(status)) { Player sender = Bukkit.getPlayer(req.senderUUID); if (sender != null) { sendMessage(sender, config.getString("messages.request-denied").replace("%player%", req.targetName)); } } } // ------------------------------------------------------------------------- // PLUGIN MESSAGE RECEIVER // ------------------------------------------------------------------------- @Override public void onPluginMessageReceived(String channel, Player player, byte[] message) { if (!crossServerEnabled) return; if (channel.equals("teleport:cross")) { ByteArrayDataInput in = ByteStreams.newDataInput(message); String subChannel = in.readUTF(); switch (subChannel) { case "REQUEST": String reqId = in.readUTF(); String sName = in.readUTF(); String sUUID = in.readUTF(); String tName = in.readUTF(); String type = in.readUTF(); String srcServer = in.readUTF(); handleCrossServerRequest(reqId, sName, sUUID, tName, type, srcServer); break; case "RESPONSE": String respId = in.readUTF(); String status = in.readUTF(); String locWorld = in.readUTF(); Location loc = null; if (!locWorld.isEmpty()) { double x = in.readDouble(); double y = in.readDouble(); double z = in.readDouble(); float yaw = in.readFloat(); float pitch = in.readFloat(); loc = new Location(Bukkit.getWorld(locWorld), x, y, z, yaw, pitch); } String reason = in.readUTF(); handleCrossServerResponse(respId, status, loc, reason); break; } } else if (channel.equals("BungeeCord")) { ByteArrayDataInput in = ByteStreams.newDataInput(message); String subChannel = in.readUTF(); if (subChannel.equals("PlayerServer")) { String playerName = in.readUTF(); String serverName = in.readUTF(); Consumer callback = pendingServerRequests.remove(playerName.toLowerCase()); if (callback != null) { callback.accept(serverName); } } } } // ------------------------------------------------------------------------- // UTILITIES // ------------------------------------------------------------------------- private String getCurrentServerName() { return config.getString("cross-server.server-name", "unknown"); } private void sendPluginMessageToServer(String serverName, byte[] data) { ByteArrayDataOutput out = ByteStreams.newDataOutput(); out.writeUTF("Forward"); out.writeUTF(serverName); out.writeUTF("teleport:cross"); out.writeShort(data.length); out.write(data); getServer().sendPluginMessage(this, "BungeeCord", out.toByteArray()); } private void connectPlayerToServer(Player player, String serverName) { ByteArrayDataOutput out = ByteStreams.newDataOutput(); out.writeUTF("Connect"); out.writeUTF(serverName); player.sendPluginMessage(this, "BungeeCord", out.toByteArray()); } // ------------------------------------------------------------------------- // GUI, AUTO-ACCEPT, TPACCEPT, ETC. // ------------------------------------------------------------------------- private void handleAutoAccept(Player sender, Player target, String requestType) { String requestKey = sender.getUniqueId() + target.getUniqueId().toString(); teleportRequests.put(requestKey, requestType); sendMessage(target, "�FC00Auto-accepted %BFF8" + sender.getName() + "�FC00's teleport request!"); sendMessage(sender, "�FC00Your teleport request was auto-accepted by %BFF8" + target.getName()); playSound(target, config.getString("sounds.success")); playSound(sender, config.getString("sounds.success")); if (requestType.equals("To")) { startTeleportCountdown(sender, target.getLocation(), false, true); } else { startTeleportCountdown(target, sender.getLocation(), true, true); } new BukkitRunnable() { @Override public void run() { teleportRequests.remove(requestKey); } }.runTaskLater(this, config.getInt("teleport.request-timeout") * 20L); } private void handleTpAcceptRecent(Player accepter) { String last = lastRequestSenders.get(accepter.getUniqueId()); if (last == null) { sendMessage(accepter, config.getString("messages.request-not-exist")); playSound(accepter, config.getString("sounds.error")); return; } handleTpAcceptCommand(accepter, last); } private void handleTpAcceptCommand(Player accepter, String senderName) { Player sender = Bukkit.getPlayer(senderName); if (sender != null) { String key = sender.getUniqueId() + accepter.getUniqueId().toString(); if (!teleportRequests.containsKey(key)) { sendMessage(accepter, config.getString("messages.request-not-exist")); playSound(accepter, config.getString("sounds.error")); return; } lastRequestSenders.put(accepter.getUniqueId(), sender.getName()); openTpAcceptGUI(accepter, sender); } else if (crossServerEnabled) { for (Map.Entry entry : crossServerRequests.entrySet()) { CrossServerRequest req = entry.getValue(); if (req.targetName.equalsIgnoreCase(accepter.getName()) && !req.isExpired()) { handleCrossServerAccept(entry.getKey(), accepter); return; } } sendMessage(accepter, config.getString("messages.request-not-exist")); playSound(accepter, config.getString("sounds.error")); } else { sendMessage(accepter, config.getString("messages.request-not-exist")); playSound(accepter, config.getString("sounds.error")); } } private void handleTpaCancelCommand(Player accepter, String senderName) { Player sender = Bukkit.getPlayer(senderName); if (sender != null) { String key = sender.getUniqueId() + accepter.getUniqueId().toString(); if (teleportRequests.containsKey(key)) { teleportRequests.remove(key); sendMessage(accepter, config.getString("messages.request-denied").replace("%player%", sender.getName())); sendMessage(sender, config.getString("messages.request-denied-notify").replace("%player%", accepter.getName())); playSound(accepter, config.getString("sounds.success")); playSound(sender, config.getString("sounds.error")); return; } } if (crossServerEnabled) { for (Map.Entry entry : crossServerRequests.entrySet()) { CrossServerRequest req = entry.getValue(); if (req.targetName.equalsIgnoreCase(accepter.getName()) && req.senderName.equalsIgnoreCase(senderName)) { crossServerRequests.remove(entry.getKey()); sendMessage(accepter, config.getString("messages.request-denied").replace("%player%", senderName)); return; } } } sendMessage(accepter, config.getString("messages.request-not-exist")); playSound(accepter, config.getString("sounds.error")); } private void openTpaConfirmationGUI(Player player, Player target) { Inventory gui = Bukkit.createInventory(null, 27, colorize(config.getString("gui.confirm-request"))); guiPlayers.put(player.getUniqueId(), target.getName()); guiRequestTypes.put(player.getUniqueId(), "tpa"); gui.setItem(10, createItem(Material.RED_STAINED_GLASS_PANE, "&#FC0000ᴄᴀɴᴄᴇʟ", "&7Click to cancel")); gui.setItem(12, getLocationItem(target)); gui.setItem(13, getPlayerHead(target)); gui.setItem(14, createItem(Material.FEATHER, "�F986ʀᴇɢɪᴏɴ", "&#A8A8A8NA East (�A4FC" + getPing(target) + "ms&#A8A8A8)")); gui.setItem(16, createItem(Material.LIME_STAINED_GLASS_PANE, "�FC00ᴄᴏɴꜰɪʀᴍ", "&7Click to send request")); player.openInventory(gui); playSound(player, config.getString("sounds.gui-click")); } private void openTpaHereConfirmationGUI(Player player, Player target) { Inventory gui = Bukkit.createInventory(null, 27, colorize(config.getString("gui.confirm-request"))); guiPlayers.put(player.getUniqueId(), target.getName()); guiRequestTypes.put(player.getUniqueId(), "tpahere"); gui.setItem(10, createItem(Material.RED_STAINED_GLASS_PANE, "&#FC0000ᴄᴀɴᴄᴇʟ", "&7Click to cancel")); gui.setItem(12, getLocationItem(target)); gui.setItem(13, getPlayerHead(target)); gui.setItem(14, createItem(Material.FEATHER, "�F986ʀᴇɢɪᴏɴ", "&#A8A8A8NA East (�A4FC" + getPing(target) + "ms&#A8A8A8)")); gui.setItem(16, createItem(Material.LIME_STAINED_GLASS_PANE, "�FC00ᴄᴏɴꜰɪʀᴍ", "&7Click to teleport them to you")); player.openInventory(gui); playSound(player, config.getString("sounds.gui-click")); } private void openTpAcceptGUI(Player player, Player target) { Inventory gui = Bukkit.createInventory(null, 27, colorize(config.getString("gui.accept-request"))); guiPlayers.put(player.getUniqueId(), target.getName()); guiRequestTypes.put(player.getUniqueId(), "accept"); gui.setItem(10, createItem(Material.RED_STAINED_GLASS_PANE, "&#FC0000ᴄᴀɴᴄᴇʟ", "&7Click to cancel")); gui.setItem(12, getLocationItem(target)); gui.setItem(13, getPlayerHead(target)); gui.setItem(14, createItem(Material.FEATHER, "�F986ʀᴇɢɪᴏɴ", "&#A8A8A8NA East (�A4FC" + getPing(target) + "ms&#A8A8A8)")); gui.setItem(16, createItem(Material.LIME_STAINED_GLASS_PANE, "�FC00ᴄᴏɴꜰɪʀᴍ", "&7Click to accept request")); player.openInventory(gui); playSound(player, config.getString("sounds.gui-click")); } @EventHandler public void onInventoryClick(InventoryClickEvent event) { if (!(event.getWhoClicked() instanceof Player)) return; Player player = (Player) event.getWhoClicked(); String title = event.getView().getTitle(); if (title.equals(colorize(config.getString("gui.confirm-request"))) || title.equals(colorize(config.getString("gui.accept-request")))) { event.setCancelled(true); if (event.getSlot() == 16) { handleConfirmClick(player, title); } else if (event.getSlot() == 10) { player.closeInventory(); playSound(player, config.getString("sounds.gui-click")); guiPlayers.remove(player.getUniqueId()); guiRequestTypes.remove(player.getUniqueId()); } } } private void handleConfirmClick(Player player, String title) { String targetName = guiPlayers.get(player.getUniqueId()); String reqType = guiRequestTypes.get(player.getUniqueId()); Player target = Bukkit.getPlayer(targetName); if (target == null) { sendMessage(player, config.getString("messages.player-not-found")); player.closeInventory(); guiPlayers.remove(player.getUniqueId()); guiRequestTypes.remove(player.getUniqueId()); return; } player.closeInventory(); playSound(player, config.getString("sounds.gui-click")); if (reqType.equals("tpa") || reqType.equals("tpahere")) { String key = player.getUniqueId() + target.getUniqueId().toString(); teleportRequests.put(key, reqType.equals("tpa") ? "To" : "Here"); if (reqType.equals("tpa")) sendTpaRequest(player, target); else sendTpaHereRequest(player, target); lastRequestSenders.put(target.getUniqueId(), player.getName()); new BukkitRunnable() { @Override public void run() { teleportRequests.remove(key); if (player.getName().equals(lastRequestSenders.get(target.getUniqueId()))) { lastRequestSenders.remove(target.getUniqueId()); } } }.runTaskLater(this, config.getInt("teleport.request-timeout") * 20L); } else if (reqType.equals("accept")) { String key = target.getUniqueId() + player.getUniqueId().toString(); String stored = teleportRequests.get(key); if (stored != null) { teleportRequests.remove(key); handleTeleportAccept(player, target, stored); lastRequestSenders.remove(player.getUniqueId()); } } guiPlayers.remove(player.getUniqueId()); guiRequestTypes.remove(player.getUniqueId()); } private void sendTpaRequest(Player sender, Player target) { sendMessage(sender, config.getString("messages.request-sent-tpa").replace("%player%", target.getName())); sendMessage(target, config.getString("messages.request-received-tpa").replace("%player%", sender.getName())); sendClickableAcceptMessage(target, sender.getName()); sendMessage(target, config.getString("messages.tp-trap-warning")); playSound(sender, config.getString("sounds.success")); playSound(target, config.getString("sounds.success")); } private void sendTpaHereRequest(Player sender, Player target) { sendMessage(sender, config.getString("messages.request-sent-tpahere").replace("%player%", target.getName())); sendMessage(target, config.getString("messages.request-received-tpahere").replace("%player%", sender.getName())); sendClickableAcceptMessage(target, sender.getName()); sendMessage(target, config.getString("messages.tp-trap-warning")); playSound(sender, config.getString("sounds.success")); playSound(target, config.getString("sounds.success")); } private void sendClickableAcceptMessage(Player player, String senderName) { TextComponent msg = new TextComponent(colorize("�A4FB[CLICK TO ACCEPT]")); msg.setClickEvent(new ClickEvent(ClickEvent.Action.RUN_COMMAND, "/tpaccept " + senderName)); msg.setHoverEvent(new HoverEvent(HoverEvent.Action.SHOW_TEXT, new ComponentBuilder("Click to accept").create())); TextComponent or = new TextComponent(colorize(" &r&#A8A8A8or type �A4FB/tpaccept " + senderName)); player.spigot().sendMessage(msg, or); } private void handleTeleportAccept(Player accepter, Player requester, String type) { sendMessage(requester, config.getString("messages.request-accepted").replace("%player%", accepter.getName())); sendMessage(accepter, config.getString("messages.self-accepted")); playSound(accepter, config.getString("sounds.success")); playSound(requester, config.getString("sounds.success")); if (type.equals("To")) { startTeleportCountdown(requester, accepter.getLocation(), false, false); } else { startTeleportCountdown(accepter, requester.getLocation(), true, false); } } private void startTeleportCountdown(Player player, Location dest, boolean isTpaHere, boolean auto) { UUID pid = player.getUniqueId(); teleportingPlayers.put(pid.toString(), true); teleportPositions.put(pid.toString(), player.getLocation()); new BukkitRunnable() { int countdown = config.getInt("teleport.countdown", 5); @Override public void run() { if (!teleportingPlayers.containsKey(pid.toString()) || !player.isOnline()) { cancel(); return; } if (countdown <= 0) { player.teleport(dest); sendMessage(player, auto ? "�FC00Auto-teleport complete!" : config.getString("messages.teleport-complete")); playSound(player, config.getString("sounds.teleport-complete")); teleportingPlayers.remove(pid.toString()); teleportPositions.remove(pid.toString()); cancel(); return; } sendMessage(player, config.getString("messages.teleporting-countdown").replace("%seconds%", String.valueOf(countdown))); playSound(player, config.getString("sounds.teleport-start")); countdown--; } }.runTaskTimer(this, 0L, 20L); } @EventHandler public void onPlayerMove(PlayerMoveEvent event) { Player p = event.getPlayer(); String id = p.getUniqueId().toString(); if (teleportingPlayers.containsKey(id)) { Location to = event.getTo(); Location start = teleportPositions.get(id); if (to != null && start != null && to.distance(start) > config.getDouble("teleport.movement-threshold", 0.5)) { teleportingPlayers.remove(id); teleportPositions.remove(id); sendMessage(p, config.getString("messages.teleport-cancelled-moved")); playSound(p, config.getString("sounds.error")); } } } @EventHandler public void onPlayerQuit(PlayerQuitEvent event) { Player p = event.getPlayer(); String id = p.getUniqueId().toString(); teleportPositions.remove(id); teleportingPlayers.remove(id); guiPlayers.remove(p.getUniqueId()); guiRequestTypes.remove(p.getUniqueId()); lastRequestSenders.remove(p.getUniqueId()); stopActionBar(p); teleportRequests.entrySet().removeIf(e -> e.getKey().contains(id)); if (crossServerEnabled) { pendingTeleportLocations.remove(p.getUniqueId()); crossServerRequests.entrySet().removeIf(e -> e.getValue().senderUUID.equals(p.getUniqueId()) || (e.getValue().targetUUID != null && e.getValue().targetUUID.equals(p.getUniqueId())) ); } } @EventHandler public void onPlayerJoin(PlayerJoinEvent event) { if (crossServerEnabled) { Location pending = pendingTeleportLocations.remove(event.getPlayer().getUniqueId()); if (pending != null) { new BukkitRunnable() { @Override public void run() { if (event.getPlayer().isOnline()) { event.getPlayer().teleport(pending); sendMessage(event.getPlayer(), config.getString("messages.teleport-complete")); playSound(event.getPlayer(), config.getString("sounds.teleport-complete")); } } }.runTaskLater(TeleportPlugin.this, 20L); } } } private void handleTpAutoCommand(Player player) { String id = player.getUniqueId().toString(); boolean cur = tpAutoPlayers.getOrDefault(id, false); if (cur) { tpAutoPlayers.put(id, false); sendMessage(player, "&cTP Auto-accept disabled!"); stopActionBar(player); } else { tpAutoPlayers.put(id, true); sendMessage(player, "&aTP Auto-accept enabled!"); startActionBar(player); } playSound(player, config.getString("sounds.success")); } private void startActionBar(Player player) { stopActionBar(player); BukkitRunnable task = new BukkitRunnable() { @Override public void run() { if (!player.isOnline() || !tpAutoPlayers.getOrDefault(player.getUniqueId().toString(), false)) { cancel(); return; } sendActionBar(player, "�FC00TP Auto-accept Enabled"); } }; task.runTaskTimer(this, 0L, 20L); actionBarTasks.put(player.getUniqueId(), task); } private void stopActionBar(Player player) { BukkitRunnable task = actionBarTasks.remove(player.getUniqueId()); if (task != null) task.cancel(); sendActionBar(player, ""); } private void handleTpaToggleCommand(Player player) { String id = player.getUniqueId().toString(); boolean cur = tpaToggle.getOrDefault(id, false); tpaToggle.put(id, !cur); sendMessage(player, cur ? "&aTPA requests enabled!" : "&cTPA requests disabled!"); playSound(player, config.getString("sounds.success")); } private void handleTpaHereToggleCommand(Player player) { String id = player.getUniqueId().toString(); boolean cur = tpaHereToggle.getOrDefault(id, false); tpaHereToggle.put(id, !cur); sendMessage(player, cur ? "&aTPAHere requests enabled!" : "&cTPAHere requests disabled!"); playSound(player, config.getString("sounds.success")); } // Helper methods private ItemStack getLocationItem(Player player) { String world = player.getWorld().getName(); String display = config.getString("worlds." + world, "&7Unknown"); Material mat = Material.GRASS_BLOCK; switch (world) { case "spawn": case "afk": mat = Material.IRON_BLOCK; break; case "world_nether": mat = Material.NETHERRACK; break; case "world_the_end": mat = Material.END_STONE; break; case "arena_badlands": mat = Material.RED_SAND; break; case "arena_flat": mat = Material.NETHERITE_BLOCK; break; case "arena_desert": mat = Material.SAND; break; } return createItem(mat, "�F986ʟᴏᴄᴀᴛɪᴏɴ", display); } private ItemStack getPlayerHead(Player player) { ItemStack head = new ItemStack(Material.PLAYER_HEAD); SkullMeta meta = (SkullMeta) head.getItemMeta(); if (meta != null) { meta.setOwningPlayer(player); meta.setDisplayName(colorize("�F986ᴘʟᴀʏᴇʀ")); meta.setLore(Collections.singletonList(colorize("&7" + player.getName()))); head.setItemMeta(meta); } return head; } private int getPing(Player player) { return player.getPing(); } private ItemStack createItem(Material mat, String name, String... lore) { ItemStack item = new ItemStack(mat); ItemMeta meta = item.getItemMeta(); if (meta != null) { meta.setDisplayName(colorize(name)); if (lore.length > 0) { List colored = new ArrayList<>(); for (String l : lore) colored.add(colorize(l)); meta.setLore(colored); } item.setItemMeta(meta); } return item; } private void sendMessage(Player player, String msg) { if (msg != null) player.sendMessage(colorize(msg)); } private void sendActionBar(Player player, String msg) { try { player.sendActionBar(colorize(msg)); } catch (Exception e) { sendMessage(player, msg); } } private void playSound(Player player, String soundName) { try { Sound sound = Sound.valueOf(soundName); player.playSound(player.getLocation(), sound, 1f, 1f); } catch (IllegalArgumentException e) { player.playSound(player.getLocation(), Sound.ENTITY_VILLAGER_NO, 1f, 1f); } } private String colorize(String msg) { if (msg == null) return ""; Matcher m = hexPattern.matcher(msg); StringBuffer sb = new StringBuffer(); while (m.find()) { String hex = m.group(1); m.appendReplacement(sb, "§x§" + hex.charAt(0) + "§" + hex.charAt(1) + "§" + hex.charAt(2) + "§" + hex.charAt(3) + "§" + hex.charAt(4) + "§" + hex.charAt(5)); } msg = m.appendTail(sb).toString(); return ChatColor.translateAlternateColorCodes('&', msg); } }