Function checkPortInUse

ssh/ssh.ts:60–124

(port: number)

    try {
      await execFileAsync("systemctl", ["is-active", "--quiet", serviceName]);
      return true;
    } catch { }
  }
  try {
    await execFileAsync("pgrep", ["sshd"]);
    return true;
  } catch {
    return false;
  }
}

// HTML转义函数
// 验证路径安全性
function validatePath(pathStr: string): boolean {
  if (!pathStr || typeof pathStr !== "string") return false;
  // 检查危险字符
  const dangerousChars = /[;&|`$(){}[\]<>'"\\]/;
  if (dangerousChars.test(pathStr)) return false;
  // 检查路径遍历
  if (pathStr.includes("../") || pathStr.includes("..\\")) return false;
  return true;
}

// 端口验证函数
const validatePort = (port: string): number | null => {
  const portNum = parseInt(port, 10);
  if (isNaN(portNum) || portNum < 1 || portNum > 65535) {
    return null;
  }
  return portNum;
};

// 检查端口是否被占用
async function checkPortInUse(port: number): Promise<{ inUse: boolean; processInfo?: string }> {
  const parseListeners = async (
    command: string,
    args: string[],
  ): Promise<{ inUse: boolean; processInfo?: string }> => {
    const { stdout } = await execFileAsync(command, args);
    const portPattern = new RegExp(`:${port}(?:\\s|$)`);
    const lines = stdout.split("\n").filter((line) => portPattern.test(line));
    if (lines.length === 0) return { inUse: false };

    const processInfos = await Promise.all(lines.map(async (line) => {
      const parts = line.trim().split(/\s+/);
      const protocol = parts[0] || "tcp";
      const address = parts.find((part) => portPattern.test(part)) || `:${port}`;
      const pid = line.match(/pid=(\d+)/)?.[1] || line.match(/\s(\d+)\/\S+/)?.[1];
      let processName = "未知进程";
      if (pid) {
        try {
          const { stdout: nameOutput } = await execFileAsync("ps", ["-p", pid, "-o", "comm="]);
          processName = nameOutput.trim() || processName;
        } catch { }
      }
      return `${protocol} ${address} (${processName})`;
    }));
    return { inUse: true, processInfo: processInfos.join(", ") };