Method connect

src/node/runtime/SSH2ConnectionPool.ts:431–663

(
    config: SSHConnectionConfig,
    timeoutMs: number,
    abortSignal?: AbortSignal
  )

  }

  private async connect(
    config: SSHConnectionConfig,
    timeoutMs: number,
    abortSignal?: AbortSignal
  ): Promise<SSH2ConnectionEntry> {
    const key = makeConnectionKey(config);
    try {
      const resolved = await resolveSSHConfig(config.host);
      const resolvedConfig: ResolvedSSHConfig = {
        ...resolved,
        port: config.port ?? resolved.port,
        identityFiles: config.identityFile
          ? [expandLocalPath(config.identityFile)]
          : resolved.identityFiles,
      };
      const agent = getAgentConfig();
      const baseIdentityFiles =
        resolvedConfig.identityFiles.length > 0 ? resolvedConfig.identityFiles : [];
      const fallbackIdentityFiles =
        baseIdentityFiles.length > 0
          ? baseIdentityFiles
          : DEFAULT_IDENTITY_FILES.map((file) => expandLocalPath(file));
      const username = resolvedConfig.user ?? getDefaultUsername();
      const proxyTokens = {
        host: resolvedConfig.hostName,
        port: resolvedConfig.port,
        user: username,
      };

      const attemptConnection = async (
        identityFiles: string[],
        agentOverride: string | undefined
      ): Promise<SSH2ConnectionEntry> => {
        const resolvedConfigWithIdentities: ResolvedSSHConfig = {
          ...resolvedConfig,
          identityFiles,
        };

        const readableKeys = await resolvePrivateKeys(resolvedConfigWithIdentities.identityFiles);
        if (abortSignal?.aborted) {
          throw new Error(SSH2_OPERATION_ABORTED_ERROR);
        }
        const keysToTry: Array<Buffer | undefined> =
          readableKeys.length > 0 ? readableKeys : [undefined];
        // Keep the sshPromptService wiring in place so known_hosts-backed
        // verification can be restored without changing the public module API.
        void sshPromptService;

        const connectWithKey = async (
          privateKey: Buffer | undefined,
          reportAuthFailure: boolean
        ): Promise<SSH2ConnectionEntry> => {
          const proxy = resolvedConfigWithIdentities.proxyCommand
            ? spawnProxyCommand(resolvedConfigWithIdentities.proxyCommand, proxyTokens)
            : undefined;

          // Lazy-load ssh2 to avoid loading the native sshcrypto.node module at
          // startup. Bun doesn't support the libuv functions the NAPI module calls,