feat(admin): add game lifecycle controls

src/main/java/games/dmg/spigottyrant/GameLifecycleService.java

@@ -0,0 +1,137 @@
+package games.dmg.spigottyrant;
+
+import java.time.Duration;
+import java.time.Instant;
+import java.util.EnumMap;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Set;
+import java.util.UUID;
+
+public final class GameLifecycleService {
+    public LifecycleState start(
+        PersistentState state,
+        UUID tyrantId,
+        Optional<UUID> vigilanteId,
+        Instant now
+    ) {
+        if (state.game().lifecycle() != GameLifecycle.UNSTARTED) {
+            throw new IllegalStateException("game has already been started");
+        }
+        if (vigilanteId.filter(tyrantId::equals).isPresent()) {
+            throw new IllegalArgumentException("Tyrant and Vigilante must be different players");
+        }
+        GameState game = new GameState(
+            GameLifecycle.RUNNING,
+            Optional.of(tyrantId),
+            vigilanteId,
+            Optional.empty(),
+            Optional.empty(),
+            Optional.empty(),
+            Duration.ZERO,
+            0,
+            1,
+            Set.of()
+        );
+        return new LifecycleState(game, state.players());
+    }
+
+    public LifecycleState pause(PersistentState state, Instant now) {
+        if (state.game().lifecycle() != GameLifecycle.RUNNING) {
+            throw new IllegalStateException("only a running game can be paused");
+        }
+        GameState current = state.game();
+        GameState paused = new GameState(
+            GameLifecycle.PAUSED,
+            current.tyrantId(),
+            current.vigilanteId(),
+            current.pendingTyrant(),
+            current.pendingVigilante(),
+            Optional.of(now),
+            current.accumulatedPausedTime(),
+            current.tyrantLevel(),
+            current.unspentChoices(),
+            current.purchases()
+        );
+        return new LifecycleState(paused, state.players());
+    }
+
+    public LifecycleState resume(PersistentState state, Instant now) {
+        GameState current = state.game();
+        if (current.lifecycle() != GameLifecycle.PAUSED || current.pausedAt().isEmpty()) {
+            throw new IllegalStateException("only a paused game can be resumed");
+        }
+        Instant pausedAt = current.pausedAt().orElseThrow();
+        Duration pausedFor = Duration.between(pausedAt, now);
+        if (pausedFor.isNegative()) {
+            throw new IllegalArgumentException("resume time must not precede pause time");
+        }
+        GameState resumed = new GameState(
+            GameLifecycle.RUNNING,
+            current.tyrantId(),
+            current.vigilanteId(),
+            shiftSelection(current.pendingTyrant(), pausedFor),
+            shiftSelection(current.pendingVigilante(), pausedFor),
+            Optional.empty(),
+            current.accumulatedPausedTime().plus(pausedFor),
+            current.tyrantLevel(),
+            current.unspentChoices(),
+            current.purchases()
+        );
+        Map<UUID, PlayerState> players = new HashMap<>();
+        for (PlayerState player : state.players().values()) {
+            players.put(player.playerId(), shift(player, pausedFor));
+        }
+        return new LifecycleState(resumed, players);
+    }
+
+    public LifecycleState reset(PersistentState state) {
+        Map<UUID, PlayerState> players = new HashMap<>();
+        for (PlayerState player : state.players().values()) {
+            players.put(player.playerId(), new PlayerState(
+                player.playerId(),
+                player.latestName(),
+                player.lastLogin(),
+                player.optedOutUntil(),
+                TyrantClass.NONE,
+                Optional.empty(),
+                Map.of(),
+                Set.of(),
+                player.capturedMobs()
+            ));
+        }
+        return new LifecycleState(GameState.empty(), players);
+    }
+
+    private static Optional<PendingSelection> shiftSelection(
+        Optional<PendingSelection> selection,
+        Duration pausedFor
+    ) {
+        return selection.map(value -> new PendingSelection(
+            value.candidateId(), value.expiresAt().plus(pausedFor)
+        ));
+    }
+
+    private static PlayerState shift(PlayerState player, Duration pausedFor) {
+        Map<Ability, Instant> cooldowns = new EnumMap<>(Ability.class);
+        player.cooldownEnds().forEach((ability, deadline) ->
+            cooldowns.put(ability, deadline.plus(pausedFor))
+        );
+        return new PlayerState(
+            player.playerId(),
+            player.latestName(),
+            shiftInstant(player.lastLogin(), pausedFor),
+            shiftInstant(player.optedOutUntil(), pausedFor),
+            player.tyrantClass(),
+            player.followerOf(),
+            cooldowns,
+            player.readyAbilityItems(),
+            player.capturedMobs()
+        );
+    }
+
+    private static Optional<Instant> shiftInstant(Optional<Instant> value, Duration duration) {
+        return value.map(instant -> instant.plus(duration));
+    }
+}

src/main/java/games/dmg/spigottyrant/LifecycleState.java

@@ -0,0 +1,14 @@
+package games.dmg.spigottyrant;
+
+import java.util.Map;
+import java.util.UUID;
+
+public record LifecycleState(GameState game, Map<UUID, PlayerState> players) {
+    public LifecycleState {
+        players = Map.copyOf(players);
+    }
+
+    public PersistentState asPersistentState() {
+        return new PersistentState(game, players);
+    }
+}

src/main/java/games/dmg/spigottyrant/ManagedRoleEffects.java

@@ -0,0 +1,7 @@
+package games.dmg.spigottyrant;
+
+public interface ManagedRoleEffects {
+    void suppressAll();
+
+    void restoreAll();
+}

src/main/java/games/dmg/spigottyrant/NoopManagedRoleEffects.java

@@ -0,0 +1,13 @@
+package games.dmg.spigottyrant;
+
+public final class NoopManagedRoleEffects implements ManagedRoleEffects {
+    @Override
+    public void suppressAll() {
+        // No managed effects exist until their corresponding abilities are unlocked.
+    }
+
+    @Override
+    public void restoreAll() {
+        // No managed effects exist until their corresponding abilities are unlocked.
+    }
+}

src/main/java/games/dmg/spigottyrant/RoleCandidateSelector.java

@@ -0,0 +1,47 @@
+package games.dmg.spigottyrant;
+
+import java.time.Duration;
+import java.time.Instant;
+import java.util.ArrayList;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Set;
+import java.util.UUID;
+import java.util.random.RandomGenerator;
+
+public final class RoleCandidateSelector {
+    public Optional<UUID> select(
+        Map<UUID, PlayerState> players,
+        Set<UUID> excluded,
+        Optional<UUID> previousHolder,
+        Instant now,
+        Duration activityWindow,
+        RandomGenerator random
+    ) {
+        Instant cutoff = now.minus(activityWindow);
+        List<UUID> eligible = new ArrayList<>();
+        for (PlayerState player : players.values()) {
+            if (excluded.contains(player.playerId())) {
+                continue;
+            }
+            if (player.lastLogin().isEmpty()
+                    || player.lastLogin().orElseThrow().isBefore(cutoff)) {
+                continue;
+            }
+            if (player.optedOutUntil().filter(deadline -> deadline.isAfter(now)).isPresent()) {
+                continue;
+            }
+            eligible.add(player.playerId());
+        }
+        if (eligible.size() > 1) {
+            previousHolder.ifPresent(eligible::remove);
+        }
+        if (eligible.isEmpty()) {
+            return Optional.empty();
+        }
+        eligible.sort(Comparator.comparing(UUID::toString));
+        return Optional.of(eligible.get(random.nextInt(eligible.size())));
+    }
+}

src/main/java/games/dmg/spigottyrant/SpigotTyrantPlugin.java

@@ -29,6 +29,18 @@ public final class SpigotTyrantPlugin extends JavaPlugin {
 
         Objects.requireNonNull(getCommand("tyrant"), "Missing tyrant command metadata")
             .setExecutor(new TyrantCommand(stateManager, new TyrantProgressionService()));
+        Objects.requireNonNull(getCommand("tyrantadmin"), "Missing tyrantadmin metadata")
+            .setExecutor(new TyrantAdminCommand(
+                stateManager,
+                new GameLifecycleService(),
+                new BukkitOnlinePlayerDirectory(),
+                new NoopManagedRoleEffects(),
+                Clock.systemUTC(),
+                new RoleCandidateSelector(),
+                settings.candidateActivityWindow(),
+                settings.pendingSelectionTimeout(),
+                java.util.random.RandomGenerator.getDefault()
+            ));
         getServer().getPluginManager().registerEvents(
             new PlayerJoinListener(stateManager, Clock.systemUTC()),
             this

src/main/java/games/dmg/spigottyrant/TyrantAdminCommand.java

@@ -0,0 +1,209 @@
+package games.dmg.spigottyrant;
+
+import java.time.Clock;
+import java.time.Duration;
+import java.util.Locale;
+import java.util.Optional;
+import java.util.Set;
+import java.util.UUID;
+import java.util.random.RandomGenerator;
+import org.bukkit.ChatColor;
+import org.bukkit.command.Command;
+import org.bukkit.command.CommandExecutor;
+import org.bukkit.command.CommandSender;
+import org.bukkit.entity.Player;
+
+public final class TyrantAdminCommand implements CommandExecutor {
+    private static final String PERMISSION = "spigottyrant.admin";
+    private final TyrantStateManager stateManager;
+    private final GameLifecycleService lifecycle;
+    private final OnlinePlayerDirectory onlinePlayers;
+    private final ManagedRoleEffects effects;
+    private final Clock clock;
+    private final RoleCandidateSelector candidateSelector;
+    private final Duration activityWindow;
+    private final Duration pendingTimeout;
+    private final RandomGenerator random;
+
+    public TyrantAdminCommand(
+        TyrantStateManager stateManager,
+        GameLifecycleService lifecycle,
+        OnlinePlayerDirectory onlinePlayers,
+        ManagedRoleEffects effects,
+        Clock clock
+    ) {
+        this(
+            stateManager, lifecycle, onlinePlayers, effects, clock,
+            new RoleCandidateSelector(), Duration.ofHours(24), Duration.ofHours(24),
+            RandomGenerator.getDefault()
+        );
+    }
+
+    public TyrantAdminCommand(
+        TyrantStateManager stateManager,
+        GameLifecycleService lifecycle,
+        OnlinePlayerDirectory onlinePlayers,
+        ManagedRoleEffects effects,
+        Clock clock,
+        RoleCandidateSelector candidateSelector,
+        Duration activityWindow,
+        Duration pendingTimeout,
+        RandomGenerator random
+    ) {
+        this.stateManager = stateManager;
+        this.lifecycle = lifecycle;
+        this.onlinePlayers = onlinePlayers;
+        this.effects = effects;
+        this.clock = clock;
+        this.candidateSelector = candidateSelector;
+        this.activityWindow = activityWindow;
+        this.pendingTimeout = pendingTimeout;
+        this.random = random;
+    }
+
+    @Override
+    public boolean onCommand(
+        CommandSender sender,
+        Command command,
+        String label,
+        String[] arguments
+    ) {
+        if (!sender.hasPermission(PERMISSION)) {
+            sender.sendMessage(ChatColor.RED + "You do not have permission to administer Tyrant.");
+            return true;
+        }
+        if (arguments.length == 0 || arguments[0].equalsIgnoreCase("status")) {
+            showStatus(sender);
+            return true;
+        }
+        try {
+            switch (arguments[0].toLowerCase(Locale.ROOT)) {
+                case "start" -> start(sender, arguments);
+                case "pause" -> pause(sender);
+                case "resume" -> resume(sender);
+                case "reset" -> reset(sender, arguments);
+                default -> usage(sender);
+            }
+        } catch (IllegalArgumentException | IllegalStateException exception) {
+            sender.sendMessage(ChatColor.RED + exception.getMessage());
+        }
+        return true;
+    }
+
+    private void start(CommandSender sender, String[] arguments) {
+        if (arguments.length < 2 || arguments.length > 3) {
+            sender.sendMessage(ChatColor.YELLOW
+                + "Usage: /tyrantadmin start <tyrant> [vigilante]");
+            return;
+        }
+        Player tyrant = onlinePlayers.findByName(arguments[1]);
+        if (tyrant == null) {
+            sender.sendMessage(ChatColor.RED + "The initial Tyrant must be online.");
+            return;
+        }
+        Optional<Player> vigilante = Optional.empty();
+        if (arguments.length == 3) {
+            vigilante = Optional.ofNullable(onlinePlayers.findByName(arguments[2]));
+            if (vigilante.isEmpty()) {
+                sender.sendMessage(ChatColor.RED + "The initial Vigilante must be online.");
+                return;
+            }
+        }
+        stateManager.player(tyrant.getUniqueId(), tyrant.getName());
+        vigilante.ifPresent(player -> stateManager.player(player.getUniqueId(), player.getName()));
+        InstantHolder now = new InstantHolder(clock.instant());
+        Optional<UUID> randomCandidate = vigilante.isEmpty()
+            ? candidateSelector.select(
+                stateManager.players(), Set.of(tyrant.getUniqueId()), Optional.empty(),
+                now.value(), activityWindow, random
+            )
+            : Optional.empty();
+        Optional<UUID> activeVigilante = vigilante.map(Player::getUniqueId);
+        if (activeVigilante.isEmpty() && randomCandidate.isPresent()
+                && onlinePlayers.findById(randomCandidate.orElseThrow()) != null) {
+            activeVigilante = randomCandidate;
+        }
+        LifecycleState started = lifecycle.start(
+            stateManager.snapshot(), tyrant.getUniqueId(), activeVigilante, now.value()
+        );
+        if (activeVigilante.isEmpty() && randomCandidate.isPresent()) {
+            GameState game = started.game();
+            started = new LifecycleState(new GameState(
+                game.lifecycle(), game.tyrantId(), game.vigilanteId(), game.pendingTyrant(),
+                Optional.of(new PendingSelection(
+                    randomCandidate.orElseThrow(), now.value().plus(pendingTimeout)
+                )),
+                game.pausedAt(), game.accumulatedPausedTime(), game.tyrantLevel(),
+                game.unspentChoices(), game.purchases()
+            ), started.players());
+        }
+        stateManager.replaceState(started);
+        stateManager.saveIfDirty();
+        effects.restoreAll();
+        sender.sendMessage(ChatColor.GREEN + "Tyrant game started.");
+        if (vigilante.isEmpty()) {
+            sender.sendMessage(ChatColor.YELLOW
+                + "An eligible recently active Vigilante will be selected automatically.");
+        }
+    }
+
+    private void pause(CommandSender sender) {
+        LifecycleState paused = lifecycle.pause(stateManager.snapshot(), clock.instant());
+        stateManager.replaceState(paused);
+        stateManager.saveIfDirty();
+        effects.suppressAll();
+        sender.sendMessage(ChatColor.GREEN + "Tyrant game paused.");
+    }
+
+    private void resume(CommandSender sender) {
+        LifecycleState resumed = lifecycle.resume(stateManager.snapshot(), clock.instant());
+        stateManager.replaceState(resumed);
+        stateManager.saveIfDirty();
+        effects.restoreAll();
+        sender.sendMessage(ChatColor.GREEN + "Tyrant game resumed.");
+    }
+
+    private void reset(CommandSender sender, String[] arguments) {
+        if (arguments.length != 2 || !arguments[1].equalsIgnoreCase("confirm")) {
+            sender.sendMessage(ChatColor.RED
+                + "This clears the game. Use /tyrantadmin reset confirm.");
+            return;
+        }
+        stateManager.replaceState(lifecycle.reset(stateManager.snapshot()));
+        stateManager.saveIfDirty();
+        effects.suppressAll();
+        sender.sendMessage(ChatColor.GREEN + "Tyrant game reset.");
+    }
+
+    private void showStatus(CommandSender sender) {
+        GameState game = stateManager.game();
+        sender.sendMessage(ChatColor.GOLD + "Lifecycle: " + game.lifecycle());
+        sender.sendMessage("Tyrant: " + game.tyrantId().map(Object::toString).orElse("none"));
+        sender.sendMessage("Vigilante: "
+            + game.vigilanteId().map(Object::toString).orElse("none"));
+        sender.sendMessage("Level: " + game.tyrantLevel()
+            + ", choices: " + game.unspentChoices()
+            + ", purchases: " + game.purchases());
+        sender.sendMessage("Pending Tyrant: " + game.pendingTyrant());
+        sender.sendMessage("Pending Vigilante: " + game.pendingVigilante());
+        for (PlayerState player : stateManager.players().values()) {
+            boolean optedOut = player.optedOutUntil()
+                .filter(deadline -> deadline.isAfter(clock.instant()))
+                .isPresent();
+            sender.sendMessage(
+                player.latestName() + " (" + player.playerId() + "): class="
+                    + player.tyrantClass() + ", followerOf="
+                    + player.followerOf().map(Object::toString).orElse("none")
+                    + ", optedOut=" + optedOut + ", cooldowns=" + player.cooldownEnds()
+            );
+        }
+    }
+
+    private record InstantHolder(java.time.Instant value) {
+    }
+
+    private static void usage(CommandSender sender) {
+        sender.sendMessage(ChatColor.YELLOW
+            + "Usage: /tyrantadmin <status|start|pause|resume|reset confirm>");
+    }
+}

src/main/java/games/dmg/spigottyrant/TyrantStateManager.java

@@ -76,6 +76,17 @@ public final class TyrantStateManager {
         return game;
     }
 
+    public void replaceState(LifecycleState replacement) {
+        game = replacement.game();
+        players.clear();
+        players.putAll(replacement.players());
+        dirty = true;
+    }
+
+    public PersistentState snapshot() {
+        return new PersistentState(game, players);
+    }
+
     public boolean saveIfDirty() {
         if (!dirty) {
             return true;