package com.acchat.plugin.commands; import com.acchat.plugin.ACChat; import com.acchat.plugin.models.AIAnalysis; import com.acchat.plugin.models.Appeal; import com.acchat.plugin.models.PunishmentRecord; import org.bukkit.Bukkit; 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.io.File; import java.io.FileWriter; import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.UUID; import java.util.stream.Collectors; public class AdminCommand implements CommandExecutor, TabCompleter { private final ACChat plugin; public AdminCommand(ACChat plugin) { this.plugin = plugin; } @Override public boolean onCommand(CommandSender sender, Command command, String label, String[] args) { if (!sender.hasPermission("acchat.admin")) { sender.sendMessage(plugin.getConfigManager().getMessage("error.no-permission")); return true; } if (args.length == 0) { sendHelp(sender); return true; } switch (args[0].toLowerCase()) { case "stats" -> handleStats(sender, args); case "logs" -> handleLogs(sender, args); case "trust" -> handleTrust(sender, args); case "whitelist" -> handleWhitelist(sender, args); case "blacklist" -> handleBlacklist(sender, args); case "punish" -> handlePunish(sender, args); case "mute" -> handleMute(sender, args); case "kick" -> handleKick(sender, args); case "ban" -> handleBan(sender, args); case "pardon" -> handlePardon(sender, args); case "appeal" -> handleAppeal(sender, args); case "alerts" -> handleAlerts(sender); case "debug" -> handleDebug(sender); case "cache" -> handleCache(sender, args); case "api" -> handleApi(sender, args); case "export" -> handleExport(sender, args); case "test" -> handleTest(sender, args); case "reload" -> handleReload(sender, args); default -> sendHelp(sender); } return true; } private void sendHelp(CommandSender sender) { sender.sendMessage("§7§m----------§r §bACChat Admin §7§m----------"); sender.sendMessage("§b/acca stats [player] §7- View statistics"); sender.sendMessage("§b/acca logs [page] §7- View player logs"); sender.sendMessage("§b/acca trust §7- Manage trust"); sender.sendMessage("§b/acca whitelist [player] §7- Manage whitelist"); sender.sendMessage("§b/acca blacklist [word] §7- Manage blacklist"); sender.sendMessage("§b/acca mute [reason] §7- Mute player"); sender.sendMessage("§b/acca kick [reason] §7- Kick player"); sender.sendMessage("§b/acca ban [reason] §7- Ban player"); sender.sendMessage("§b/acca pardon §7- Clear punishments"); sender.sendMessage("§b/acca appeal [id] §7- Manage appeals"); sender.sendMessage("§b/acca alerts §7- Toggle real-time alerts"); sender.sendMessage("§b/acca debug §7- Toggle debug mode"); sender.sendMessage("§b/acca cache §7- Manage cache"); sender.sendMessage("§b/acca api §7- Check API"); sender.sendMessage("§b/acca export §7- Export data"); sender.sendMessage("§b/acca test §7- Test AI analysis"); sender.sendMessage("§b/acca reload [config/rules/messages] §7- Reload configs"); } private void handleStats(CommandSender sender, String[] args) { Player target = null; if (args.length > 1) { target = Bukkit.getPlayer(args[1]); if (target == null) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-not-found") .replace("{player}", args[1])); return; } } if (target != null) { showPlayerStats(sender, target); } else { showGlobalStats(sender); } } private void showPlayerStats(CommandSender sender, Player target) { sender.sendMessage("§7§m----------§r §bPlayer Statistics §7§m----------"); sender.sendMessage("§7Player: §f" + target.getName()); double trustScore = plugin.getTrustFactorManager().getTrustScore(target.getUniqueId()); String trustStatus = plugin.getTrustFactorManager().getTrustStatus(trustScore); sender.sendMessage(String.format("§7Trust Factor: §f%.1f/100 §7(%s)", trustScore, trustStatus)); List punishments = plugin.getLogManager().getPunishments(target.getUniqueId(), 10); sender.sendMessage("§7Total Punishments: §f" + punishments.size()); if (!punishments.isEmpty()) { sender.sendMessage("§7Recent Punishments:"); for (int i = 0; i < Math.min(5, punishments.size()); i++) { PunishmentRecord record = punishments.get(i); sender.sendMessage(String.format(" §8- §f%s §7for §f%s §8(%.0f%% confidence)", record.getPunishmentType(), record.getRuleViolated(), record.getConfidence() * 100)); } } boolean whitelisted = plugin.getWhitelistManager().isWhitelisted(target.getUniqueId()); sender.sendMessage("§7Whitelisted: " + (whitelisted ? "§aYes" : "§cNo")); boolean muted = plugin.getPunishmentManager().isMuted(target.getUniqueId()); sender.sendMessage("§7Currently Muted: " + (muted ? "§cYes" : "§aNo")); } private void showGlobalStats(CommandSender sender) { sender.sendMessage("§7§m----------§r §bGlobal Statistics §7§m----------"); long uptime = plugin.getMetricsCollector().getUptime(); sender.sendMessage("§7Uptime: §f" + formatUptime(uptime)); sender.sendMessage("§7Messages Processed: §f" + plugin.getMetricsCollector().getTotalMessagesProcessed().sum()); sender.sendMessage("§7Violations Detected: §f" + plugin.getMetricsCollector().getTotalViolationsDetected().sum()); sender.sendMessage(String.format("§7Violation Rate: §f%.2f%%", plugin.getMetricsCollector().getViolationRate())); sender.sendMessage("§7Warnings Issued: §f" + plugin.getMetricsCollector().getTotalWarningsIssued().sum()); sender.sendMessage("§7Mutes Applied: §f" + plugin.getMetricsCollector().getTotalMutesApplied().sum()); sender.sendMessage("§7Bans Applied: §f" + plugin.getMetricsCollector().getTotalBansApplied().sum()); sender.sendMessage(String.format("§7AI Success Rate: §f%.2f%%", plugin.getMetricsCollector().getAiSuccessRate())); sender.sendMessage("§7Avg AI Response: §f" + plugin.getMetricsCollector().getAvgAiResponseTime().get() + "ms"); sender.sendMessage("§7Peak AI Response: §f" + plugin.getMetricsCollector().getPeakAiResponseTime().get() + "ms"); sender.sendMessage(String.format("§7Cache Hit Rate: §f%.2f%%", plugin.getMetricsCollector().getCacheHitRate())); } private void handleLogs(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage("§cUsage: /acca logs [page]"); return; } Player target = Bukkit.getPlayer(args[1]); if (target == null) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-not-found") .replace("{player}", args[1])); return; } int page = 1; if (args.length > 2) { try { page = Integer.parseInt(args[2]); } catch (NumberFormatException e) { sender.sendMessage("§cInvalid page number"); return; } } List punishments = plugin.getLogManager().getPunishments(target.getUniqueId(), 50); int perPage = 10; int totalPages = (int) Math.ceil((double) punishments.size() / perPage); if (page < 1 || page > totalPages) { sender.sendMessage("§cInvalid page number. Total pages: " + totalPages); return; } sender.sendMessage("§7§m----------§r §bLogs: " + target.getName() + " §7(Page " + page + "/" + totalPages + ") §7§m----------"); int start = (page - 1) * perPage; int end = Math.min(start + perPage, punishments.size()); for (int i = start; i < end; i++) { PunishmentRecord record = punishments.get(i); long ago = System.currentTimeMillis() - record.getTimestamp(); sender.sendMessage(String.format("§7[%s ago] §f%s §7- §f%s §8(%.0f%%)", formatTime(ago), record.getPunishmentType(), record.getReason(), record.getConfidence() * 100)); } } private void handleTrust(CommandSender sender, String[] args) { if (args.length < 4) { sender.sendMessage("§cUsage: /acca trust "); return; } Player target = Bukkit.getPlayer(args[1]); if (target == null) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-not-found") .replace("{player}", args[1])); return; } String action = args[2].toLowerCase(); double amount; try { amount = Double.parseDouble(args[3]); } catch (NumberFormatException e) { sender.sendMessage("§cInvalid amount"); return; } double currentScore = plugin.getTrustFactorManager().getTrustScore(target.getUniqueId()); switch (action) { case "set" -> { plugin.getTrustFactorManager().setTrustScore(target.getUniqueId(), amount); sender.sendMessage(plugin.getConfigManager().getMessage("admin.trust-set") .replace("{player}", target.getName()) .replace("{score}", String.format("%.1f", amount))); } case "add" -> { plugin.getTrustFactorManager().increaseTrust(target.getUniqueId(), amount); double newScore = plugin.getTrustFactorManager().getTrustScore(target.getUniqueId()); sender.sendMessage(plugin.getConfigManager().getMessage("admin.trust-added") .replace("{player}", target.getName()) .replace("{amount}", String.format("%.1f", amount)) .replace("{score}", String.format("%.1f", newScore))); } case "remove" -> { plugin.getTrustFactorManager().decreaseTrust(target.getUniqueId(), amount); double newScore = plugin.getTrustFactorManager().getTrustScore(target.getUniqueId()); sender.sendMessage(plugin.getConfigManager().getMessage("admin.trust-removed") .replace("{player}", target.getName()) .replace("{amount}", String.format("%.1f", amount)) .replace("{score}", String.format("%.1f", newScore))); } default -> sender.sendMessage("§cInvalid action. Use: set, add, or remove"); } } private void handleWhitelist(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage("§cUsage: /acca whitelist [player]"); return; } String action = args[1].toLowerCase(); switch (action) { case "add" -> { if (args.length < 3) { sender.sendMessage("§cUsage: /acca whitelist add "); return; } Player target = Bukkit.getPlayer(args[2]); if (target == null) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-not-found") .replace("{player}", args[2])); return; } plugin.getWhitelistManager().addToWhitelist(target.getUniqueId(), target.getName()); sender.sendMessage(plugin.getConfigManager().getMessage("admin.whitelist-added") .replace("{target}", target.getName())); } case "remove" -> { if (args.length < 3) { sender.sendMessage("§cUsage: /acca whitelist remove "); return; } Player target = Bukkit.getPlayer(args[2]); if (target == null) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-not-found") .replace("{player}", args[2])); return; } plugin.getWhitelistManager().removeFromWhitelist(target.getUniqueId()); sender.sendMessage(plugin.getConfigManager().getMessage("admin.whitelist-removed") .replace("{target}", target.getName())); } case "list" -> { List players = plugin.getWhitelistManager().getWhitelistedPlayers(); sender.sendMessage(plugin.getConfigManager().getMessage("admin.whitelist-list") .replace("{list}", players.isEmpty() ? "None" : String.join(", ", players))); } default -> sender.sendMessage("§cInvalid action. Use: add, remove, or list"); } } private void handleBlacklist(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage("§cUsage: /acca blacklist [word]"); return; } String action = args[1].toLowerCase(); switch (action) { case "add" -> { if (args.length < 3) { sender.sendMessage("§cUsage: /acca blacklist add "); return; } String word = args[2]; plugin.getWhitelistManager().addToBlacklist(word); sender.sendMessage(plugin.getConfigManager().getMessage("admin.blacklist-added") .replace("{word}", word)); } case "remove" -> { if (args.length < 3) { sender.sendMessage("§cUsage: /acca blacklist remove "); return; } String word = args[2]; plugin.getWhitelistManager().removeFromBlacklist(word); sender.sendMessage(plugin.getConfigManager().getMessage("admin.blacklist-removed") .replace("{word}", word)); } case "list" -> { List words = plugin.getWhitelistManager().getBlacklistedWords(); sender.sendMessage(plugin.getConfigManager().getMessage("admin.blacklist-list") .replace("{list}", words.isEmpty() ? "None" : String.join(", ", words))); } default -> sender.sendMessage("§cInvalid action. Use: add, remove, or list"); } } private void handlePunish(CommandSender sender, String[] args) { sender.sendMessage("§7Use specific commands: /acca mute, /acca kick, /acca ban"); } private void handleMute(CommandSender sender, String[] args) { if (args.length < 3) { sender.sendMessage("§cUsage: /acca mute [reason]"); return; } Player target = Bukkit.getPlayer(args[1]); if (target == null) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-not-found") .replace("{player}", args[1])); return; } long duration = parseDuration(args[2]); if (duration == 0) { sender.sendMessage("§cInvalid duration format. Use: 10m, 1h, 1d"); return; } String reason = args.length > 3 ? String.join(" ", Arrays.copyOfRange(args, 3, args.length)) : "Manual mute"; AIAnalysis analysis = new AIAnalysis(true, "manual", 1.0, reason, "high"); plugin.getPunishmentManager().mute(target, duration, analysis); sender.sendMessage(plugin.getConfigManager().getMessage("admin.manual-mute") .replace("{player}", target.getName()) .replace("{duration}", formatDuration(duration)) .replace("{reason}", reason)); } private void handleKick(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage("§cUsage: /acca kick [reason]"); return; } Player target = Bukkit.getPlayer(args[1]); if (target == null) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-not-found") .replace("{player}", args[1])); return; } String reason = args.length > 2 ? String.join(" ", Arrays.copyOfRange(args, 2, args.length)) : "Manual kick"; AIAnalysis analysis = new AIAnalysis(true, "manual", 1.0, reason, "medium"); plugin.getPunishmentManager().kick(target, analysis); sender.sendMessage(plugin.getConfigManager().getMessage("admin.manual-kick") .replace("{player}", target.getName()) .replace("{reason}", reason)); } private void handleBan(CommandSender sender, String[] args) { if (args.length < 3) { sender.sendMessage("§cUsage: /acca ban [reason]"); return; } Player target = Bukkit.getPlayer(args[1]); if (target == null) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-not-found") .replace("{player}", args[1])); return; } long duration = parseDuration(args[2]); if (duration == 0 && !args[2].equalsIgnoreCase("permanent")) { sender.sendMessage("§cInvalid duration format. Use: 10m, 1h, 1d, or permanent"); return; } if (args[2].equalsIgnoreCase("permanent")) { duration = -1; } String reason = args.length > 3 ? String.join(" ", Arrays.copyOfRange(args, 3, args.length)) : "Manual ban"; AIAnalysis analysis = new AIAnalysis(true, "manual", 1.0, reason, "critical"); plugin.getPunishmentManager().ban(target, duration, analysis); sender.sendMessage(plugin.getConfigManager().getMessage("admin.manual-ban") .replace("{player}", target.getName()) .replace("{duration}", duration == -1 ? "permanently" : formatDuration(duration)) .replace("{reason}", reason)); } private void handlePardon(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage("§cUsage: /acca pardon "); return; } Player target = Bukkit.getPlayer(args[1]); if (target == null) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-not-found") .replace("{player}", args[1])); return; } plugin.getExecutorService().submit(() -> { try (var conn = plugin.getDatabaseManager().getConnection()) { var stmt = conn.prepareStatement("UPDATE acchat_punishments SET active = FALSE WHERE uuid = ?"); stmt.setString(1, target.getUniqueId().toString()); stmt.executeUpdate(); sender.sendMessage(plugin.getConfigManager().getMessage("admin.pardon") .replace("{player}", target.getName())); } catch (Exception e) { sender.sendMessage("§cFailed to pardon player: " + e.getMessage()); } }); } private void handleAppeal(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage("§cUsage: /acca appeal [id]"); return; } String action = args[1].toLowerCase(); switch (action) { case "list" -> { List appeals = plugin.getAppealManager().getPendingAppeals(); sender.sendMessage("§7§m----------§r §bPending Appeals §7§m----------"); if (appeals.isEmpty()) { sender.sendMessage("§7No pending appeals."); } else { for (Appeal appeal : appeals) { long ago = System.currentTimeMillis() - appeal.getSubmittedAt(); sender.sendMessage(String.format("§7[#%d] §f%s §7- %s ago", appeal.getId(), appeal.getPlayerName(), formatTime(ago))); sender.sendMessage(" §7Reason: §f" + appeal.getReason()); } } } case "accept" -> { if (args.length < 3) { sender.sendMessage("§cUsage: /acca appeal accept [response]"); return; } int id; try { id = Integer.parseInt(args[2]); } catch (NumberFormatException e) { sender.sendMessage("§cInvalid appeal ID"); return; } String response = args.length > 3 ? String.join(" ", Arrays.copyOfRange(args, 3, args.length)) : "Appeal accepted"; Appeal appeal = plugin.getAppealManager().getAppeal(id); if (appeal == null) { sender.sendMessage("§cAppeal not found"); return; } plugin.getAppealManager().acceptAppeal(id, response); sender.sendMessage(plugin.getConfigManager().getMessage("admin.appeal-accepted") .replace("{id}", String.valueOf(id)) .replace("{player}", appeal.getPlayerName())); } case "deny" -> { if (args.length < 3) { sender.sendMessage("§cUsage: /acca appeal deny [response]"); return; } int id; try { id = Integer.parseInt(args[2]); } catch (NumberFormatException e) { sender.sendMessage("§cInvalid appeal ID"); return; } String response = args.length > 3 ? String.join(" ", Arrays.copyOfRange(args, 3, args.length)) : "Appeal denied"; Appeal appeal = plugin.getAppealManager().getAppeal(id); if (appeal == null) { sender.sendMessage("§cAppeal not found"); return; } plugin.getAppealManager().denyAppeal(id, response); sender.sendMessage(plugin.getConfigManager().getMessage("admin.appeal-denied") .replace("{id}", String.valueOf(id)) .replace("{player}", appeal.getPlayerName())); } default -> sender.sendMessage("§cInvalid action. Use: accept, deny, or list"); } } private void handleAlerts(CommandSender sender) { if (!(sender instanceof Player player)) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-only")); return; } plugin.getAdminManager().toggleAlerts(player.getUniqueId()); if (plugin.getAdminManager().hasAlertsEnabled(player.getUniqueId())) { sender.sendMessage(plugin.getConfigManager().getMessage("admin.alerts-enabled")); } else { sender.sendMessage(plugin.getConfigManager().getMessage("admin.alerts-disabled")); } } private void handleDebug(CommandSender sender) { if (!(sender instanceof Player player)) { sender.sendMessage(plugin.getConfigManager().getMessage("error.player-only")); return; } plugin.getAdminManager().toggleDebug(player.getUniqueId()); if (plugin.getAdminManager().hasDebugEnabled(player.getUniqueId())) { sender.sendMessage(plugin.getConfigManager().getMessage("admin.debug-enabled")); } else { sender.sendMessage(plugin.getConfigManager().getMessage("admin.debug-disabled")); } } private void handleCache(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage("§cUsage: /acca cache "); return; } String action = args[1].toLowerCase(); switch (action) { case "clear" -> { plugin.getCacheManager().invalidateAll(); sender.sendMessage(plugin.getConfigManager().getMessage("admin.cache-cleared")); } case "stats" -> { var trustStats = plugin.getCacheManager().getTrustScoreCacheStats(); var punishmentStats = plugin.getCacheManager().getPunishmentCacheStats(); double trustHitRate = trustStats.hitRate() * 100; double punishmentHitRate = punishmentStats.hitRate() * 100; sender.sendMessage(plugin.getConfigManager().getMessage("admin.cache-stats") .replace("{trust_hit_rate}", String.format("%.2f", trustHitRate)) .replace("{punishment_hit_rate}", String.format("%.2f", punishmentHitRate))); } default -> sender.sendMessage("§cInvalid action. Use: clear or stats"); } } private void handleApi(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage("§cUsage: /acca api "); return; } String action = args[1].toLowerCase(); switch (action) { case "status" -> { boolean healthy = plugin.getDatabaseManager().isHealthy(); String status = healthy ? "§aOnline" : "§cOffline"; sender.sendMessage(plugin.getConfigManager().getMessage("admin.api-status") .replace("{status}", status) .replace("{success_rate}", String.format("%.2f", plugin.getMetricsCollector().getAiSuccessRate())) .replace("{avg_response}", String.valueOf(plugin.getMetricsCollector().getAvgAiResponseTime().get()))); } case "test" -> { sender.sendMessage(plugin.getConfigManager().getMessage("admin.api-test")); long startTime = System.currentTimeMillis(); plugin.getAiManager().analyzeMessage( sender instanceof Player ? (Player) sender : null, "This is a test message", null ).thenAccept(analysis -> { long responseTime = System.currentTimeMillis() - startTime; if (analysis != null) { sender.sendMessage(plugin.getConfigManager().getMessage("admin.api-test-success") .replace("{time}", String.valueOf(responseTime))); } else { sender.sendMessage(plugin.getConfigManager().getMessage("admin.api-test-failed") .replace("{error}", "No response")); } }); } default -> sender.sendMessage("§cInvalid action. Use: status or test"); } } private void handleExport(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage("§cUsage: /acca export "); return; } String type = args[1].toLowerCase(); sender.sendMessage(plugin.getConfigManager().getMessage("admin.export-started")); plugin.getExecutorService().submit(() -> { try { File exportDir = new File(plugin.getDataFolder(), "exports"); exportDir.mkdirs(); String filename = type + "_" + System.currentTimeMillis() + ".csv"; File exportFile = new File(exportDir, filename); try (FileWriter writer = new FileWriter(exportFile)) { if (type.equals("logs")) { exportLogs(writer); } else if (type.equals("stats")) { exportStats(writer); } } sender.sendMessage(plugin.getConfigManager().getMessage("admin.export-complete") .replace("{file}", exportFile.getName())); } catch (IOException e) { sender.sendMessage(plugin.getConfigManager().getMessage("admin.export-failed") .replace("{error}", e.getMessage())); } }); } private void exportLogs(FileWriter writer) throws IOException { writer.write("ID,UUID,Player,Type,Reason,Rule,Duration,Confidence,Timestamp\n"); List records = plugin.getLogManager().getRecentPunishments(1000); for (PunishmentRecord record : records) { writer.write(String.format("%d,%s,%s,%s,%s,%s,%d,%.2f,%d\n", record.getId(), record.getPlayerUuid(), record.getPlayerName(), record.getPunishmentType(), record.getReason().replace(",", ";"), record.getRuleViolated(), record.getDuration(), record.getConfidence(), record.getTimestamp())); } } private void exportStats(FileWriter writer) throws IOException { writer.write("Metric,Value\n"); writer.write("Total Messages," + plugin.getMetricsCollector().getTotalMessagesProcessed().sum() + "\n"); writer.write("Total Violations," + plugin.getMetricsCollector().getTotalViolationsDetected().sum() + "\n"); writer.write("Violation Rate," + plugin.getMetricsCollector().getViolationRate() + "%\n"); writer.write("Warnings Issued," + plugin.getMetricsCollector().getTotalWarningsIssued().sum() + "\n"); writer.write("Mutes Applied," + plugin.getMetricsCollector().getTotalMutesApplied().sum() + "\n"); writer.write("Bans Applied," + plugin.getMetricsCollector().getTotalBansApplied().sum() + "\n"); writer.write("AI Success Rate," + plugin.getMetricsCollector().getAiSuccessRate() + "%\n"); writer.write("Avg AI Response," + plugin.getMetricsCollector().getAvgAiResponseTime().get() + "ms\n"); writer.write("Cache Hit Rate," + plugin.getMetricsCollector().getCacheHitRate() + "%\n"); } private void handleTest(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage("§cUsage: /acca test "); return; } String message = String.join(" ", Arrays.copyOfRange(args, 1, args.length)); sender.sendMessage("§7Testing message: §f" + message); plugin.getAiManager().analyzeMessage( sender instanceof Player ? (Player) sender : null, message, null ).thenAccept(analysis -> { sender.sendMessage("§7§m----------§r §bAI Analysis Result §7§m----------"); sender.sendMessage("§7Violation: " + (analysis.isViolation() ? "§cYes" : "§aNo")); sender.sendMessage("§7Rule: §f" + analysis.getRule()); sender.sendMessage(String.format("§7Confidence: §f%.0f%%", analysis.getConfidence() * 100)); sender.sendMessage("§7Reason: §f" + analysis.getReason()); sender.sendMessage("§7Severity: §f" + analysis.getSeverity()); }); } private void handleReload(CommandSender sender, String[] args) { if (args.length < 2) { plugin.reload(); sender.sendMessage(plugin.getConfigManager().getMessage("admin.reload-success")); return; } String type = args[1].toLowerCase(); switch (type) { case "config" -> { plugin.reloadConfig(); sender.sendMessage("§aConfig reloaded!"); } case "rules" -> { plugin.getKnowledgeBaseManager().reload(); sender.sendMessage("§aRules reloaded!"); } case "messages" -> { plugin.getConfigManager().reload(); sender.sendMessage("§aMessages reloaded!"); } default -> { plugin.reload(); sender.sendMessage(plugin.getConfigManager().getMessage("admin.reload-success")); } } } private long parseDuration(String duration) { try { long multiplier = 1; String value = duration; if (duration.endsWith("s")) { multiplier = 1000; value = duration.substring(0, duration.length() - 1); } else if (duration.endsWith("m")) { multiplier = 60 * 1000; value = duration.substring(0, duration.length() - 1); } else if (duration.endsWith("h")) { multiplier = 60 * 60 * 1000; value = duration.substring(0, duration.length() - 1); } else if (duration.endsWith("d")) { multiplier = 24 * 60 * 60 * 1000; value = duration.substring(0, duration.length() - 1); } return Long.parseLong(value) * multiplier; } catch (NumberFormatException e) { return 0; } } private String formatDuration(long millis) { long seconds = millis / 1000; long minutes = seconds / 60; long hours = minutes / 60; long days = hours / 24; if (days > 0) { return days + " day" + (days > 1 ? "s" : ""); } else if (hours > 0) { return hours + " hour" + (hours > 1 ? "s" : ""); } else if (minutes > 0) { return minutes + " minute" + (minutes > 1 ? "s" : ""); } else { return seconds + " second" + (seconds > 1 ? "s" : ""); } } private String formatTime(long millis) { long seconds = millis / 1000; long minutes = seconds / 60; long hours = minutes / 60; long days = hours / 24; if (days > 0) return days + "d"; if (hours > 0) return hours + "h"; if (minutes > 0) return minutes + "m"; return seconds + "s"; } private String formatUptime(long millis) { long seconds = millis / 1000; long minutes = seconds / 60; long hours = minutes / 60; long days = hours / 24; return String.format("%dd %dh %dm", days, hours % 24, minutes % 60); } @Override public List onTabComplete(CommandSender sender, Command command, String alias, String[] args) { if (!sender.hasPermission("acchat.admin")) { return new ArrayList<>(); } if (args.length == 1) { return Arrays.asList("stats", "logs", "trust", "whitelist", "blacklist", "mute", "kick", "ban", "pardon", "appeal", "alerts", "debug", "cache", "api", "export", "test", "reload") .stream() .filter(s -> s.startsWith(args[0].toLowerCase())) .collect(Collectors.toList()); } if (args.length == 2) { return switch (args[0].toLowerCase()) { case "logs", "trust", "mute", "kick", "ban", "pardon" -> Bukkit.getOnlinePlayers().stream() .map(Player::getName) .filter(s -> s.toLowerCase().startsWith(args[1].toLowerCase())) .collect(Collectors.toList()); case "whitelist", "blacklist" -> Arrays.asList("add", "remove", "list").stream() .filter(s -> s.startsWith(args[1].toLowerCase())) .collect(Collectors.toList()); case "appeal" -> Arrays.asList("accept", "deny", "list").stream() .filter(s -> s.startsWith(args[1].toLowerCase())) .collect(Collectors.toList()); case "cache" -> Arrays.asList("clear", "stats").stream() .filter(s -> s.startsWith(args[1].toLowerCase())) .collect(Collectors.toList()); case "api" -> Arrays.asList("status", "test").stream() .filter(s -> s.startsWith(args[1].toLowerCase())) .collect(Collectors.toList()); case "export" -> Arrays.asList("logs", "stats").stream() .filter(s -> s.startsWith(args[1].toLowerCase())) .collect(Collectors.toList()); case "reload" -> Arrays.asList("config", "rules", "messages").stream() .filter(s -> s.startsWith(args[1].toLowerCase())) .collect(Collectors.toList()); default -> new ArrayList<>(); }; } if (args.length == 3) { return switch (args[0].toLowerCase()) { case "trust" -> Arrays.asList("set", "add", "remove").stream() .filter(s -> s.startsWith(args[2].toLowerCase())) .collect(Collectors.toList()); case "whitelist", "blacklist" -> { if (args[1].equalsIgnoreCase("add") || args[1].equalsIgnoreCase("remove")) { yield Bukkit.getOnlinePlayers().stream() .map(Player::getName) .filter(s -> s.toLowerCase().startsWith(args[2].toLowerCase())) .collect(Collectors.toList()); } yield new ArrayList<>(); } case "mute", "ban" -> Arrays.asList("10m", "30m", "1h", "6h", "1d", "7d", "permanent").stream() .filter(s -> s.startsWith(args[2].toLowerCase())) .collect(Collectors.toList()); default -> new ArrayList<>(); }; } return new ArrayList<>(); } }