package eu.codexe.autostopqueueplugin; import com.velocitypowered.api.proxy.ProxyServer; import com.velocitypowered.api.proxy.Player; import org.slf4j.Logger; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.Map; import java.util.Queue; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; public final class QueueManager { private final ProxyServer server; private final Logger logger; private final PluginConfiguration configuration; private final ServerRegistry registry; private final Map> queues = new ConcurrentHashMap<>(); private final Map starting = new ConcurrentHashMap<>(); public QueueManager(ProxyServer server, Logger logger, PluginConfiguration configuration, ServerRegistry registry) { this.server = server; this.logger = logger; this.configuration = configuration; this.registry = registry; } public void enqueue(Player player, String serverName) { queues.computeIfAbsent(serverName, key -> new ArrayDeque<>()).add(new QueueEntry(player.getUniqueId(), player.getUsername(), serverName, System.currentTimeMillis())); logger.info("Queued player {} for {}", player.getUsername(), serverName); } public boolean isQueued(UUID playerId, String serverName) { Queue queue = queues.get(serverName); if (queue == null) { return false; } return queue.stream().anyMatch(entry -> entry.playerId().equals(playerId)); } public void setStarting(String serverName, boolean value) { starting.put(serverName, value); } public boolean isStarting(String serverName) { return starting.getOrDefault(serverName, false); } public String serverFor(Player player) { for (ServerDefinition definition : configuration.servers().values()) { if (definition.permission().isEmpty() || player.hasPermission(definition.permission())) { return definition.name(); } } return configuration.defaultServer(); } public void flushQueue(String serverName) { Queue queue = queues.get(serverName); if (queue == null) { return; } ServerDefinition definition = configuration.getServer(serverName); if (definition == null) { return; } server.getScheduler().buildTask(this, () -> { QueueEntry entry; while ((entry = queue.poll()) != null) { server.getPlayer(entry.playerId()).ifPresent(player -> { server.getServer(serverName).ifPresent(registered -> player.createConnectionRequest(registered).connect()); }); } }).schedule(); } public void clearPlayer(UUID playerId) { for (Queue queue : queues.values()) { queue.removeIf(entry -> entry.playerId().equals(playerId)); } } public ArrayList queueSnapshot(String serverName) { Queue queue = queues.get(serverName); return queue == null ? new ArrayList<>() : new ArrayList<>(queue); } }

AutoStopQueuePlugin