diff --git a/src/main/java/earth/krakatao/Formatter.java b/src/main/java/earth/krakatao/Formatter.java index a6bb87d..c44e197 100644 --- a/src/main/java/earth/krakatao/Formatter.java +++ b/src/main/java/earth/krakatao/Formatter.java @@ -4,12 +4,7 @@ import java.math.BigInteger; import java.util.UUID; public class Formatter { - - /* - public static String formatUuid(String uuid) { - return uuid.replaceAll("-", ""); - } */ - + public static String formatUuid(UUID uuid) { return uuid.toString().replaceAll("-", ""); } diff --git a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java index 7600648..30ac267 100644 --- a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java +++ b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java @@ -4,23 +4,14 @@ import earth.krakatao.Formatter; import earth.krakatao.KraSocketClient; import earth.krakatao.SocketClient; import java.nio.charset.StandardCharsets; -import java.text.Format; -import java.text.Normalizer.Form; -import java.util.ArrayList; import java.util.HashMap; -import java.util.Iterator; import java.util.UUID; -import java.util.function.Consumer; import lombok.Getter; public class KraSocketClientProtocol { - //@Getter - //private final ArrayList cmdIDs; @Getter private int currentCmdIDIndex; - //@Getter - //private final HashMap> consumerHashMap; @Getter private final HashMap sendQueueMessages; @@ -28,9 +19,7 @@ public class KraSocketClientProtocol { private final HashMap receivedQueueMessages; public KraSocketClientProtocol() { - //this.cmdIDs = new ArrayList<>(); this.currentCmdIDIndex = 9; - //this.consumerHashMap = new HashMap<>(); this.sendQueueMessages = new HashMap<>(); this.receivedQueueMessages = new HashMap<>(); } @@ -91,8 +80,6 @@ public class KraSocketClientProtocol { } } - //this.cmdIDs.add(cmdID); - return raw; } @@ -142,26 +129,15 @@ public class KraSocketClientProtocol { public void removeMessageFromSendQueue(int cmdID) { this.sendQueueMessages.remove(cmdID); - /* - Iterator iterator = this.cmdIDs.iterator(); - - KraSocketClient.getLogger().info("before: " + this.cmdIDs); - - while (iterator.hasNext()) { - if (iterator.next() == cmdID) { - iterator.remove(); - } - } - KraSocketClient.getLogger().info("after: " + this.cmdIDs); - - this.consumerHashMap.remove(cmdID); */ } public void removeMessageFromReceivedQueue(int cmdID) { this.receivedQueueMessages.remove(cmdID); } - // This method is used to send a reply message to the backend that we have received the ack message. + /* + * This method is used to send a reply message to the backend that we have received the ack message. + */ public void replyThatWeReceivedAckMessage(SocketClient socketClient, KraSocketClientProtocol kraSocketClientProtocol, int cmdID, byte dest, UUID uuid, int cmdNumber) {