package com.agserverstats; import org.bukkit.Bukkit; import org.bukkit.command.Command; import org.bukkit.command.CommandSender; import org.bukkit.command.TabCompleter; import org.bukkit.plugin.java.JavaPlugin; import java.io.BufferedReader; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Set; import java.util.stream.Collectors; import com.google.gson.JsonArray; import com.google.gson.JsonElement; import com.google.gson.JsonObject; import com.google.gson.JsonParser; public class AGServerStats extends JavaPlugin implements TabCompleter, IStatsProvider{ private ServerInfo serverInfo = new ServerInfo(false,0,"",""); private Map serverInfos = new java.util.HashMap<>(); @Override public void onEnable(){ saveDefaultConfig(); getCommand("agserverstatus").setExecutor(this); getCommand("agserverstatus").setTabCompleter(this); Bukkit.getScheduler().runTaskTimerAsynchronously(this,this::updateStats,0,600); if(Bukkit.getPluginManager().getPlugin("PlaceholderAPI") != null){ new AGServerStatsExpansion(this).register(); } } private void updateStats(){ Set serverNames = getConfig().getConfigurationSection("servers").getKeys(false); for(String name : serverNames){ String ip = getConfig().getString("servers." + name + ".ip"); if(ip == null) continue; String[] parts = ip.split(":"); String ipAddr = parts[0]; int port = parts.length > 1 ? Integer.parseInt(parts[1]): 25565; ServerInfo pinged = pingServer(ipAddr,port); serverInfos.put(name,new ServerInfo(pinged.online,pinged.players,pinged.motd,pinged.status)); } if(!serverInfos.isEmpty()){ serverInfo = serverInfos.values().iterator().next(); } } private ServerInfo pingServer(String ip,int port){ try{ URL url = new URL("https://api.mcsrvstat.us/2/" + ip +(port == 25565 ? "" : ":" + port)); HttpURLConnection conn =(HttpURLConnection)url.openConnection(); conn.setRequestMethod("GET"); conn.connect(); int responseCode = conn.getResponseCode(); if(responseCode != 200)return new ServerInfo(false,0,"","Offline"); BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream())); StringBuilder sb = new StringBuilder(); String line; while((line = in.readLine())!= null)sb.append(line); in.close(); JsonObject obj = JsonParser.parseString(sb.toString()).getAsJsonObject(); boolean online = obj.get("online").getAsBoolean(); if(!online)return new ServerInfo(false,0,"","Offline"); JsonObject playersObj = obj.get("players").getAsJsonObject(); int onlinePlayers = playersObj.get("online").getAsInt(); String motd = ""; if(obj.has("motd")&& obj.get("motd").isJsonObject()){ JsonObject motdObj = obj.get("motd").getAsJsonObject(); if(motdObj.has("clean")&& motdObj.get("clean").isJsonArray()){ JsonArray cleanArray = motdObj.get("clean").getAsJsonArray(); if(!cleanArray.isEmpty()){ motd = cleanArray.get(0).getAsString(); } } } return new ServerInfo(true,onlinePlayers,motd,"Online"); } catch(Exception e){ return new ServerInfo(false,0,"","Offline"); } } public ServerInfo getServerInfo(){ return serverInfo; } public Map getServerInfos(){ return serverInfos; } @Override public boolean onCommand(CommandSender sender,Command command,String label,String[] args){ if(args.length == 0){ sender.sendMessage("Usage: /" + label + " [args]"); return true; } if(args[0].equalsIgnoreCase("reload")){ reloadConfig(); updateStats(); sender.sendMessage("Config reloaded and stats updated."); return true; } if(args[0].equalsIgnoreCase("status")){ List namesToCheck = new ArrayList<>(); if(args.length == 1){ namesToCheck.addAll(getConfig().getConfigurationSection("servers").getKeys(false)); } else{ for(int i = 1; i < args.length; i++){ namesToCheck.add(args[i]); } } for(String name : namesToCheck){ ServerInfo info = serverInfos.get(name); if(info != null){ sender.sendMessage(name + ": " + info.status + (info.online ? " (" + info.players + " players - " + info.motd + ")" : "")); } else{ sender.sendMessage(name + ": Not found"); } } return true; } if(args[0].equalsIgnoreCase("changename")){ if(args.length != 3){ sender.sendMessage("Usage: /" + label + " changename "); return true; } String serverName = args[1]; String newName = args[2]; if(!getConfig().getConfigurationSection("servers").getKeys(false).contains(serverName)){ sender.sendMessage("Server not found: " + serverName); return true; } if(getConfig().getConfigurationSection("servers").getKeys(false).contains(newName)){ sender.sendMessage("Server name already exists: " + newName); return true; } String ip = getConfig().getString("servers." + serverName + ".ip"); getConfig().set("servers." + serverName,null); getConfig().set("servers." + newName + ".ip",ip); saveConfig(); reloadConfig(); updateStats(); sender.sendMessage("Server name changed from " + serverName + " to " + newName); return true; } if(args[0].equalsIgnoreCase("changeip")){ if(args.length != 3){ sender.sendMessage("Usage: /" + label + " changeip "); return true; } String serverName = args[1]; String newIp = args[2]; if(!getConfig().getConfigurationSection("servers").getKeys(false).contains(serverName)){ sender.sendMessage("Server not found: " + serverName); return true; } getConfig().set("servers." + serverName + ".ip",newIp); saveConfig(); reloadConfig(); updateStats(); sender.sendMessage("IP changed for " + serverName + " to " + newIp); return true; } if(args[0].equalsIgnoreCase("changestatus")){ if(args.length != 3){ sender.sendMessage("Usage: /" + label + " changestatus "); return true; } String serverName = args[1]; String newStatus = args[2]; if(!serverInfos.containsKey(serverName)){ sender.sendMessage("Server not found: " + serverName); return true; } if(newStatus.equalsIgnoreCase("reset")){ String ip = getConfig().getString("servers." + serverName + ".ip"); if(ip != null){ String[] parts = ip.split(":"); String ipAddr = parts[0]; int port = parts.length > 1 ? Integer.parseInt(parts[1]): 25565; ServerInfo pinged = pingServer(ipAddr,port); serverInfos.put(serverName,pinged); sender.sendMessage("Status reset for " + serverName); } }else{ ServerInfo current = serverInfos.get(serverName); serverInfos.put(serverName,new ServerInfo(current.online,current.players,current.motd,newStatus)); sender.sendMessage("Status changed for " + serverName + " to " + newStatus); } return true; } return false; } @Override public List onTabComplete(CommandSender sender,Command command,String alias,String[] args){ List completions = new ArrayList<>(); if(args.length == 1){ completions.add("reload"); completions.add("status"); completions.add("changename"); completions.add("changeip"); completions.add("changestatus"); } else if(args.length == 2){ if(args[0].equalsIgnoreCase("changename")|| args[0].equalsIgnoreCase("changeip")|| args[0].equalsIgnoreCase("changestatus")|| args[0].equalsIgnoreCase("status")){ completions.addAll(getConfig().getConfigurationSection("servers").getKeys(false)); } } else if(args.length == 3 && args[0].equalsIgnoreCase("changestatus")){ completions.add("online"); completions.add("offline"); completions.add("coming soon"); completions.add("reset"); } return completions.stream().filter(s -> s.toLowerCase().startsWith(args[args.length-1].toLowerCase())).collect(Collectors.toList()); } }