Better handling desynced maps

Author: AlexProgrammerDE

src/main/java/net/pistonmaster/pistonqueue/bungee/PistonQueue.java

@@ -153,6 +153,19 @@ public void onEnable() {
         // Moves the queue when someone logs off the main server on an interval set in the config.yml
         getProxy().getScheduler().schedule(this, queueListener::moveQueue, Config.QUEUEMOVEDELAY, Config.QUEUEMOVEDELAY, TimeUnit.MILLISECONDS);
 
+        getProxy().getScheduler().schedule(this, () -> {
+            for (QueueType type : QueueType.values()) {
+                for (Entry<UUID, String> entry : new LinkedHashMap<>(type.getQueueMap()).entrySet()) {
+                    ProxiedPlayer player = getProxy().getPlayer(entry.getKey());
+
+                    if (player == null || !player.isConnected()) {
+                        getLogger().info("Removed bugged player from data!");
+                        type.getQueueMap().remove(entry.getKey());
+                    }
+                }
+            }
+        }, 0, 500, TimeUnit.MILLISECONDS);
+
         // Checks the status of all the servers
         getProxy().getScheduler().schedule(this, () -> {
             if (getProxy().getServers().containsKey(Config.MAINSERVER)) {
@@ -270,9 +283,7 @@ private void sendMessage(QueueType queue, boolean bool, ChatMessageType type) {
 
             for (Entry<UUID, String> entry : new LinkedHashMap<>(queue.getQueueMap()).entrySet()) {
                 ProxiedPlayer player = getProxy().getPlayer(entry.getKey());
-
                 if (player == null || !player.isConnected()) {
-                    queue.getQueueMap().remove(entry.getKey());
                     continue;
                 }
 
@@ -293,7 +304,6 @@ private void updateTab(QueueType queue, List<String> header, List<String> footer
         for (Entry<UUID, String> entry : new LinkedHashMap<>(queue.getQueueMap()).entrySet()) {
             ProxiedPlayer player = getProxy().getPlayer(entry.getKey());
             if (player == null || !player.isConnected()) {
-                queue.getQueueMap().remove(entry.getKey());
                 continue;
             }