Events in Echtzeit behandeln

Subscription sub = api.event().server().onStarted(event -> {
    System.out.println("Server gestartet: " + event.getServerId());
});

// Schließen wenn fertig
sub.close();

public class MeinPlugin extends JavaPlugin {
    private CloudApi api;
    private final List<Subscription> subscriptions = new ArrayList<>();

    @Override
    public void onEnable() {
        api = CloudApi.create();
        registerEvents();
    }

    @Override
    public void onDisable() {
        subscriptions.forEach(Subscription::close);
        subscriptions.clear();
    }

    private void registerEvents() {
        subscriptions.add(api.event().server().onStarted(this::onServerStarted));
        subscriptions.add(api.event().server().onStopped(this::onServerStopped));
        subscriptions.add(api.event().group().onUpdated(this::onGroupUpdated));
    }

    private void onServerStarted(ServerStartedEvent event) {
        getLogger().info("Server gestartet: " + event.getServerId());
    }

    private void onServerStopped(ServerStoppedEvent event) {
        getLogger().info("Server gestoppt: " + event.getServerId());
    }

    private void onGroupUpdated(GroupUpdatedEvent event) {
        getLogger().info("Gruppe aktualisiert: " + event.getServerGroupId());
    }
}

public void setupAutoStart(String groupName, int minimum) {
    api.event().server().onStopped(event -> {
        Server stopped = event.getServer();
        if (!stopped.isFromGroup() || !groupName.equals(stopped.getGroup().getName())) {
            return;
        }

        api.server().getServersByGroup(groupName).thenAccept(servers -> {
            long running = servers.stream()
                .filter(server -> server.getState() != ServerState.STOPPING)
                .filter(server -> server.getState() != ServerState.CLEANUP)
                .count();

            if (running < minimum) {
                api.group().getGroupByName(groupName).thenCompose(group -> {
                    if (group == null) {
                        return CompletableFuture.failedFuture(
                            new IllegalArgumentException("Gruppe nicht gefunden: " + groupName));
                    }
                    return api.group().requestServerStart(group);
                });
            }
        });
    });
}

public void setupStateLogging() {
    api.event().server().onStateChanged(event -> {
        String message = String.format("[%s] %s -> %s",
            event.getServerId(),
            event.getOldState(),
            event.getNewState());

        logger.info(message);
    });
}

public void setupCrashNotifications() {
    api.event().server().onStopped(event -> {
        if (!event.getCrashed()) return;

        notifyStaff(Component.text("[Alert] Server abgestürzt: " + event.getServerId())
            .color(NamedTextColor.RED));
    });
}

public void watchGroup(String groupName) {
    api.event().server().onStarted(event -> {
        Server server = event.getServer();
        if (server.isFromGroup() && groupName.equals(server.getGroup().getName())) {
            handleGroupServerStart(event);
        }
    });
}

public CompletableFuture<Void> waitForServer(String serverId) {
    CompletableFuture<Void> future = new CompletableFuture<>();

    Subscription sub = api.event().server().onStateChanged(event -> {
        if (event.getServerId().equals(serverId) &&
            event.getNewState() == ServerState.AVAILABLE) {
            future.complete(null);
        }
    });

    future.whenComplete((result, error) -> sub.close());

    return future;
}