package com.serverterminal.commands import com.serverterminal.ServerTerminal import net.kyori.adventure.text.Component import net.kyori.adventure.text.format.NamedTextColor import org.bukkit.command.Command import org.bukkit.command.CommandExecutor import org.bukkit.command.CommandSender import org.bukkit.entity.Player import java.io.BufferedReader import java.io.File import java.io.InputStreamReader import java.lang.management.ManagementFactory import java.text.SimpleDateFormat import java.util.Date import java.util.concurrent.TimeUnit class TerminalCommand(private val plugin: ServerTerminal) : CommandExecutor { override fun onCommand(sender: CommandSender, command: Command, label: String, args: Array): Boolean { if (!sender.hasPermission("serverterminal.use")) { sender.sendMessage(Component.text("No permission.", NamedTextColor.RED)) return true } if (args.isEmpty()) { sender.sendMessage(Component.text("Usage: /terminal [args]", NamedTextColor.RED)) return true } val subCommand = args[0].lowercase() val arguments = args.drop(1) val uuid = if (sender is Player) sender.uniqueId.toString() else "CONSOLE" // Run async to avoid blocking main thread plugin.server.scheduler.runTaskAsynchronously(plugin, Runnable { try { when (subCommand) { "exec" -> handleExec(sender, arguments, uuid) "ls" -> handleLs(sender, arguments, uuid) "cd" -> handleCd(sender, arguments, uuid) "cat" -> handleCat(sender, arguments, uuid) "ps" -> handlePs(sender, arguments) "kill" -> handleKill(sender, arguments) "sysinfo" -> handleSysInfo(sender) else -> sender.sendMessage(Component.text("Unknown subcommand.", NamedTextColor.RED)) } } catch (e: Exception) { sender.sendMessage(Component.text("Error: ${e.message}", NamedTextColor.RED)) e.printStackTrace() } }) return true } private fun handleExec(sender: CommandSender, args: List, uuid: String) { if (args.isEmpty()) { sender.sendMessage(Component.text("Usage: /terminal exec ", NamedTextColor.RED)) return } val workingDir = plugin.getWorkingDir(uuid) val cmd = args.joinToString(" ") sender.sendMessage(Component.text("> $cmd", NamedTextColor.GRAY)) val processBuilder = ProcessBuilder() // Handle OS specific shell val os = System.getProperty("os.name").lowercase() if (os.contains("win")) { processBuilder.command("cmd.exe", "/c", cmd) } else { processBuilder.command("bash", "-c", cmd) } processBuilder.directory(workingDir) processBuilder.redirectErrorStream(true) val process = processBuilder.start() val reader = BufferedReader(InputStreamReader(process.inputStream)) var line: String? while (reader.readLine().also { line = it } != null) { sender.sendMessage(Component.text(line ?: "", NamedTextColor.GREEN)) } process.waitFor(10, TimeUnit.SECONDS) sender.sendMessage(Component.text("Exit code: ${process.exitValue()}", NamedTextColor.YELLOW)) } private fun handleLs(sender: CommandSender, args: List, uuid: String) { val currentDir = plugin.getWorkingDir(uuid) val targetDir = if (args.isNotEmpty()) { val path = args[0] if (path.startsWith("/") || (path.length > 1 && path[1] == ':')) { File(path) // Absolute path } else { File(currentDir, path) // Relative path } } else { currentDir } if (!targetDir.exists()) { sender.sendMessage(Component.text("Directory not found: ${targetDir.path}", NamedTextColor.RED)) return } sender.sendMessage(Component.text("Listing: ${targetDir.canonicalPath}", NamedTextColor.GOLD)) val files = targetDir.listFiles() if (files == null) { sender.sendMessage(Component.text("Could not list files (Access Denied?).", NamedTextColor.RED)) return } val dateFormat = SimpleDateFormat("yyyy-MM-dd HH:mm") sender.sendMessage(Component.text(String.format("%-4s %-16s %-10s %s", "Type", "Modified", "Size", "Name"), NamedTextColor.GRAY)) files.sortedWith(compareBy({ !it.isDirectory }, { it.name })).forEach { file -> val type = if (file.isDirectory) "DIR" else "FILE" val color = if (file.isDirectory) NamedTextColor.BLUE else NamedTextColor.WHITE val date = dateFormat.format(Date(file.lastModified())) val size = if (file.isDirectory) "-" else formatSize(file.length()) val line = String.format("%-4s %-16s %-10s %s", type, date, size, file.name) sender.sendMessage(Component.text(line, color)) } } private fun formatSize(bytes: Long): String { val kilo = 1024.0 val mega = kilo * kilo val giga = mega * kilo return when { bytes < kilo -> "$bytes B" bytes < mega -> String.format("%.1f KB", bytes / kilo) bytes < giga -> String.format("%.1f MB", bytes / mega) else -> String.format("%.1f GB", bytes / giga) } } private fun handleCd(sender: CommandSender, args: List, uuid: String) { if (args.isEmpty()) { sender.sendMessage(Component.text("Usage: /terminal cd ", NamedTextColor.RED)) return } val currentDir = plugin.getWorkingDir(uuid) val targetPath = args[0] val newDir = if (targetPath == "..") { currentDir.parentFile ?: currentDir } else if (targetPath.startsWith("/") || (targetPath.length > 1 && targetPath[1] == ':')) { File(targetPath) // Absolute path } else { File(currentDir, targetPath) // Relative path } if (newDir.exists() && newDir.isDirectory) { plugin.setWorkingDir(uuid, newDir.canonicalFile) sender.sendMessage(Component.text("Changed directory to: ${newDir.canonicalPath}", NamedTextColor.GREEN)) } else { sender.sendMessage(Component.text("Directory not found: ${newDir.path}", NamedTextColor.RED)) } } private fun handleCat(sender: CommandSender, args: List, uuid: String) { if (args.isEmpty()) { sender.sendMessage(Component.text("Usage: /terminal cat ", NamedTextColor.RED)) return } val currentDir = plugin.getWorkingDir(uuid) val file = File(currentDir, args[0]) if (!file.exists() || !file.isFile) { sender.sendMessage(Component.text("File not found.", NamedTextColor.RED)) return } sender.sendMessage(Component.text("--- ${file.name} ---", NamedTextColor.GOLD)) file.forEachLine { line -> sender.sendMessage(Component.text(line, NamedTextColor.WHITE)) } sender.sendMessage(Component.text("--- End of file ---", NamedTextColor.GOLD)) } private fun handlePs(sender: CommandSender, args: List) { val filter = if (args.isNotEmpty()) args[0].lowercase() else null sender.sendMessage(Component.text("Running Processes${if (filter != null) " (Filter: $filter)" else ""}:", NamedTextColor.GOLD)) val limit = if (filter == null) 20L else 100L var count = 0 ProcessHandle.allProcesses() .filter { it.info().command().isPresent } .filter { filter == null || it.info().command().get().lowercase().contains(filter) } .limit(limit) .forEach { process -> val info = process.info() val pid = process.pid() val cmd = info.command().get() val user = info.user().orElse("?") sender.sendMessage(Component.text("[$pid] ($user) $cmd", NamedTextColor.WHITE)) count++ } if (count == 0) { sender.sendMessage(Component.text("No matching processes found.", NamedTextColor.YELLOW)) } else if (count >= limit) { sender.sendMessage(Component.text("... output truncated. Use filter to see more.", NamedTextColor.YELLOW)) } } private fun handleKill(sender: CommandSender, args: List) { if (args.isEmpty()) { sender.sendMessage(Component.text("Usage: /terminal kill ", NamedTextColor.RED)) return } val pid = args[0].toLongOrNull() if (pid == null) { sender.sendMessage(Component.text("Invalid PID.", NamedTextColor.RED)) return } val process = ProcessHandle.of(pid) if (process.isPresent) { if (process.get().destroy()) { sender.sendMessage(Component.text("Process $pid terminated.", NamedTextColor.GREEN)) } else { sender.sendMessage(Component.text("Failed to terminate process $pid.", NamedTextColor.RED)) } } else { sender.sendMessage(Component.text("Process not found.", NamedTextColor.RED)) } } private fun handleSysInfo(sender: CommandSender) { val os = ManagementFactory.getOperatingSystemMXBean() val runtime = Runtime.getRuntime() sender.sendMessage(Component.text("=== System Info ===", NamedTextColor.GOLD)) sender.sendMessage(Component.text("OS: ${os.name} ${os.version} (${os.arch})", NamedTextColor.WHITE)) sender.sendMessage(Component.text("Cores: ${os.availableProcessors}", NamedTextColor.WHITE)) sender.sendMessage(Component.text("Load Avg: ${os.systemLoadAverage}", NamedTextColor.WHITE)) val maxMem = runtime.maxMemory() / 1024 / 1024 val totalMem = runtime.totalMemory() / 1024 / 1024 val freeMem = runtime.freeMemory() / 1024 / 1024 val usedMem = totalMem - freeMem sender.sendMessage(Component.text("Memory: ${usedMem}MB / ${maxMem}MB (Allocated: ${totalMem}MB)", NamedTextColor.WHITE)) } }