Krakatoa-Earth
/
ProxySystem
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

reply to ack msg that we recevied the connection/closed information about the clients

master
Alex 2022-03-15 15:16:35 +01:00
parent c91a062be3
commit c7abef9630
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java
View File

@ -144,17 +144,11 @@ public class SocketClientMessageListener implements KraSocketClientEventInterfac
break; break;
} }
case 53874: { // test message - ack case 53874: { // test message - ack
KraSocketClientProtocolMessage kraSocketClientProtocolMessage = new KraSocketClientProtocolMessage( ProxySystem.getInstance().getKraSocketClientProtocol().replyThatWeReceivedAckMessage(
KraSocketClientProtocolStatus.REPLY.getStatus(), ProxySystem.getInstance().getKraSocketClient().getSocketClient(),
kraProtocolMessage.getCmdID(), KraSocketClientProtocolDest.BACKEND.getStatus(), ProxySystem.getInstance().getKraSocketClientProtocol(), kraProtocolMessage.getCmdID(),
kraProtocolMessage.getUuid(), KraSocketClientProtocolDest.BACKEND.getStatus(), kraProtocolMessage.getUuid(),
(short) 53874, "", null); kraProtocolMessage.getCmdNumber());
ProxySystem.getInstance().getKraSocketClient().getSocketClient()
.SendMessage(kraSocketClientProtocolMessage);
ProxySystem.getInstance().getKraSocketClientProtocol()
.removeMessageFromSendQueue(kraProtocolMessage.getCmdID());
System.out.println( System.out.println(
"cmdNumber 53874 answered back to uuid:" + kraProtocolMessage.getUuid() "cmdNumber 53874 answered back to uuid:" + kraProtocolMessage.getUuid()
@ -167,6 +161,14 @@ public class SocketClientMessageListener implements KraSocketClientEventInterfac
case 64247: // mobile connection closed case 64247: // mobile connection closed
case 22348: { // voice connection closed case 22348: { // voice connection closed
ProxyServer.getInstance().getScheduler().runAsync(ProxySystem.getInstance(), () -> { ProxyServer.getInstance().getScheduler().runAsync(ProxySystem.getInstance(), () -> {
// ack msg -> Reply to backend that we received the message
ProxySystem.getInstance().getKraSocketClientProtocol()
.replyThatWeReceivedAckMessage(
ProxySystem.getInstance().getKraSocketClient().getSocketClient(),
ProxySystem.getInstance()
.getKraSocketClientProtocol(), kraProtocolMessage.getCmdID(),
KraSocketClientProtocolDest.BACKEND.getStatus(), kraProtocolMessage.getUuid(),
kraProtocolMessage.getCmdNumber());
ProxiedPlayer proxiedPlayer = ProxySystem.getInstance().getProxy() ProxiedPlayer proxiedPlayer = ProxySystem.getInstance().getProxy()
.getPlayer(kraProtocolMessage.getUuid()); .getPlayer(kraProtocolMessage.getUuid());