formate code + remove todos

Author: ThaminduR

src/main/java/ClientHandler/Client.java

@@ -3,9 +3,9 @@
 import Constants.ChatServerConstants.ServerConstants;
 import Constants.ChatServerConstants.ServerExceptionConstants;
 import Exception.ServerException;
-import Utilities.Messaging;
 import Server.Server;
 import Server.ServerState;
+import Utilities.Messaging;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.json.simple.JSONObject;

src/main/java/Consensus/Consensus.java

@@ -1,9 +1,9 @@
 package Consensus;
 
 import Constants.ChatServerConstants.ServerConstants;
-import Utilities.Messaging;
 import Server.Server;
 import Server.ServerState;
+import Utilities.Messaging;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.json.simple.JSONObject;

src/main/java/Consensus/LeaderElection.java

@@ -8,10 +8,6 @@ public ServerException(String message, String code) {
         this.code = code;
     }
 
-    public ServerException(String message, Throwable throwable) {
-        super(message, throwable);
-    }
-
     public String getCode() {
         return code;
     }

src/main/java/Exception/ServerException.java

@@ -37,7 +37,6 @@ public void run() {
                 ServerState.getServerState().setSmallPartitionFormed(true);
                 ServerState.getServerState().purgeServerState();
             } else {
-                // TODO: Larger partition needs to remove identities.
                 // Start election()
                 ConcurrentLinkedQueue<String> failedServersId = ServerState.getServerState().getFailedServers();
                 if (failedServersId.size() != 0) {

src/main/java/Gossiping/FailureDetector.java

@@ -1,9 +1,9 @@
 package Gossiping;
 
 import Constants.ChatServerConstants.ServerConstants;
-import Utilities.Messaging;
 import Server.Server;
 import Server.ServerState;
+import Utilities.Messaging;
 import Utilities.Util;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;

src/main/java/Gossiping/Gossiping.java

@@ -1,9 +1,9 @@
 package Gossiping;
 
 import Constants.ChatServerConstants.ServerConstants;
-import Utilities.Messaging;
 import Server.Server;
 import Server.ServerState;
+import Utilities.Messaging;
 import org.json.simple.JSONObject;
 
 import java.util.Collection;

src/main/java/Gossiping/HeartBeatSender.java

@@ -19,9 +19,7 @@ public class ServerState {
     private final ConcurrentHashMap<Long, ClientHandler> clientHandlerHashMap = new ConcurrentHashMap<>();
     private final ConcurrentHashMap<String, Room> roomsHashMap = new ConcurrentHashMap<>();
     private final ConcurrentHashMap<String, Server> serversHashmap = new ConcurrentHashMap<>(); // has all the Servers; dead and alive; except this
-    // TODO: Change identityList into a HashMap to keep the serverIds.
-    // unique client identifies
-    private final ConcurrentHashMap<String, String> identityHashMap = new ConcurrentHashMap<>();
+    private final ConcurrentHashMap<String, String> identityHashMap = new ConcurrentHashMap<>(); // unique client identifies
     private final ConcurrentHashMap<String, Long> heartBeatMap = new ConcurrentHashMap<>(); //store heartbeats of servers
     private final ConcurrentLinkedQueue<String> failedServers = new ConcurrentLinkedQueue<>(); // store failed servers
     private boolean smallPartitionFormed = false;
@@ -90,7 +88,7 @@ public Server getServerFromId(String serverId) {
             }
         }
         if (serverId.equals(this.serverId)) {
-            return new Server(this.serverId, this.serverAddress, this.coordinationPort, this.clientsPort); //todo check coordination port or clients port
+            return new Server(this.serverId, this.serverAddress, this.coordinationPort, this.clientsPort);
         }
         return null;
     }
@@ -250,7 +248,6 @@ public boolean amITheLeader() {
     public HashMap<String, String> getCurrentServerState() throws IOException {
         HashMap<String, String> serverState = new HashMap<>();
 
-        // TODO: change the code to reflect the datatype change in identityList.
         // Serialize identity list.
         serverState.put("IdentityMap", serialize(identityHashMap));
 
@@ -364,9 +361,6 @@ private void removeRoomsExceptMainHall() {
      */
     private void disconnectClients() throws IOException {
 
-        //TODO:
-        //Closing the socket here might throw an SocketException in either ClientHandler or main.
-        //Need to handle that scenario after testing.
         for (ClientHandler clientHandler : clientHandlerHashMap.values()) {
             clientHandler.forceQuitClient();
         }
@@ -424,7 +418,7 @@ public void removeIdentity(String identity) {
     public Collection<String> getIdentityByServer(String sId) {
         Collection<String> identities = new ArrayList<>();
         for (Map.Entry<String, String> entry : identityHashMap.entrySet()) {
-            if(sId.equals(entry.getValue())){
+            if (sId.equals(entry.getValue())) {
                 identities.add(entry.getKey());
             }
         }