EpicKnarvik97/Stargate
EpicKnarvik97/Stargate
2
0
Fork 0
Code Issues 7 Pull Requests Projects 1 Releases 27 Wiki Activity

Cleans, comments and renames BungeeCordListener

Browse Source
This commit is contained in:
Kristian Knarvik 2021-02-08 00:32:58 +01:00
parent 9233776b2c
commit 6e1a69881c
2 changed files with 80 additions and 58 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
src/main/java/net/knarcraft/stargate/BungeeCoordListener.java
View File

@ -1,58 +0,0 @@
package net.knarcraft.stargate;
import org.bukkit.entity.Player;
import org.bukkit.plugin.messaging.PluginMessageListener;
import java.io.ByteArrayInputStream;
import java.io.DataInputStream;
import java.io.IOException;
public class BungeeCoordListener implements PluginMessageListener {
@Override
public void onPluginMessageReceived(String channel, Player unused, byte[] message) {
if (!Stargate.enableBungee || !channel.equals("BungeeCord")) return;
// Get data from message
String inChannel;
byte[] data;
try {
DataInputStream in = new DataInputStream(new ByteArrayInputStream(message));
inChannel = in.readUTF();
short len = in.readShort();
data = new byte[len];
in.readFully(data);
} catch (IOException ex) {
Stargate.log.severe("[stargate] Error receiving BungeeCord message");
ex.printStackTrace();
return;
}
// Verify that it's an SGBungee packet
if (!inChannel.equals("SGBungee")) {
return;
}
// Data should be player name, and destination gate name
String msg = new String(data);
String[] parts = msg.split("#@#");
String playerName = parts[0];
String destination = parts[1];
// Check if the player is online, if so, teleport, otherwise, queue
Player player = Stargate.server.getPlayer(playerName);
if (player == null) {
Stargate.bungeeQueue.put(playerName.toLowerCase(), destination);
} else {
Portal dest = Portal.getBungeeGate(destination);
// Specified an invalid gate. For now we'll just let them connect at their current location
if (dest == null) {
Stargate.log.info("[stargate] Bungee gate " + destination + " does not exist");
return;
}
dest.teleport(player, dest, null);
}
}
}

80
src/main/java/net/knarcraft/stargate/BungeeCordListener.java Normal file
View File

@ -0,0 +1,80 @@
package net.knarcraft.stargate;
import org.bukkit.entity.Player;
import org.bukkit.plugin.messaging.PluginMessageListener;
import java.io.ByteArrayInputStream;
import java.io.DataInputStream;
import java.io.IOException;
/**
* This listener teleports a user if a valid message is received from BungeeCord
*
* <p>Specifically, if a string starts with SGBungee encoded to be readable by readUTF followed by
* PlayerName#@#DestinationPortal is received on the BungeeCord channel, this listener will teleport the player to the
* destination portal.</p>
*/
public class BungeeCordListener implements PluginMessageListener {
@Override
public void onPluginMessageReceived(String channel, Player unused, byte[] message) {
if (!Stargate.enableBungee || !channel.equals("BungeeCord")) {
return;
}
String receivedMessage = readPluginMessage(message);
if (receivedMessage == null) {
return;
}
String[] messageParts = receivedMessage.split("#@#");
String playerName = messageParts[0];
String destination = messageParts[1];
// Check if the player is online, if so, teleport, otherwise, queue
Player player = Stargate.server.getPlayer(playerName);
if (player == null) {
Stargate.bungeeQueue.put(playerName.toLowerCase(), destination);
} else {
Portal destinationPortal = Portal.getBungeeGate(destination);
// Specified an invalid gate. For now we'll just let them connect at their current location
if (destinationPortal == null) {
Stargate.log.info("[stargate] Bungee gate " + destination + " does not exist");
return;
}
destinationPortal.teleport(player, destinationPortal, null);
}
}
/**
* Reads a plugin message byte array to a string
* @param message <p>The byte array to read</p>
* @return <p>The message contained in the byte array</p>
*/
private String readPluginMessage(byte[] message) {
// Get data from message
String inChannel;
byte[] data;
try {
DataInputStream dataInputStream = new DataInputStream(new ByteArrayInputStream(message));
inChannel = dataInputStream.readUTF();
short dataLength = dataInputStream.readShort();
data = new byte[dataLength];
dataInputStream.readFully(data);
} catch (IOException ex) {
Stargate.log.severe("[stargate] Error receiving BungeeCord message");
ex.printStackTrace();
return null;
}
// Verify that it's an SGBungee packet
if (!inChannel.equals("SGBungee")) {
return null;
}
// Data should be player name, and destination gate name
return new String(data);
}
}