Spieler mit Autoscaling weiterleiten

package com.example;

import app.simplecloud.api.CloudApi;
import app.simplecloud.api.player.CloudPlayer;
import app.simplecloud.api.server.Server;
import app.simplecloud.api.server.ServerQuery;
import app.simplecloud.api.server.ServerState;

import java.util.Comparator;
import java.util.concurrent.CompletableFuture;

public final class GroupRouter {
    private final CloudApi api;

    public GroupRouter(CloudApi api) {
        this.api = api;
    }

    public CompletableFuture<RouteResult> routeToGroup(
        CloudPlayer player,
        String groupName
    ) {
        ServerQuery query = ServerQuery.create()
            .filterByServerGroupName(groupName)
            .filterByState(ServerState.AVAILABLE, ServerState.INGAME);

        return api.server().getAllServers(query).thenCompose(servers -> servers.stream()
            .filter(server -> server.getPlayerCount() != null)
            .filter(server -> server.getPlayerCount() < server.getMaxPlayers())
            .min(Comparator
                .comparingInt((Server server) -> server.getPlayerCount())
                .thenComparingInt(Server::getNumericalId))
            .<CompletableFuture<RouteResult>>map(server -> {
                String serverName = groupName + "-" + server.getNumericalId();
                return player.connect(serverName)
                    .thenApply(RouteResult.ConnectionAttempted::new);
            })
            .orElseGet(() -> CompletableFuture.completedFuture(
                new RouteResult.NoCapacity()
            )));
    }

    public sealed interface RouteResult {
        record NoCapacity() implements RouteResult {}

        record ConnectionAttempted(
            CloudPlayer.ConnectResult result
        ) implements RouteResult {}
    }
}