PandacubeFr/BungeeCord
1
0
Fork 0
Code Releases Activity

Add player list and player count channels.

Browse Source
This commit is contained in:
md_5 2013-01-27 09:51:45 +11:00
parent 4c07fbf953
commit 8f090b6692
1 changed files with 69 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

99
proxy/src/main/java/net/md_5/bungee/UserConnection.java
View File

@ -382,47 +382,86 @@ public class UserConnection extends GenericConnection implements ProxiedPlayer
if (message.tag.equals("BungeeCord")) if (message.tag.equals("BungeeCord"))
{ {
switch (in.readUTF()) String subChannel = in.readUTF();
if (subChannel.equals("Disconnect"))
{ {
case "Disconnect": break;
break outer; }
case "Forward": if (subChannel.equals("Forward"))
String target = in.readUTF(); {
String channel = in.readUTF(); String target = in.readUTF();
short len = in.readShort(); String channel = in.readUTF();
byte[] data = new byte[len]; short len = in.readShort();
in.readFully(data); byte[] data = new byte[len];
in.readFully(data);
if (target.equals("ALL")) if (target.equals("ALL"))
{
for (String s : BungeeCord.getInstance().getServers().keySet())
{ {
for (String s : BungeeCord.getInstance().getServers().keySet()) Server server = BungeeCord.getInstance().getServer(s);
{
Server server = BungeeCord.getInstance().getServer(s);
server.sendData(channel, data);
}
} else
{
Server server = BungeeCord.getInstance().getServer(target);
server.sendData(channel, data); server.sendData(channel, data);
} }
} else
break; {
case "Connect": Server server = BungeeCord.getInstance().getServer(target);
ServerInfo server = BungeeCord.getInstance().config.getServers().get(in.readUTF());
if (server != null) if (server != null)
{ {
connect(server); server.sendData(channel, data);
break outer;
} }
break; }
case "IP": }
if (subChannel.equals("Connect"))
{
ServerInfo server = BungeeCord.getInstance().config.getServers().get(in.readUTF());
if (server != null)
{
connect(server);
break outer;
}
}
if (subChannel.equals("IP"))
{
ByteArrayOutputStream b = new ByteArrayOutputStream();
DataOutputStream out = new DataOutputStream(b);
out.writeUTF("IP");
out.writeUTF(getAddress().getHostString());
out.writeInt(getAddress().getPort());
getServer().sendData("BungeeCord", b.toByteArray());
}
if (subChannel.equals("PlayerCount"))
{
ServerInfo server = BungeeCord.getInstance().config.getServers().get(in.readUTF());
if (server != null)
{
ByteArrayOutputStream b = new ByteArrayOutputStream(); ByteArrayOutputStream b = new ByteArrayOutputStream();
DataOutputStream out = new DataOutputStream(b); DataOutputStream out = new DataOutputStream(b);
out.writeUTF("IP"); out.writeUTF("PlayerCount");
out.writeUTF(getAddress().getHostString()); out.writeUTF(server.getName());
out.writeInt(getAddress().getPort()); out.writeInt(server.getPlayers().size());
getServer().sendData("BungeeCord", b.toByteArray()); getServer().sendData("BungeeCord", b.toByteArray());
break; }
}
if (subChannel.equals("PlayerList"))
{
ServerInfo server = BungeeCord.getInstance().config.getServers().get(in.readUTF());
if (server != null)
{
ByteArrayOutputStream b = new ByteArrayOutputStream();
DataOutputStream out = new DataOutputStream(b);
out.writeUTF("PlayerList");
out.writeUTF(server.getName());
StringBuilder sb = new StringBuilder();
for (ProxiedPlayer p : server.getPlayers())
{
sb.append(p.getName());
sb.append(",");
}
out.writeUTF(sb.substring(0, sb.length() - 1));
getServer().sendData("BungeeCord", b.toByteArray());
}
} }
continue; continue;
} }