Upstream/ViaVersion
1
0
Fork 0
mirror of https://github.com/ViaVersion/ViaVersion.git synced 2025-02-23 07:01:24 +01:00
Code Issues Projects Releases Wiki Activity

Allow servers to manually be probed with API

Browse Source
This commit is contained in:
Myles 2016-11-14 12:38:39 +00:00
parent f4eeb94a2e
commit 1209beb47d
2 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
bungee/src/main/java/us/myles/ViaVersion/bungee/platform/BungeeViaAPI.java
View File

@ -2,6 +2,7 @@ package us.myles.ViaVersion.bungee.platform;
import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBuf;
import lombok.NonNull; import lombok.NonNull;
import net.md_5.bungee.api.config.ServerInfo;
import net.md_5.bungee.api.connection.ProxiedPlayer; import net.md_5.bungee.api.connection.ProxiedPlayer;
import us.myles.ViaVersion.api.Via; import us.myles.ViaVersion.api.Via;
import us.myles.ViaVersion.api.ViaAPI; import us.myles.ViaVersion.api.ViaAPI;
@ -10,6 +11,7 @@ import us.myles.ViaVersion.api.boss.BossColor;
import us.myles.ViaVersion.api.boss.BossStyle; import us.myles.ViaVersion.api.boss.BossStyle;
import us.myles.ViaVersion.api.data.UserConnection; import us.myles.ViaVersion.api.data.UserConnection;
import us.myles.ViaVersion.api.protocol.ProtocolRegistry; import us.myles.ViaVersion.api.protocol.ProtocolRegistry;
import us.myles.ViaVersion.bungee.service.ProtocolDetectorService;
import us.myles.ViaVersion.protocols.base.ProtocolInfo; import us.myles.ViaVersion.protocols.base.ProtocolInfo;
import java.util.Map; import java.util.Map;
@ -75,4 +77,13 @@ public class BungeeViaAPI implements ViaAPI<ProxiedPlayer> {
public Map<UUID, UserConnection> getPortedPlayers() { public Map<UUID, UserConnection> getPortedPlayers() {
return Via.getManager().getPortedPlayers(); return Via.getManager().getPortedPlayers();
} }
/**
* Forces ViaVersion to probe a server
*
* @param serverInfo The serverinfo to probe
*/
public void probeServer(ServerInfo serverInfo) {
ProtocolDetectorService.probeServer(serverInfo);
}
} }

7
bungee/src/main/java/us/myles/ViaVersion/bungee/service/ProtocolDetectorService.java
View File

@ -45,12 +45,13 @@ public class ProtocolDetectorService implements Runnable {
@Override @Override
public void run() { public void run() {
for (final Map.Entry<String, ServerInfo> lists : plugin.getProxy().getServers().entrySet()) { for (final Map.Entry<String, ServerInfo> lists : plugin.getProxy().getServers().entrySet()) {
updateProtocolInfo(lists.getKey(), lists.getValue()); probeServer(lists.getValue());
} }
} }
private void updateProtocolInfo(final String key, ServerInfo value) { public static void probeServer(final ServerInfo serverInfo) {
value.ping(new Callback<ServerPing>() { final String key = serverInfo.getName();
serverInfo.ping(new Callback<ServerPing>() {
@Override @Override
public void done(ServerPing serverPing, Throwable throwable) { public void done(ServerPing serverPing, Throwable throwable) {
if (throwable == null) { if (throwable == null) {