Skip to content

Commit

Permalink
Remove some unnecessary conversions
Browse files Browse the repository at this point in the history
  • Loading branch information
ME1312 committed Jun 14, 2021
1 parent 2c7175e commit 517074f
Show file tree
Hide file tree
Showing 8 changed files with 76 additions and 35 deletions.
Expand Up @@ -26,6 +26,15 @@ static BungeeAPI getInstance() {
return ((BungeeCommon) ProxyServer.getInstance()).api.run();
}

/**
* Gets the BungeeCommon Internals
*
* @deprecated Use BungeeAPI Methods when available
* @return BungeeCommon Internals
*/
@Deprecated
BungeeCommon getInternals();

/**
* Get the number of players on this network across all known proxies
*
Expand Down
Expand Up @@ -12,12 +12,10 @@
* BungeeCord Common Layout Class
*/
public abstract class BungeeCommon extends BungeeCord {
private static BungeeCommon instance;
final ReturnRunnable<BungeeAPI> api;

protected BungeeCommon(ReturnRunnable<BungeeAPI> api) throws IOException {
this.api = api;
instance = this;
}

/**
Expand All @@ -33,13 +31,4 @@ protected BungeeCommon(ReturnRunnable<BungeeAPI> api) throws IOException {
* @return Server Map Copy
*/
public abstract Map<String, ServerInfo> getServersCopy();

/**
* Gets the ProxyServer Common Object
*
* @return ProxyServer Common
*/
public static BungeeCommon getInstance() {
return instance;
}
}
Expand Up @@ -75,6 +75,16 @@ default void sendMessage(String... messages) {
sendMessage(messages, i -> {});
}

/**
* Sends messages to this player
*
* @param message Message to send
* @param response Success Status
*/
default void sendMessage(String message, Callback<Integer> response) {
sendMessage(new String[]{ message }, response);
}

/**
* Sends messages to this player
*
Expand All @@ -92,6 +102,16 @@ default void sendMessage(BaseComponent... messages) {
sendMessage(messages, i -> {});
}

/**
* Sends messages to this player
*
* @param message Message to send
* @param response Success Status
*/
default void sendMessage(BaseComponent message, Callback<Integer> response) {
sendMessage(new BaseComponent[]{ message }, response);
}

/**
* Sends messages to this player
*
Expand Down Expand Up @@ -153,17 +173,17 @@ default void disconnect(Callback<Integer> response) {
/**
* Disconnects this player from the network
*
* @param message Disconnect Message
* @param reason Disconnect Reason
*/
default void disconnect(String message) {
disconnect(message, i -> {});
default void disconnect(String reason) {
disconnect(reason, i -> {});
}

/**
* Disconnects this player from the network
*
* @param message Disconnect Message
* @param reason Disconnect Reason
* @param response Success status
*/
void disconnect(String message, Callback<Integer> response);
void disconnect(String reason, Callback<Integer> response);
}
Expand Up @@ -17,6 +17,8 @@

import java.lang.reflect.InvocationTargetException;
import java.net.InetSocketAddress;
import java.util.Arrays;
import java.util.Collections;
import java.util.UUID;

/**
Expand Down Expand Up @@ -140,7 +142,7 @@ public void sendMessage(String[] messages, Callback<Integer> response) {
SubDataClient client = getProxyConnection();
if (client != null) {
StackTraceElement[] origin = new Exception().getStackTrace();
client.sendPacket(new PacketExMessagePlayer(getUniqueId(), messages, null, data -> {
client.sendPacket(new PacketExMessagePlayer(getUniqueId(), Arrays.asList(messages), null, data -> {
try {
response.run(data.getInt(0x0001));
} catch (Throwable e) {
Expand All @@ -162,7 +164,7 @@ public void sendMessage(BaseComponent[] messages, Callback<Integer> response) {
SubDataClient client = getProxyConnection();
if (client != null) {
StackTraceElement[] origin = new Exception().getStackTrace();
client.sendPacket(new PacketExMessagePlayer(getUniqueId(), null, new String[]{ ComponentSerializer.toString(messages) }, data -> {
client.sendPacket(new PacketExMessagePlayer(getUniqueId(), null, Collections.singletonList(ComponentSerializer.toString(messages)), data -> {
try {
response.run(data.getInt(0x0001));
} catch (Throwable e) {
Expand Down Expand Up @@ -223,17 +225,17 @@ public void transfer(ServerInfo server, Callback<Integer> response) {
}

@Override
public void disconnect(String message, Callback<Integer> response) {
public void disconnect(String reason, Callback<Integer> response) {
if (local != null) {
if (message != null) {
local.disconnect(message);
if (reason != null) {
local.disconnect(reason);
} else local.disconnect();
response.run(0);
} else {
SubDataClient client = getProxyConnection();
if (client != null) {
StackTraceElement[] origin = new Exception().getStackTrace();
client.sendPacket(new PacketExDisconnectPlayer(getUniqueId(), message, data -> {
client.sendPacket(new PacketExDisconnectPlayer(getUniqueId(), reason, data -> {
try {
response.run(data.getInt(0x0001));
} catch (Throwable e) {
Expand Down
Expand Up @@ -8,6 +8,7 @@
import net.ME1312.SubData.Server.SubDataClient;

import java.util.HashMap;
import java.util.List;
import java.util.UUID;

/**
Expand All @@ -16,7 +17,7 @@
public class PacketExMessagePlayer implements PacketObjectIn<Integer>, PacketObjectOut<Integer> {
private static HashMap<UUID, Callback<ObjectMap<Integer>>[]> callbacks = new HashMap<UUID, Callback<ObjectMap<Integer>>[]>();
private UUID player;
private String[] legacy, raw;
private List<String> legacy, raw;
private UUID id;

/**
Expand All @@ -33,7 +34,7 @@ public PacketExMessagePlayer() {}
* @param callback Callbacks
*/
@SafeVarargs
public PacketExMessagePlayer(UUID player, String[] legacy, String[] raw, Callback<ObjectMap<Integer>>... callback) {
public PacketExMessagePlayer(UUID player, List<String> legacy, List<String> raw, Callback<ObjectMap<Integer>>... callback) {
if (Util.isNull(player, callback)) throw new NullPointerException();
this.player = player;
this.legacy = legacy;
Expand Down
Expand Up @@ -75,7 +75,7 @@ public void receive(SubDataClient client, ObjectMap<Integer> data) {
client.sendPacket(new PacketMessagePlayer(0, tracker));
} else if ((remote = plugin.api.getRemotePlayer(id)) != null) {
if (remote.getProxy().getSubData()[0] != null) {
((SubDataClient) remote.getProxy().getSubData()[0]).sendPacket(new PacketExMessagePlayer(remote.getUniqueId(), (data.contains(0x0002)?data.getRawStringList(0x0002).toArray(new String[0]):null), (data.contains(0x0003)?data.getRawStringList(0x0003).toArray(new String[0]):null), r -> {
((SubDataClient) remote.getProxy().getSubData()[0]).sendPacket(new PacketExMessagePlayer(remote.getUniqueId(), (data.contains(0x0002)?data.getRawStringList(0x0002):null), (data.contains(0x0003)?data.getRawStringList(0x0003):null), r -> {
client.sendPacket(new PacketMessagePlayer(r.getInt(0x0001), tracker));
}));
} else {
Expand Down
Expand Up @@ -176,6 +176,16 @@ public void sendMessage(String... messages) {
sendMessage(messages, i -> {});
}

/**
* Sends messages to this player
*
* @param message Message to send
* @param response Success Status
*/
public void sendMessage(String message, Callback<Integer> response) {
sendMessage(new String[]{ message }, response);
}

/**
* Sends messages to this player
*
Expand Down Expand Up @@ -204,6 +214,16 @@ public void sendRawMessage(String... messages) {
sendRawMessage(messages, i -> {});
}

/**
* Sends JSON format messages to this player
*
* @param message Message to send
* @param response Success Status
*/
public void sendRawMessage(String message, Callback<Integer> response) {
sendRawMessage(new String[]{ message }, response);
}

/**
* Sends JSON format messages to this player
*
Expand Down Expand Up @@ -289,21 +309,21 @@ public void disconnect(Callback<Integer> response) {
/**
* Disconnects this player from the network
*
* @param message Disconnect Message
* @param reason Disconnect Reason
*/
public void disconnect(String message) {
disconnect(message, i -> {});
public void disconnect(String reason) {
disconnect(reason, i -> {});
}

/**
* Disconnects this player from the network
*
* @param message Disconnect Message
* @param reason Disconnect Reason
* @param response Success status
*/
public void disconnect(String message, Callback<Integer> response) {
public void disconnect(String reason, Callback<Integer> response) {
StackTraceElement[] origin = new Exception().getStackTrace();
client().sendPacket(new PacketDisconnectPlayer(getUniqueId(), message, data -> {
client().sendPacket(new PacketDisconnectPlayer(getUniqueId(), reason, data -> {
try {
response.run(data.getInt(0x0001));
} catch (Throwable e) {
Expand Down
Expand Up @@ -139,15 +139,15 @@ public void transfer(ServerInfo server, Callback<Integer> response) {
}

@Override
public void disconnect(String message, Callback<Integer> response) {
public void disconnect(String reason, Callback<Integer> response) {
ProxiedPlayer local = get();
if (local != null) {
if (message != null) {
local.disconnect(message);
if (reason != null) {
local.disconnect(reason);
} else local.disconnect();
response.run(0);
} else {
super.disconnect(message, response);
super.disconnect(reason, response);
}
}
}

0 comments on commit 517074f

Please sign in to comment.