package com.rscontrol.command; import com.rscontrol.RSControl; import com.rscontrol.model.ServerInstance; import com.rscontrol.model.ServerStatus; import net.kyori.adventure.text.Component; import net.kyori.adventure.text.format.NamedTextColor; import net.kyori.adventure.text.format.TextDecoration; import org.bukkit.command.Command; import org.bukkit.command.CommandExecutor; import org.bukkit.command.CommandSender; import org.bukkit.command.TabCompleter; import org.bukkit.entity.Player; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.stream.Collectors; public class RSCommand implements CommandExecutor, TabCompleter { private final RSControl plugin; public RSCommand(RSControl plugin) { this.plugin = plugin; } @Override public boolean onCommand(CommandSender sender, Command command, String label, String[] args) { if (sender instanceof Player) { Player player = (Player) sender; if (!plugin.getSecurityManager().canUseCommand(player)) { return true; } } if (args.length == 0) { sendHelp(sender); return true; } String subCommand = args[0].toLowerCase(); switch (subCommand) { case "start": handleStart(sender, args); break; case "stop": handleStop(sender, args); break; case "restart": handleRestart(sender, args); break; case "status": handleStatus(sender, args); break; case "list": handleList(sender); break; case "console": handleConsole(sender, args); break; case "create": handleCreate(sender, args); break; case "delete": handleDelete(sender, args); break; case "reload": handleReload(sender); break; default: sendHelp(sender); break; } return true; } private void handleStart(CommandSender sender, String[] args) { if (!checkPermission(sender, "rscontrol.command.start")) return; if (args.length < 2) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Usage: /rs start ", NamedTextColor.RED))); return; } String serverId = args[1]; ServerInstance server = plugin.getServerManager().getServer(serverId); if (server == null) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server '" + serverId + "' not found.", NamedTextColor.RED))); return; } if (server.isRunning()) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server '" + server.getName() + "' is already running.", NamedTextColor.RED))); return; } sender.sendMessage(plugin.getPrefix() .append(Component.text("Starting server '" + server.getName() + "'...", NamedTextColor.GREEN))); plugin.getServerManager().startServer(serverId).thenAccept(result -> { if (result) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server '" + server.getName() + "' started successfully.", NamedTextColor.GREEN))); } else { sender.sendMessage(plugin.getPrefix() .append(Component.text("Failed to start server '" + server.getName() + "'.", NamedTextColor.RED))); } }); } private void handleStop(CommandSender sender, String[] args) { if (!checkPermission(sender, "rscontrol.command.stop")) return; if (args.length < 2) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Usage: /rs stop ", NamedTextColor.RED))); return; } String serverId = args[1]; ServerInstance server = plugin.getServerManager().getServer(serverId); if (server == null) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server '" + serverId + "' not found.", NamedTextColor.RED))); return; } if (!server.isRunning()) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server '" + server.getName() + "' is not running.", NamedTextColor.RED))); return; } sender.sendMessage(plugin.getPrefix() .append(Component.text("Stopping server '" + server.getName() + "'...", NamedTextColor.YELLOW))); plugin.getServerManager().stopServer(serverId).thenAccept(result -> { if (result) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server '" + server.getName() + "' stopped successfully.", NamedTextColor.GREEN))); } else { sender.sendMessage(plugin.getPrefix() .append(Component.text("Failed to stop server '" + server.getName() + "'.", NamedTextColor.RED))); } }); } private void handleRestart(CommandSender sender, String[] args) { if (!checkPermission(sender, "rscontrol.command.restart")) return; if (args.length < 2) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Usage: /rs restart ", NamedTextColor.RED))); return; } String serverId = args[1]; ServerInstance server = plugin.getServerManager().getServer(serverId); if (server == null) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server '" + serverId + "' not found.", NamedTextColor.RED))); return; } sender.sendMessage(plugin.getPrefix() .append(Component.text("Restarting server '" + server.getName() + "'...", NamedTextColor.YELLOW))); plugin.getServerManager().restartServer(serverId).thenAccept(result -> { if (result) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server '" + server.getName() + "' restarted successfully.", NamedTextColor.GREEN))); } else { sender.sendMessage(plugin.getPrefix() .append(Component.text("Failed to restart server '" + server.getName() + "'.", NamedTextColor.RED))); } }); } private void handleStatus(CommandSender sender, String[] args) { if (!checkPermission(sender, "rscontrol.command.status")) return; if (args.length < 2) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Usage: /rs status ", NamedTextColor.RED))); return; } String serverId = args[1]; ServerInstance server = plugin.getServerManager().getServer(serverId); if (server == null) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server '" + serverId + "' not found.", NamedTextColor.RED))); return; } sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); sender.sendMessage(Component.text("Server Status: ", NamedTextColor.GOLD) .append(Component.text(server.getName(), NamedTextColor.WHITE, TextDecoration.BOLD))); sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); sender.sendMessage(Component.text("Status: ", NamedTextColor.AQUA) .append(getStatusComponent(server.getStatus()))); sender.sendMessage(Component.text("Memory: ", NamedTextColor.AQUA) .append(Component.text(server.getMemoryMb() + " MB", NamedTextColor.WHITE))); if (server.isRunning()) { long uptimeSeconds = server.getUptimeSeconds(); String uptime = formatUptime(uptimeSeconds); sender.sendMessage(Component.text("Uptime: ", NamedTextColor.AQUA) .append(Component.text(uptime, NamedTextColor.WHITE))); sender.sendMessage(Component.text("Players: ", NamedTextColor.AQUA) .append(Component.text(server.getPlayerCount(), NamedTextColor.WHITE))); } sender.sendMessage(Component.text("JAR: ", NamedTextColor.AQUA) .append(Component.text(server.getJarPath(), NamedTextColor.GRAY))); sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); } private void handleList(CommandSender sender) { if (!checkPermission(sender, "rscontrol.command.list")) return; sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); sender.sendMessage(Component.text("Managed Servers", NamedTextColor.GOLD, TextDecoration.BOLD)); sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); if (plugin.getServerManager().getServerCount() == 0) { sender.sendMessage(Component.text("No servers configured.", NamedTextColor.GRAY)); } else { for (ServerInstance server : plugin.getServerManager().getAllServers()) { Component statusIcon = server.isRunning() ? Component.text("●", NamedTextColor.GREEN) : Component.text("●", NamedTextColor.RED); sender.sendMessage(statusIcon .append(Component.space()) .append(Component.text(server.getName(), NamedTextColor.WHITE)) .append(Component.text(" (", NamedTextColor.GRAY)) .append(Component.text(server.getId(), NamedTextColor.GRAY)) .append(Component.text(")", NamedTextColor.GRAY))); } } sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); } private void handleConsole(CommandSender sender, String[] args) { if (!checkPermission(sender, "rscontrol.command.console")) return; if (args.length < 2) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Usage: /rs console [lines]", NamedTextColor.RED))); return; } String serverId = args[1]; int lines = 20; if (args.length >= 3) { try { lines = Integer.parseInt(args[2]); lines = Math.min(lines, 100); } catch (NumberFormatException e) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Invalid line count.", NamedTextColor.RED))); return; } } ServerInstance server = plugin.getServerManager().getServer(serverId); if (server == null) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server '" + serverId + "' not found.", NamedTextColor.RED))); return; } List consoleLog = server.getRecentConsoleLog(lines); sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); sender.sendMessage(Component.text("Console: ", NamedTextColor.GOLD) .append(Component.text(server.getName(), NamedTextColor.WHITE))); sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); if (consoleLog.isEmpty()) { sender.sendMessage(Component.text("No console output available.", NamedTextColor.GRAY)); } else { for (String line : consoleLog) { sender.sendMessage(Component.text(line, NamedTextColor.GRAY)); } } sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); } private void handleCreate(CommandSender sender, String[] args) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server creation via command is not yet implemented.", NamedTextColor.YELLOW))); sender.sendMessage(Component.text("Please add new servers to config.yml and use /rs reload", NamedTextColor.GRAY)); } private void handleDelete(CommandSender sender, String[] args) { sender.sendMessage(plugin.getPrefix() .append(Component.text("Server deletion via command is not yet implemented.", NamedTextColor.YELLOW))); sender.sendMessage(Component.text("Please edit config.yml and use /rs reload", NamedTextColor.GRAY)); } private void handleReload(CommandSender sender) { if (!checkPermission(sender, "rscontrol.admin")) return; sender.sendMessage(plugin.getPrefix() .append(Component.text("Reloading configuration...", NamedTextColor.YELLOW))); plugin.getConfigManager().reload(); sender.sendMessage(plugin.getPrefix() .append(Component.text("Configuration reloaded.", NamedTextColor.GREEN))); } private void sendHelp(CommandSender sender) { sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); sender.sendMessage(Component.text("RSControl Commands", NamedTextColor.GOLD, TextDecoration.BOLD)); sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); sender.sendMessage(Component.text("/rs start ", NamedTextColor.GREEN) .append(Component.text(" - Start a server", NamedTextColor.GRAY))); sender.sendMessage(Component.text("/rs stop ", NamedTextColor.YELLOW) .append(Component.text(" - Stop a server", NamedTextColor.GRAY))); sender.sendMessage(Component.text("/rs restart ", NamedTextColor.AQUA) .append(Component.text(" - Restart a server", NamedTextColor.GRAY))); sender.sendMessage(Component.text("/rs status ", NamedTextColor.BLUE) .append(Component.text(" - Check server status", NamedTextColor.GRAY))); sender.sendMessage(Component.text("/rs list", NamedTextColor.LIGHT_PURPLE) .append(Component.text(" - List all servers", NamedTextColor.GRAY))); sender.sendMessage(Component.text("/rs console [lines]", NamedTextColor.WHITE) .append(Component.text(" - View console", NamedTextColor.GRAY))); sender.sendMessage(Component.text("/rs reload", NamedTextColor.RED) .append(Component.text(" - Reload config", NamedTextColor.GRAY))); sender.sendMessage(Component.text("═══════════════════════════", NamedTextColor.GRAY)); } private boolean checkPermission(CommandSender sender, String permission) { if (!sender.hasPermission(permission)) { sender.sendMessage(plugin.getPrefix() .append(Component.text("You don't have permission to use this command.", NamedTextColor.RED))); return false; } return true; } private Component getStatusComponent(ServerStatus status) { return switch (status) { case RUNNING -> Component.text("RUNNING", NamedTextColor.GREEN, TextDecoration.BOLD); case STOPPED -> Component.text("STOPPED", NamedTextColor.RED); case STARTING -> Component.text("STARTING", NamedTextColor.YELLOW); case STOPPING -> Component.text("STOPPING", NamedTextColor.YELLOW); case CRASHED -> Component.text("CRASHED", NamedTextColor.DARK_RED, TextDecoration.BOLD); }; } private String formatUptime(long seconds) { long hours = seconds / 3600; long minutes = (seconds % 3600) / 60; long secs = seconds % 60; return String.format("%dh %dm %ds", hours, minutes, secs); } @Override public List onTabComplete(CommandSender sender, Command command, String alias, String[] args) { List completions = new ArrayList<>(); if (args.length == 1) { completions.addAll(Arrays.asList("start", "stop", "restart", "status", "list", "console", "create", "delete", "reload")); } else if (args.length == 2) { String subCommand = args[0].toLowerCase(); if (Arrays.asList("start", "stop", "restart", "status", "console").contains(subCommand)) { completions.addAll(plugin.getServerManager().getAllServers().stream() .map(ServerInstance::getId) .collect(Collectors.toList())); } } return completions.stream() .filter(s -> s.toLowerCase().startsWith(args[args.length - 1].toLowerCase())) .collect(Collectors.toList()); } }