From 4b1d6756e2159cb196853e14ccc73e04673761e9 Mon Sep 17 00:00:00 2001 From: Jonathan Williams Date: Thu, 5 Sep 2013 02:12:12 -0700 Subject: [PATCH] Added missing PlayerCount project. --- .../Mineplex.Bungee.PlayerCount/.classpath | 7 + .../.settings/org.eclipse.jdt.core.prefs | 11 + .../Mineplex.Bungee.PlayerCount/plugin.yml | 4 + .../bungee/PlayerCount/PlayerCount.java | 278 ++++++++++++++++++ .../ReloadPlayerCountListCommand.java | 24 ++ 5 files changed, 324 insertions(+) create mode 100644 Plugins/Mineplex.Bungee.PlayerCount/.classpath create mode 100644 Plugins/Mineplex.Bungee.PlayerCount/.settings/org.eclipse.jdt.core.prefs create mode 100644 Plugins/Mineplex.Bungee.PlayerCount/plugin.yml create mode 100644 Plugins/Mineplex.Bungee.PlayerCount/src/mineplex/bungee/PlayerCount/PlayerCount.java create mode 100644 Plugins/Mineplex.Bungee.PlayerCount/src/mineplex/bungee/PlayerCount/ReloadPlayerCountListCommand.java diff --git a/Plugins/Mineplex.Bungee.PlayerCount/.classpath b/Plugins/Mineplex.Bungee.PlayerCount/.classpath new file mode 100644 index 000000000..fbeb69b51 --- /dev/null +++ b/Plugins/Mineplex.Bungee.PlayerCount/.classpath @@ -0,0 +1,7 @@ + + + + + + + diff --git a/Plugins/Mineplex.Bungee.PlayerCount/.settings/org.eclipse.jdt.core.prefs b/Plugins/Mineplex.Bungee.PlayerCount/.settings/org.eclipse.jdt.core.prefs new file mode 100644 index 000000000..7341ab168 --- /dev/null +++ b/Plugins/Mineplex.Bungee.PlayerCount/.settings/org.eclipse.jdt.core.prefs @@ -0,0 +1,11 @@ +eclipse.preferences.version=1 +org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled +org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.7 +org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve +org.eclipse.jdt.core.compiler.compliance=1.7 +org.eclipse.jdt.core.compiler.debug.lineNumber=generate +org.eclipse.jdt.core.compiler.debug.localVariable=generate +org.eclipse.jdt.core.compiler.debug.sourceFile=generate +org.eclipse.jdt.core.compiler.problem.assertIdentifier=error +org.eclipse.jdt.core.compiler.problem.enumIdentifier=error +org.eclipse.jdt.core.compiler.source=1.7 diff --git a/Plugins/Mineplex.Bungee.PlayerCount/plugin.yml b/Plugins/Mineplex.Bungee.PlayerCount/plugin.yml new file mode 100644 index 000000000..18b6810c7 --- /dev/null +++ b/Plugins/Mineplex.Bungee.PlayerCount/plugin.yml @@ -0,0 +1,4 @@ +name: PlayerCount +main: mineplex.bungee.PlayerCount.PlayerCount +version: 1 +author: defek7 diff --git a/Plugins/Mineplex.Bungee.PlayerCount/src/mineplex/bungee/PlayerCount/PlayerCount.java b/Plugins/Mineplex.Bungee.PlayerCount/src/mineplex/bungee/PlayerCount/PlayerCount.java new file mode 100644 index 000000000..b46b7ae6a --- /dev/null +++ b/Plugins/Mineplex.Bungee.PlayerCount/src/mineplex/bungee/PlayerCount/PlayerCount.java @@ -0,0 +1,278 @@ +package mineplex.bungee.PlayerCount; + +import java.io.BufferedReader; +import java.io.DataInput; +import java.io.DataInputStream; +import java.io.DataOutput; +import java.io.DataOutputStream; +import java.io.File; +import java.io.FileInputStream; +import java.io.IOException; +import java.io.InputStreamReader; +import java.net.ConnectException; +import java.net.InetSocketAddress; +import java.net.Socket; +import java.net.SocketTimeoutException; +import java.util.HashMap; +import java.util.concurrent.TimeUnit; + +import net.md_5.bungee.api.config.ListenerInfo; +import net.md_5.bungee.api.event.ProxyPingEvent; +import net.md_5.bungee.api.plugin.Listener; +import net.md_5.bungee.api.plugin.Plugin; +import net.md_5.bungee.event.EventHandler; + +public class PlayerCount extends Plugin implements Listener, Runnable +{ + private HashMap _otherBungeeInstances; + private int _totalPlayers; + private int _totalMaxPlayers; + + private int _tempPlayers; + private int _tempMaxPlayers; + + @Override + public void onEnable() + { + _otherBungeeInstances = new HashMap(); + + LoadBungeeServers(); + + getProxy().getScheduler().schedule(this, this, 1L, 1L, TimeUnit.SECONDS); + getProxy().getPluginManager().registerListener(this, this); + + getProxy().getPluginManager().registerCommand(this, new ReloadPlayerCountListCommand(this)); + } + + public void run() + { + _tempPlayers = getProxy().getOnlineCount(); + _tempMaxPlayers = 0; + + for(ListenerInfo li : getProxy().getConfigurationAdapter().getListeners()) + { + _tempMaxPlayers += li.getMaxPlayers(); + } + + for (InetSocketAddress address : _otherBungeeInstances.values()) + { + try + { + UpdateServerCount(address); + } catch (IOException e) + { + e.printStackTrace(); + } + } + + _totalPlayers = _tempPlayers; + _totalMaxPlayers = _tempMaxPlayers; + } + + @EventHandler + public void ServerPing(ProxyPingEvent event) + { + if (!_otherBungeeInstances.containsKey(event.getConnection().getAddress().getAddress().getHostAddress())) + { + net.md_5.bungee.api.ServerPing serverPing = event.getResponse(); + event.setResponse(new net.md_5.bungee.api.ServerPing(serverPing.getProtocolVersion(), serverPing.getGameVersion(), serverPing.getMotd(), _totalPlayers, _totalMaxPlayers)); + } + } + + protected void UpdateServerCount(InetSocketAddress address) throws IOException + { + Socket socket = null; + DataInputStream dataInputStream = null; + DataOutputStream dataOutputStream = null; + + try + { + socket = new Socket(); + socket.setSoTimeout(3000); + socket.setTcpNoDelay(true); + socket.setTrafficClass(18); + socket.connect(address, 3000); + dataInputStream = new DataInputStream(socket.getInputStream()); + dataOutputStream = new DataOutputStream(socket.getOutputStream()); + + dataOutputStream.writeByte(254); + dataOutputStream.writeByte(1); + dataOutputStream.writeByte(254); + writeString("MC|PingHost", dataOutputStream); + dataOutputStream.writeShort(3 + 2 * address.getAddress().getHostName().length() + 4); + dataOutputStream.writeByte(73); + writeString(address.getAddress().getHostName(), dataOutputStream); + dataOutputStream.writeInt(address.getPort()); + + if (dataInputStream.read() != 255) + { + System.out.println("not 255"); + return; + } + + String var6 = readString(dataInputStream, 256); + + String[] var27; + + if (var6.startsWith("\u00a7") && var6.length() > 1) + { + var27 = var6.substring(1).split("\u0000"); + + _tempPlayers += Integer.parseInt(var27[4]); + _tempMaxPlayers += Integer.parseInt(var27[5]); + } + } + catch (SocketTimeoutException e) + { + ; + } + catch (ConnectException e) + { + ; + } + catch (IOException e) + { + System.out.println("[BungeeSigns] Error pinging " + address.getHostString() + ":" + address.getPort()); + throw e; + } + finally + { + try + { + if (dataInputStream != null) + { + dataInputStream.close(); + } + } + catch (Exception exception) + { + ; + } + + try + { + if (dataOutputStream != null) + { + dataOutputStream.close(); + } + } + catch (Exception exception) + { + ; + } + + try + { + if (socket != null) + { + socket.close(); + } + } + catch (Exception exception) + { + ; + } + } + } + + public static void writeString(String par0Str, DataOutput par1DataOutput) throws IOException + { + if (par0Str.length() > 32767) + { + throw new IOException("String too big"); + } + else + { + par1DataOutput.writeShort(par0Str.length()); + par1DataOutput.writeChars(par0Str); + } + } + + public static String readString(DataInput par0DataInput, int par1) throws IOException + { + short var2 = par0DataInput.readShort(); + + if (var2 > par1) + { + throw new IOException("Received string length longer than maximum allowed (" + var2 + " > " + par1 + ")"); + } + else if (var2 < 0) + { + throw new IOException("Received string length is less than zero! Weird string!"); + } + else + { + StringBuilder var3 = new StringBuilder(); + + for (int var4 = 0; var4 < var2; ++var4) + { + var3.append(par0DataInput.readChar()); + } + + return var3.toString(); + } + } + + public void LoadBungeeServers() + { + FileInputStream fstream = null; + BufferedReader br = null; + + try + { + File npcFile = new File("bungeeServers.dat"); + + if (npcFile.exists()) + { + fstream = new FileInputStream(npcFile); + br = new BufferedReader(new InputStreamReader(fstream)); + + String line = br.readLine(); + + while (line != null) + { + String address = line.split(":")[0]; + Integer port = Integer.parseInt(line.split(":")[1]); + InetSocketAddress socketAddress = new InetSocketAddress(address, port); + _otherBungeeInstances.put(socketAddress.getAddress().getHostAddress(), socketAddress); + + line = br.readLine(); + } + } + else + { + npcFile.createNewFile(); + } + } + catch (Exception e) + { + System.out.println("Error parsing bungeeServers file."); + } + finally + { + if (br != null) + { + try + { + br.close(); + } + catch (IOException e) + { + e.printStackTrace(); + } + } + + if (fstream != null) + { + try + { + fstream.close(); + } + catch (IOException e) + { + e.printStackTrace(); + } + } + } + } +} diff --git a/Plugins/Mineplex.Bungee.PlayerCount/src/mineplex/bungee/PlayerCount/ReloadPlayerCountListCommand.java b/Plugins/Mineplex.Bungee.PlayerCount/src/mineplex/bungee/PlayerCount/ReloadPlayerCountListCommand.java new file mode 100644 index 000000000..84e377e03 --- /dev/null +++ b/Plugins/Mineplex.Bungee.PlayerCount/src/mineplex/bungee/PlayerCount/ReloadPlayerCountListCommand.java @@ -0,0 +1,24 @@ +package mineplex.bungee.PlayerCount; + +import net.md_5.bungee.api.ChatColor; +import net.md_5.bungee.api.CommandSender; +import net.md_5.bungee.api.plugin.Command; + +public class ReloadPlayerCountListCommand extends Command +{ + private PlayerCount _plugin; + + public ReloadPlayerCountListCommand(PlayerCount plugin) + { + super( "reloadplayercount", "bungeecord.command.reloadserverlist" ); + + _plugin = plugin; + } + + @Override + public void execute(CommandSender sender, String[] arg1) + { + _plugin.LoadBungeeServers(); + sender.sendMessage(ChatColor.BLUE + "PlayerCount>" + ChatColor.GRAY + " Reloaded player count server list."); + } +}