Method create

packages/kaos/src/ssh.ts:483–543

* Factory method to create an SSHKaos instance. * Establishes the SSH connection and SFTP session.

(options: SSHKaosOptions)

   * Establishes the SSH connection and SFTP session.
   */
  static async create(options: SSHKaosOptions): Promise<SSHKaos> {
    // Start from extraOptions (advanced ssh2 options) so our managed fields
    // below take precedence.
    const config: ConnectConfig = {
      ...options.extraOptions,
      host: options.host,
      port: options.port ?? 22,
      username: options.username,
    };

    if (options.password !== undefined) {
      config.password = options.password;
    }

    // Build private keys from keyContents and keyPaths
    const privateKeys: (Buffer | string)[] = [];
    if (options.keyContents) {
      for (const content of options.keyContents) {
        privateKeys.push(content);
      }
    }
    if (options.keyPaths) {
      const keyPromises = options.keyPaths.map((keyPath) => readFile(keyPath, 'utf-8'));
      const keyData = await Promise.all(keyPromises);
      for (const key of keyData) {
        privateKeys.push(key);
      }
    }
    if (privateKeys.length > 0) {
      const authHandler = buildAuthHandler(options.username, privateKeys, options.password);
      if (authHandler !== undefined) {
        config.authHandler = authHandler;
      }
    }

    // Disable host key verification (like asyncssh known_hosts=None)
    config.hostVerifier = () => true;

    const client = await connectClient(config);
    try {
      const sftp = await getSftp(client);

      // Determine home and cwd
      const home = await sftpRealpath(sftp, '.');
      let cwd: string;
      if (options.cwd === undefined) {
        cwd = home;
      } else {
        cwd = await sftpRealpath(sftp, options.cwd);
        const attrs = await sftpStat(sftp, cwd);
        if (!attrs.isDirectory()) {
          throw new KaosValueError(`${cwd} is not a directory`);
        }
      }

      return new SSHKaos(client, sftp, home, cwd);
    } catch (error) {
      client.end();