added consumer to send test messages command to receive and send a reply message to the player

master
Alex 2022-02-28 20:40:26 +01:00
parent fcbc93ac77
commit 463a4806fc
1 changed files with 17 additions and 1 deletions

View File

@ -2,6 +2,7 @@ package net.krakatoa.proxy.command;
import earth.krakatao.protocol.KraSocketClientProtocolMessage; import earth.krakatao.protocol.KraSocketClientProtocolMessage;
import earth.krakatao.protocol.KraSocketClientProtocolStatus; import earth.krakatao.protocol.KraSocketClientProtocolStatus;
import java.util.function.Consumer;
import net.krakatoa.proxy.ProxySystem; import net.krakatoa.proxy.ProxySystem;
import net.md_5.bungee.api.CommandSender; import net.md_5.bungee.api.CommandSender;
import net.md_5.bungee.api.chat.TextComponent; import net.md_5.bungee.api.chat.TextComponent;
@ -32,9 +33,24 @@ public class SendTestMessageCommand extends Command {
cmdID = Byte.parseByte(args[1]); cmdID = Byte.parseByte(args[1]);
} }
Consumer<KraSocketClientProtocolMessage> consumer = null;
if (status == KraSocketClientProtocolStatus.GET.getStatus()) {
consumer = kraSocketClientProtocolMessage -> {
proxiedPlayer.sendMessage(new TextComponent(
"Received msg -> status:" + kraSocketClientProtocolMessage.getStatus()
+ " cmdID: "
+ kraSocketClientProtocolMessage.getCmdID() + " dest: "
+ kraSocketClientProtocolMessage.getDest() + " uuid: "
+ kraSocketClientProtocolMessage.getUuid() + " cmdNumber: "
+ kraSocketClientProtocolMessage.getCmdNumber() + " args: "
+ kraSocketClientProtocolMessage.getArgs()));
};
}
KraSocketClientProtocolMessage kraSocketClientProtocolMessage = new KraSocketClientProtocolMessage( KraSocketClientProtocolMessage kraSocketClientProtocolMessage = new KraSocketClientProtocolMessage(
status, (byte) cmdID, Integer.parseInt(args[2]), status, (byte) cmdID, Integer.parseInt(args[2]),
proxiedPlayer.getUniqueId().toString(), Short.parseShort(args[3]), args[4], null); proxiedPlayer.getUniqueId().toString(), Short.parseShort(args[3]), args[4],
consumer);
ProxySystem.getInstance().getKraSocketClient().getSocketClient() ProxySystem.getInstance().getKraSocketClient().getSocketClient()
.SendMessage(kraSocketClientProtocolMessage); .SendMessage(kraSocketClientProtocolMessage);