package com.example.containerscan.command; import com.example.containerscan.ContainerScanPlugin; import com.example.containerscan.export.ExportFormatter; import com.example.containerscan.model.ScanProgress; import com.example.containerscan.model.ScanResult; import com.example.containerscan.scan.ScanManager; import com.example.containerscan.scan.ScanState; import com.example.containerscan.util.MessageUtil; import org.bukkit.Bukkit; import org.bukkit.World; import org.bukkit.command.Command; import org.bukkit.command.CommandExecutor; import org.bukkit.command.CommandSender; import org.bukkit.command.TabCompleter; import java.io.File; import java.io.IOException; import java.text.SimpleDateFormat; import java.util.*; public class CommandHandler implements CommandExecutor, TabCompleter { private static final SimpleDateFormat EXPORT_DATE = new SimpleDateFormat("yyyyMMdd-HHmmss"); private final ContainerScanPlugin plugin; private final ScanManager scanManager; private final ExportFormatter exportFormatter; public CommandHandler(ContainerScanPlugin plugin) { this.plugin = plugin; this.scanManager = plugin.getScanManager(); this.exportFormatter = new ExportFormatter(); } @Override public boolean onCommand(CommandSender sender, Command command, String label, String[] args) { if (!sender.hasPermission("containerscan.use")) { send(sender, "&cYou do not have permission to use ContainerScan."); return true; } if (args.length == 0) { sendHelp(sender); return true; } switch (args[0].toLowerCase()) { case "start" -> handleStart(sender, args); case "stop" -> handleStop(sender); case "pause" -> handlePause(sender); case "resume" -> handleResume(sender); case "status" -> handleStatus(sender); case "findings" -> handleFindings(sender, args); case "clearfindings"-> handleClearFindings(sender); case "reload" -> handleReload(sender); case "export" -> handleExport(sender, args); case "scanloaded" -> handleScanLoaded(sender, args); case "scanchunk" -> handleScanChunk(sender, args); case "help" -> sendHelp(sender); default -> send(sender, "&cUnknown subcommand. Use &e/cs help &cfor usage."); } return true; } private void handleStart(CommandSender sender, String[] args) { if (!sender.hasPermission("containerscan.admin")) { noPermission(sender); return; } if (args.length < 2) { send(sender, "&cUsage: &e/cs start "); return; } World world = Bukkit.getWorld(args[1]); if (world == null) { send(sender, "&cWorld &e" + args[1] + " &cnot found."); return; } if (scanManager.getState() == ScanState.RUNNING || scanManager.getState() == ScanState.PAUSED) { send(sender, "&cA scan is already active. Use &e/cs stop &cfirst."); return; } if (!plugin.getConfigManager().isWorldAllowed(world.getName())) { send(sender, "&cWorld &e" + world.getName() + " &cis excluded from scanning."); return; } boolean started = scanManager.start(world, sender); if (started) { send(sender, "&aStarted scanning &e" + world.getName() + "&a. Use &e/cs status &afor progress."); } else { send(sender, "&cFailed to start scan. No region files found, or world is excluded."); } } private void handleStop(CommandSender sender) { if (!sender.hasPermission("containerscan.admin")) { noPermission(sender); return; } if (scanManager.getState() == ScanState.IDLE) { send(sender, "&cNo active scan to stop."); return; } scanManager.stop(); send(sender, "&aScan stopped."); } private void handlePause(CommandSender sender) { if (!sender.hasPermission("containerscan.admin")) { noPermission(sender); return; } if (!scanManager.pause()) { send(sender, "&cScan is not running or is already paused."); return; } send(sender, "&eScan paused. Use &a/cs resume &eto continue."); } private void handleResume(CommandSender sender) { if (!sender.hasPermission("containerscan.admin")) { noPermission(sender); return; } if (!scanManager.resume()) { send(sender, "&cScan is not paused."); return; } send(sender, "&aScan resumed."); } private void handleStatus(CommandSender sender) { if (!sender.hasPermission("containerscan.view")) { noPermission(sender); return; } ScanProgress p = scanManager.getProgress(); send(sender, "&8&m----------&r &4ContainerScan Status &8&m----------"); send(sender, "&7State: &e" + p.state().name()); if (p.state() != ScanState.IDLE) { send(sender, "&7World: &e" + p.worldName()); send(sender, "&7Progress: &e" + MessageUtil.formatProgress(p.scannedChunks(), p.totalChunks(), p.getPercent())); send(sender, " " + MessageUtil.color(MessageUtil.bar(p.getPercent(), 30))); send(sender, "&7Speed: &e" + String.format("%.1f", p.getChunksPerSecond()) + " &7slots/s"); send(sender, "&7Elapsed: &e" + MessageUtil.formatSeconds(p.getElapsedSeconds())); long eta = p.getEtaSeconds(); send(sender, "&7ETA: &e" + (eta < 0 ? "calculating..." : MessageUtil.formatSeconds(eta))); } send(sender, "&7Findings: &e" + p.findingsCount()); send(sender, "&8&m------------------------------------------"); } private void handleFindings(CommandSender sender, String[] args) { if (!sender.hasPermission("containerscan.view")) { noPermission(sender); return; } int page = 1; if (args.length >= 2) { try { page = Integer.parseInt(args[1]); } catch (NumberFormatException e) { send(sender, "&cInvalid page number."); return; } } int totalPages = scanManager.getTotalPages(); if (page < 1) page = 1; if (page > totalPages) { send(sender, "&cPage " + page + " does not exist. Total: &e" + totalPages); return; } List pageItems = scanManager.getPage(page); int startNum = (page - 1) * scanManager.getPageSize() + 1; send(sender, "&8&m-------&r &4Findings &7(Page " + page + "/" + totalPages + ") &8&m-------"); if (pageItems.isEmpty()) { send(sender, "&7No findings recorded yet."); } else { for (int i = 0; i < pageItems.size(); i++) { ScanResult r = pageItems.get(i); String depthTag = r.depth() > 0 ? " &8[depth=" + r.depth() + "]" : ""; String nameTag = r.itemDisplayName().isBlank() ? "" : " &7\"" + r.itemDisplayName() + "&7\""; send(sender, "&e" + (startNum + i) + ". &c" + r.itemMaterial() + " &7x" + r.amount() + nameTag + " &8in &7" + r.containerType() + " &8@ &7" + r.world() + " (" + r.x() + "," + r.y() + "," + r.z() + ")" + depthTag); if (!r.path().isEmpty()) { send(sender, " &8Path: &7" + String.join(" &8> &7", r.path())); } } } send(sender, "&8&m----------------------------------------"); if (totalPages > 1) { send(sender, "&7Navigate: &e/cs findings [1-" + totalPages + "]"); } } private void handleClearFindings(CommandSender sender) { if (!sender.hasPermission("containerscan.admin")) { noPermission(sender); return; } long count = scanManager.getFindingsCount(); scanManager.clearFindings(); send(sender, "&aCleared &e" + count + " &afindings from memory."); } private void handleReload(CommandSender sender) { if (!sender.hasPermission("containerscan.admin")) { noPermission(sender); return; } if (scanManager.getState() != ScanState.IDLE) { send(sender, "&cStop the scan before reloading config."); return; } plugin.getConfigManager().load(); send(sender, "&aConfiguration reloaded successfully."); } private void handleExport(CommandSender sender, String[] args) { if (!sender.hasPermission("containerscan.admin")) { noPermission(sender); return; } if (args.length < 2) { send(sender, "&cUsage: &e/cs export "); return; } String format = args[1].toLowerCase(); if (!format.equals("csv") && !format.equals("json")) { send(sender, "&cUnknown format. Use &ecss &cor &ejson&c."); return; } List all = scanManager.getFindings(); if (all.isEmpty()) { send(sender, "&eNo findings to export."); return; } File exportDir = new File(plugin.getDataFolder(), plugin.getConfigManager().getExportDirectory()); if (!exportDir.exists()) exportDir.mkdirs(); String ts = EXPORT_DATE.format(new Date()); File exportFile = new File(exportDir, "findings-" + ts + "." + format); try { if (format.equals("csv")) { exportFormatter.exportCsv(all, exportFile); } else { exportFormatter.exportJson(all, exportFile, plugin.getConfigManager().isPrettyJson()); } send(sender, "&aExported &e" + all.size() + " &afindings to &e" + exportFile.getName() + "&a."); } catch (IOException e) { send(sender, "&cExport failed: " + e.getMessage()); plugin.getLogger().severe("Export error: " + e.getMessage()); } } private void handleScanLoaded(CommandSender sender, String[] args) { if (!sender.hasPermission("containerscan.admin")) { noPermission(sender); return; } if (args.length < 2) { send(sender, "&cUsage: &e/cs scanloaded "); return; } World world = Bukkit.getWorld(args[1]); if (world == null) { send(sender, "&cWorld &e" + args[1] + " &cnot found."); return; } if (scanManager.getState() == ScanState.RUNNING || scanManager.getState() == ScanState.PAUSED) { send(sender, "&cA full scan is already running."); return; } if (!plugin.getConfigManager().isWorldAllowed(world.getName())) { send(sender, "&cWorld &e" + world.getName() + " &cis excluded from scanning."); return; } send(sender, "&eScanning &a" + world.getLoadedChunks().length + " &ecurrently loaded chunks in &a" + world.getName() + "&e..."); scanManager.startForLoadedChunks(world, sender); } private void handleScanChunk(CommandSender sender, String[] args) { if (!sender.hasPermission("containerscan.admin")) { noPermission(sender); return; } if (args.length < 4) { send(sender, "&cUsage: &e/cs scanchunk "); return; } World world = Bukkit.getWorld(args[1]); if (world == null) { send(sender, "&cWorld &e" + args[1] + " &cnot found."); return; } try { int cx = Integer.parseInt(args[2]); int cz = Integer.parseInt(args[3]); List results = scanManager.scanSingleChunk(world, cx, cz); send(sender, "&aChunk [&e" + cx + "&a, &e" + cz + "&a] scanned. Found &e" + results.size() + "&a suspicious items."); int displayed = Math.min(results.size(), 10); for (int i = 0; i < displayed; i++) { ScanResult r = results.get(i); send(sender, " &e" + (i + 1) + ". &c" + r.itemMaterial() + " &7x" + r.amount() + " in " + r.containerType() + " at (" + r.x() + "," + r.y() + "," + r.z() + ")"); } if (results.size() > 10) { send(sender, " &7...and &e" + (results.size() - 10) + " &7more. Use &e/cs findings&7."); } } catch (NumberFormatException e) { send(sender, "&cInvalid chunk coordinates. Must be integers."); } } private void sendHelp(CommandSender sender) { send(sender, "&8&m-------&r &4ContainerScan Commands &8&m-------"); send(sender, "&e/cs start &7- Begin world scan"); send(sender, "&e/cs stop &7- Abort current scan"); send(sender, "&e/cs pause &7- Pause current scan"); send(sender, "&e/cs resume &7- Resume paused scan"); send(sender, "&e/cs status &7- View progress & ETA"); send(sender, "&e/cs findings [page] &7- Browse findings"); send(sender, "&e/cs clearfindings &7- Clear findings from memory"); send(sender, "&e/cs reload &7- Reload config.yml"); send(sender, "&e/cs export &7- Export findings to file"); send(sender, "&e/cs scanloaded &7- Scan loaded chunks only"); send(sender, "&e/cs scanchunk &7- Scan one chunk"); send(sender, "&8&m-----------------------------------------"); } private void send(CommandSender sender, String message) { sender.sendMessage(MessageUtil.color(plugin.getConfigManager().getMessagePrefix() + message)); } private void noPermission(CommandSender sender) { send(sender, "&cYou do not have permission for this command."); } @Override public List onTabComplete(CommandSender sender, Command command, String alias, String[] args) { if (!sender.hasPermission("containerscan.use")) return Collections.emptyList(); if (args.length == 1) { return filter(Arrays.asList( "start", "stop", "pause", "resume", "status", "findings", "clearfindings", "reload", "export", "scanloaded", "scanchunk", "help" ), args[0]); } if (args.length == 2) { String sub = args[0].toLowerCase(); if (sub.equals("start") || sub.equals("scanloaded") || sub.equals("scanchunk")) { List worlds = new ArrayList<>(); for (World w : Bukkit.getWorlds()) worlds.add(w.getName()); return filter(worlds, args[1]); } if (sub.equals("export")) { return filter(Arrays.asList("csv", "json"), args[1]); } } if (args.length == 3 && args[0].equalsIgnoreCase("scanchunk")) { return Collections.singletonList(""); } if (args.length == 4 && args[0].equalsIgnoreCase("scanchunk")) { return Collections.singletonList(""); } return Collections.emptyList(); } private List filter(List options, String input) { List result = new ArrayList<>(); String lower = input.toLowerCase(); for (String opt : options) { if (opt.toLowerCase().startsWith(lower)) result.add(opt); } return result; } }