package com.kodari.intellidupe.commands; import com.kodari.intellidupe.IntelliDupe; import com.kodari.intellidupe.config.OperationMode; import com.kodari.intellidupe.containment.ContainmentLevel; import com.kodari.intellidupe.inventory.impl.DashboardGUI; import com.kodari.intellidupe.inventory.impl.PlayerInspectGUI; import com.kodari.intellidupe.inventory.impl.RollbackPreviewGUI; import com.kodari.intellidupe.player.PlayerProfile; import org.bukkit.Bukkit; import org.bukkit.ChatColor; import org.bukkit.OfflinePlayer; 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.*; import java.util.stream.Collectors; public class AntiDupeCommand implements CommandExecutor, TabCompleter { private final IntelliDupe plugin; private final Map pendingRollbackConfirm = new HashMap<>(); public AntiDupeCommand(IntelliDupe plugin) { this.plugin = plugin; } @Override public boolean onCommand(CommandSender sender, Command command, String label, String[] args) { if (!sender.hasPermission("intellidupe.admin")) { sender.sendMessage(ChatColor.RED + "You do not have permission to use this command."); return true; } if (args.length == 0) { sendHelp(sender); return true; } switch (args[0].toLowerCase()) { case "status": return cmdStatus(sender); case "mode": return cmdMode(sender, args); case "dashboard": return cmdDashboard(sender); case "inspect": return cmdInspect(sender, args); case "rollback": return cmdRollback(sender, args); case "trust": return cmdTrust(sender, args); case "untrust": return cmdUntrust(sender, args); case "purge": return cmdPurge(sender, args); case "reload": return cmdReload(sender); case "simulate": return cmdSimulate(sender); default: sendHelp(sender); return true; } } private boolean cmdStatus(CommandSender sender) { OperationMode mode = plugin.getOperationMode(); double tps = plugin.getServerTPS(); long risky = plugin.getProfileManager().getAllProfiles().stream() .filter(p -> p.getRiskScore() >= 30).count(); sender.sendMessage(ChatColor.DARK_RED + "━━━ IntelliDupe Status ━━━"); sender.sendMessage(ChatColor.GRAY + "Mode: " + modeColor(mode) + mode.name()); sender.sendMessage(ChatColor.GRAY + "TPS: " + tpsColor(tps) + String.format("%.1f", tps)); sender.sendMessage(ChatColor.GRAY + "Profiles loaded: " + ChatColor.WHITE + plugin.getProfileManager().getAllProfiles().size()); sender.sendMessage(ChatColor.GRAY + "High-risk players: " + ChatColor.RED + risky); sender.sendMessage(ChatColor.GRAY + "Confidence threshold: " + ChatColor.WHITE + plugin.getConfigManager().getConfidenceThreshold() + "%"); return true; } private boolean cmdMode(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage(ChatColor.RED + "Usage: /intellidupe mode "); return true; } try { OperationMode mode = OperationMode.valueOf(args[1].toUpperCase()); plugin.setOperationMode(mode); sender.sendMessage(ChatColor.GREEN + "[IntelliDupe] Mode set to: " + mode.name()); } catch (IllegalArgumentException e) { sender.sendMessage(ChatColor.RED + "Invalid mode. Use: FULL, REDUCED, OBSERVER, EMERGENCY_OFF"); } return true; } private boolean cmdDashboard(CommandSender sender) { if (!(sender instanceof Player)) { sender.sendMessage(ChatColor.RED + "This command can only be used by players."); return true; } plugin.getGuiManager().openGUI(new DashboardGUI(plugin), (Player) sender); return true; } private boolean cmdInspect(CommandSender sender, String[] args) { if (!(sender instanceof Player)) { sender.sendMessage(ChatColor.RED + "This command can only be used by players."); return true; } if (args.length < 2) { sender.sendMessage(ChatColor.RED + "Usage: /intellidupe inspect "); return true; } UUID targetUuid = resolveUUID(args[1]); if (targetUuid == null) { sender.sendMessage(ChatColor.RED + "Player not found: " + args[1]); return true; } plugin.getGuiManager().openGUI(new PlayerInspectGUI(plugin, targetUuid), (Player) sender); return true; } private boolean cmdRollback(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage(ChatColor.RED + "Usage: /intellidupe rollback [preview|execute|cancel]"); return true; } UUID targetUuid = resolveUUID(args[1]); if (targetUuid == null) { sender.sendMessage(ChatColor.RED + "Player not found: " + args[1]); return true; } String sub = args.length >= 3 ? args[2].toLowerCase() : "preview"; if (sub.equals("preview")) { if (!(sender instanceof Player)) { sender.sendMessage(ChatColor.RED + "Preview requires a player sender."); return true; } Player admin = (Player) sender; plugin.getGuiManager().openGUI(new RollbackPreviewGUI(plugin, admin.getUniqueId(), targetUuid), admin); } else if (sub.equals("execute")) { if (!(sender instanceof Player)) { sender.sendMessage(ChatColor.RED + "Execute requires a player sender."); return true; } Player admin = (Player) sender; if (plugin.getRollbackManager().getPending(targetUuid) == null) { plugin.getRollbackManager().createRollback(targetUuid, "Admin rollback via command"); } boolean result = plugin.getRollbackManager().confirm(admin.getUniqueId(), targetUuid); if (result) { sender.sendMessage(ChatColor.GREEN + "[IntelliDupe] Rollback confirmed."); } else { sender.sendMessage(ChatColor.YELLOW + "[IntelliDupe] Dual confirmation required. Run again to execute."); } } else if (sub.equals("cancel")) { plugin.getRollbackManager().cancel(targetUuid); sender.sendMessage(ChatColor.GRAY + "[IntelliDupe] Rollback cancelled."); } return true; } private boolean cmdTrust(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage(ChatColor.RED + "Usage: /intellidupe trust "); return true; } plugin.getTrustedSourceRegistry().trust(args[1]); sender.sendMessage(ChatColor.GREEN + "[IntelliDupe] Trusted plugin added: " + args[1]); return true; } private boolean cmdUntrust(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage(ChatColor.RED + "Usage: /intellidupe untrust "); return true; } plugin.getTrustedSourceRegistry().untrust(args[1]); sender.sendMessage(ChatColor.YELLOW + "[IntelliDupe] Removed trusted plugin: " + args[1]); return true; } private boolean cmdPurge(CommandSender sender, String[] args) { if (args.length < 2) { sender.sendMessage(ChatColor.RED + "Usage: /intellidupe purge "); return true; } UUID targetUuid = resolveUUID(args[1]); if (targetUuid == null) { sender.sendMessage(ChatColor.RED + "Player not found: " + args[1]); return true; } plugin.getContainmentManager().release(targetUuid); plugin.getLineageTracker().removePlayer(targetUuid); plugin.getProfileManager().removeProfile(targetUuid); plugin.getAuditLog().log(sender.getName(), "Profile purged for: " + args[1], targetUuid); sender.sendMessage(ChatColor.GREEN + "[IntelliDupe] Profile purged for " + args[1]); return true; } private boolean cmdReload(CommandSender sender) { plugin.getConfigManager().reload(); plugin.getTrustedSourceRegistry(); sender.sendMessage(ChatColor.GREEN + "[IntelliDupe] Configuration reloaded."); plugin.getAuditLog().log(sender.getName(), "Configuration reloaded", null); return true; } private boolean cmdSimulate(CommandSender sender) { if (!(sender instanceof Player)) { sender.sendMessage(ChatColor.RED + "Simulation requires a player sender."); return true; } Player admin = (Player) sender; sender.sendMessage(ChatColor.YELLOW + "[IntelliDupe] Running simulation on your profile..."); PlayerProfile profile = plugin.getProfileManager().getProfile(admin); // Simulate rapid drop-pickup cycles for (int i = 0; i < 12; i++) profile.recordDropPickupCycle(); for (int i = 0; i < 25; i++) profile.recordInventoryAction(); plugin.getServer().getScheduler().runTaskAsynchronously(plugin, () -> { com.kodari.intellidupe.tracking.InventorySnapshot snap = new com.kodari.intellidupe.tracking.InventorySnapshot(new org.bukkit.inventory.ItemStack[0]); com.kodari.intellidupe.detection.DetectionResult result = plugin.getDetectionEngine().analyze(admin, profile, snap, snap, false); plugin.getServer().getScheduler().runTask(plugin, () -> { admin.sendMessage(ChatColor.AQUA + "[Simulation] Confidence: " + result.getConfidence() + "% | Signals: " + result.getTriggeredSignals().size() + " | Actionable: " + result.isActionable()); // Reset profile after simulation profile.setRiskScore(0); profile.resetSuspiciousDelta(); }); }); return true; } @Override public List onTabComplete(CommandSender sender, Command command, String alias, String[] args) { if (!sender.hasPermission("intellidupe.admin")) return Collections.emptyList(); if (args.length == 1) { return filter(Arrays.asList("status", "mode", "dashboard", "inspect", "rollback", "trust", "untrust", "purge", "reload", "simulate"), args[0]); } if (args.length == 2) { switch (args[0].toLowerCase()) { case "mode": return filter(Arrays.asList("FULL", "REDUCED", "OBSERVER", "EMERGENCY_OFF"), args[1]); case "inspect": case "rollback": case "purge": return Bukkit.getOnlinePlayers().stream() .map(Player::getName) .filter(n -> n.toLowerCase().startsWith(args[1].toLowerCase())) .collect(Collectors.toList()); case "trust": case "untrust": return Bukkit.getPluginManager().getPlugins() == null ? Collections.emptyList() : Arrays.stream(Bukkit.getPluginManager().getPlugins()) .map(p -> p.getName()) .filter(n -> n.toLowerCase().startsWith(args[1].toLowerCase())) .collect(Collectors.toList()); } } if (args.length == 3 && args[0].equalsIgnoreCase("rollback")) { return filter(Arrays.asList("preview", "execute", "cancel"), args[2]); } return Collections.emptyList(); } private UUID resolveUUID(String name) { Player online = Bukkit.getPlayer(name); if (online != null) return online.getUniqueId(); OfflinePlayer offline = Bukkit.getOfflinePlayer(name); return offline.hasPlayedBefore() ? offline.getUniqueId() : null; } private List filter(List options, String prefix) { return options.stream() .filter(s -> s.toLowerCase().startsWith(prefix.toLowerCase())) .collect(Collectors.toList()); } private ChatColor modeColor(OperationMode mode) { switch (mode) { case FULL: return ChatColor.GREEN; case REDUCED: return ChatColor.YELLOW; case OBSERVER: return ChatColor.GOLD; default: return ChatColor.RED; } } private ChatColor tpsColor(double tps) { if (tps >= 18) return ChatColor.GREEN; if (tps >= 14) return ChatColor.YELLOW; return ChatColor.RED; } private void sendHelp(CommandSender sender) { sender.sendMessage(ChatColor.DARK_RED + "━━━ IntelliDupe Commands ━━━"); sender.sendMessage(ChatColor.GOLD + "/idupe status" + ChatColor.GRAY + " — Server & detection status"); sender.sendMessage(ChatColor.GOLD + "/idupe mode " + ChatColor.GRAY + " — Set operation mode"); sender.sendMessage(ChatColor.GOLD + "/idupe dashboard" + ChatColor.GRAY + " — Open admin dashboard GUI"); sender.sendMessage(ChatColor.GOLD + "/idupe inspect " + ChatColor.GRAY + " — Inspect a player's profile"); sender.sendMessage(ChatColor.GOLD + "/idupe rollback [preview|execute|cancel]" + ChatColor.GRAY + " — Rollback inventory"); sender.sendMessage(ChatColor.GOLD + "/idupe trust " + ChatColor.GRAY + " — Trust a plugin as safe item source"); sender.sendMessage(ChatColor.GOLD + "/idupe untrust " + ChatColor.GRAY + " — Remove trusted plugin"); sender.sendMessage(ChatColor.GOLD + "/idupe purge " + ChatColor.GRAY + " — Purge player profile data"); sender.sendMessage(ChatColor.GOLD + "/idupe reload" + ChatColor.GRAY + " — Reload configuration"); sender.sendMessage(ChatColor.GOLD + "/idupe simulate" + ChatColor.GRAY + " — Run detection simulation on yourself"); } }