diff --git a/src/main/java/net/krakatoa/proxy/command/SendTestMessageCommand.java b/src/main/java/net/krakatoa/proxy/command/SendTestMessageCommand.java index 03d5898..b533712 100644 --- a/src/main/java/net/krakatoa/proxy/command/SendTestMessageCommand.java +++ b/src/main/java/net/krakatoa/proxy/command/SendTestMessageCommand.java @@ -2,6 +2,7 @@ package net.krakatoa.proxy.command; import earth.krakatao.protocol.KraSocketClientProtocolMessage; import earth.krakatao.protocol.KraSocketClientProtocolStatus; +import java.util.function.Consumer; import net.krakatoa.proxy.ProxySystem; import net.md_5.bungee.api.CommandSender; import net.md_5.bungee.api.chat.TextComponent; @@ -32,9 +33,24 @@ public class SendTestMessageCommand extends Command { cmdID = Byte.parseByte(args[1]); } + Consumer 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( 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() .SendMessage(kraSocketClientProtocolMessage);