package com.example.simpleauth; import com.google.gson.JsonObject; import com.google.gson.JsonParser; import org.bukkit.Bukkit; import org.bukkit.entity.Player; import org.bukkit.scheduler.BukkitTask; import java.io.BufferedReader; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.util.HashSet; import java.util.Map; import java.util.Set; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; public class AuthManager { private final SimpleAuthPlugin plugin; private final Map authenticated = new ConcurrentHashMap<>(); private final Set premiumChecked = new HashSet<>(); private final Set premiumPlayers = new HashSet<>(); private final Map timeoutTasks = new ConcurrentHashMap<>(); public AuthManager(SimpleAuthPlugin plugin) { this.plugin = plugin; } public boolean isAuthenticated(UUID uuid) { return authenticated.getOrDefault(uuid, false); } public void setAuthenticated(UUID uuid, boolean value) { authenticated.put(uuid, value); cancelTimeout(uuid); } public boolean isPremium(UUID uuid) { return premiumPlayers.contains(uuid); } public boolean isPremiumChecked(UUID uuid) { return premiumChecked.contains(uuid); } public void checkPremium(final Player player) { UUID uuid = player.getUniqueId(); premiumChecked.add(uuid); Bukkit.getScheduler().runTaskAsynchronously(plugin, () -> { boolean premium = checkMojangAccount(player.getName()); Bukkit.getScheduler().runTask(plugin, () -> { if (premium) { premiumPlayers.add(uuid); setAuthenticated(uuid, true); String prefix = plugin.getConfig().getString("prefix", "&8[&6Auth&8]&r "); String msg = plugin.getConfig().getString("messages.premium-auto-auth", "&aPremium account detected — automatically authenticated!"); player.sendMessage(org.bukkit.ChatColor.translateAlternateColorCodes('&', prefix + msg)); } else { boolean registered = plugin.getDatabaseManager().isRegistered(uuid); String prefix = plugin.getConfig().getString("prefix", "&8[&6Auth&8]&r "); if (registered) { String msg = plugin.getConfig().getString("messages.login-required", "&cPlease login using &e/login "); player.sendMessage(org.bukkit.ChatColor.translateAlternateColorCodes('&', prefix + msg)); } else { String msg = plugin.getConfig().getString("messages.register-required", "&cPlease register using &e/register "); player.sendMessage(org.bukkit.ChatColor.translateAlternateColorCodes('&', prefix + msg)); } startTimeout(player); } }); }); } private boolean checkMojangAccount(String playerName) { try { URL url = new URL("https://api.mojang.com/users/profiles/minecraft/" + playerName); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setRequestMethod("GET"); conn.setConnectTimeout(5000); conn.setReadTimeout(5000); int responseCode = conn.getResponseCode(); if (responseCode == 200) { BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream())); StringBuilder response = new StringBuilder(); String line; while ((line = reader.readLine()) != null) { response.append(line); } reader.close(); JsonObject json = JsonParser.parseString(response.toString()).getAsJsonObject(); return json.has("id") && json.has("name"); } } catch (Exception e) { plugin.getLogger().warning("Mojang API check failed for " + playerName + ": " + e.getMessage()); } return false; } private void startTimeout(Player player) { int timeout = plugin.getConfig().getInt("login-timeout", 60); BukkitTask task = Bukkit.getScheduler().runTaskLater(plugin, () -> { if (!isAuthenticated(player.getUniqueId())) { String msg = plugin.getConfig().getString("timeout-kick-message", "&cAuthentication timed out. Please reconnect and login."); player.kickPlayer(org.bukkit.ChatColor.translateAlternateColorCodes('&', msg)); } }, timeout * 20L); timeoutTasks.put(player.getUniqueId(), task); } public void cancelTimeout(UUID uuid) { BukkitTask task = timeoutTasks.remove(uuid); if (task != null) { task.cancel(); } } public void removePlayer(UUID uuid) { authenticated.remove(uuid); premiumChecked.remove(uuid); premiumPlayers.remove(uuid); cancelTimeout(uuid); } public void shutdown() { for (BukkitTask task : timeoutTasks.values()) { task.cancel(); } timeoutTasks.clear(); } }