package ru.sekta.auth.commands; import net.kyori.adventure.text.minimessage.MiniMessage; import org.bukkit.command.Command; import org.bukkit.command.CommandExecutor; import org.bukkit.command.CommandSender; import org.bukkit.entity.Player; import org.jetbrains.annotations.NotNull; import ru.sekta.auth.SektaAuthPlugin; import ru.sekta.auth.ServiceRegistry; /** * /sauth admin command hub. * Subcommands: reload, changepass, resetcode, unregister, forcelogin, id, * client allow, client remove, client list, changename, setdisplayname */ public class SAuthCommand implements CommandExecutor { private final SektaAuthPlugin plugin; private final ServiceRegistry registry; private final MiniMessage mm = MiniMessage.miniMessage(); public SAuthCommand(SektaAuthPlugin plugin, ServiceRegistry registry) { this.plugin = plugin; this.registry = registry; } @Override public boolean onCommand(@NotNull CommandSender sender, @NotNull Command command, @NotNull String label, @NotNull String[] args) { if (!sender.hasPermission("sekta.auth.admin")) { sender.sendMessage(mm.deserialize("Нет доступа.")); return true; } if (args.length == 0) { sendHelp(sender); return true; } switch (args[0].toLowerCase()) { case "reload" -> handleReload(sender); case "changepass" -> handleChangePass(sender, args); case "resetcode" -> handleResetCode(sender, args); case "unregister" -> handleUnregister(sender, args); case "forcelogin" -> handleForceLogin(sender, args); case "id" -> handleId(sender, args); case "client" -> handleClient(sender, args); case "changename" -> handleChangeName(sender, args); case "setdisplayname" -> handleSetDisplayName(sender, args); default -> sendHelp(sender); } return true; } private void handleReload(CommandSender sender) { plugin.reloadConfig(); plugin.saveResource("messages.yml", true); registry.getLoginManager().reloadMessages(); registry.getRegisterManager().reloadMessages(); registry.getRecoveryManager().reloadMessages(); registry.getIpLimiter().reloadMessages(); registry.getClientCheckManager().reloadMessages(); sender.sendMessage(mm.deserialize("Конфиг перезагружен.")); } private void handleChangePass(CommandSender sender, String[] args) { if (args.length < 3) { sender.sendMessage(mm.deserialize("Использование: /sauth changepass <ник> <пароль>")); return; } String target = args[1]; String newPass = args[2]; registry.getRecoveryManager().adminChangePassword(target, newPass, () -> sender.sendMessage(mm.deserialize("Пароль для " + target + " изменён.")), () -> sender.sendMessage(mm.deserialize("Игрок " + target + " не найден."))); } private void handleResetCode(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage(mm.deserialize("Использование: /sauth resetcode <ник>")); return; } String target = args[1]; registry.getAuthRepository().findByUsername(target).thenAcceptAsync(opt -> { if (opt.isEmpty()) { sender.sendMessage(mm.deserialize("Игрок не найден.")); return; } var ap = opt.get(); String newCode = registry.getRecoveryManager().generateRecoveryCode(); ap.setRecoveryCode(newCode); registry.getAuthRepository().update(ap).thenRun(() -> sender.sendMessage(mm.deserialize("Новый код для " + target + ": " + newCode + ""))); }); } private void handleUnregister(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage(mm.deserialize("Использование: /sauth unregister <ник>")); return; } String target = args[1]; registry.getAuthRepository().findByUsername(target).thenAcceptAsync(opt -> { if (opt.isEmpty()) { sender.sendMessage(mm.deserialize("Игрок не найден.")); return; } registry.getAuthRepository().deleteByUuid(opt.get().getUuid()).thenRun(() -> sender.sendMessage(mm.deserialize("Аккаунт " + target + " удалён."))); }); } private void handleForceLogin(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage(mm.deserialize("Использование: /sauth forcelogin <ник>")); return; } Player target = plugin.getServer().getPlayerExact(args[1]); if (target == null) { sender.sendMessage(mm.deserialize("Игрок не в сети.")); return; } plugin.getServer().getScheduler().runTask(plugin, () -> { registry.getAuthManager().authenticate(target); sender.sendMessage(mm.deserialize("Игрок " + target.getName() + " принудительно авторизован.")); }); } private void handleId(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage(mm.deserialize("Использование: /sauth id <ник>")); return; } registry.getAuthRepository().findByUsername(args[1]).thenAcceptAsync(opt -> { if (opt.isEmpty()) { sender.sendMessage(mm.deserialize("Игрок не найден.")); return; } sender.sendMessage(mm.deserialize("ID игрока " + args[1] + ": #" + opt.get().getStaticId() + "")); }); } private void handleClient(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage(mm.deserialize("Использование: /sauth client [клиент]")); return; } switch (args[1].toLowerCase()) { case "allow" -> { if (args.length < 3) return; registry.getClientWhitelistManager().addBrand(args[2]).thenRun(() -> sender.sendMessage(mm.deserialize("Клиент " + args[2] + " разрешён."))); } case "remove" -> { if (args.length < 3) return; registry.getClientWhitelistManager().removeBrand(args[2]).thenRun(() -> sender.sendMessage(mm.deserialize("Клиент " + args[2] + " удалён из белого списка."))); } case "list" -> sender.sendMessage(mm.deserialize("Белый список: " + String.join(", ", registry.getClientWhitelistManager().getWhitelist()) + "")); } } private void handleChangeName(CommandSender sender, String[] args) { if (args.length < 3) { sender.sendMessage(mm.deserialize("Использование: /sauth changename <старый> <новый>")); return; } registry.getNameChangeManager().changeName(args[1], args[2]).thenAccept(success -> { if (success) sender.sendMessage(mm.deserialize("Имя изменено с " + args[1] + " на " + args[2] + ".")); else sender.sendMessage(mm.deserialize("Игрок " + args[1] + " не найден.")); }); } private void handleSetDisplayName(CommandSender sender, String[] args) { if (args.length < 3) { sender.sendMessage(mm.deserialize("Использование: /sauth setdisplayname <ник> <имя>")); return; } registry.getAuthRepository().findByUsername(args[1]).thenAcceptAsync(opt -> { if (opt.isEmpty()) { sender.sendMessage(mm.deserialize("Игрок не найден.")); return; } String displayName = String.join(" ", java.util.Arrays.copyOfRange(args, 2, args.length)); registry.getDisplayNameManager().setDisplayName(opt.get().getUuid(), displayName).thenRun(() -> { sender.sendMessage(mm.deserialize("Отображаемое имя для " + args[1] + " установлено: " + displayName + "")); Player online = plugin.getServer().getPlayerExact(args[1]); if (online != null) { opt.get().setDisplayName(displayName); registry.getDisplayNameManager().applyDisplayName(online, opt.get()); } }); }); } private void sendHelp(CommandSender sender) { sender.sendMessage(mm.deserialize(""" SektaAuth Admin Commands /sauth reload — перезагрузить конфиг /sauth changepass <ник> <пароль> /sauth resetcode <ник> /sauth unregister <ник> /sauth forcelogin <ник> /sauth id <ник> /sauth client allow|remove|list [клиент] /sauth changename <старый> <новый> /sauth setdisplayname <ник> <имя>""")); } }