Function openSshSession

apps/sim/executor/handlers/pi/ssh-tools.ts:30–60

(connection: PiSshConnection)

/** Opens one SSH connection plus an SFTP channel for the run. */
export async function openSshSession(connection: PiSshConnection): Promise<PiSshSession> {
  const client = await createSSHConnection({
    host: connection.host,
    port: connection.port,
    username: connection.username,
    password: connection.password ?? null,
    privateKey: connection.privateKey ?? null,
    passphrase: connection.passphrase ?? null,
  })

  const close = () => {
    try {
      client.end()
    } catch (error) {
      logger.warn('Failed to close SSH session', { error: getErrorMessage(error) })
    }
  }

  // The TCP/SSH connection is already open here, so close it if opening the SFTP
  // channel fails (e.g. the server has the SFTP subsystem disabled) — otherwise
  // the connection is orphaned when this function throws.
  try {
    const sftp = await new Promise<SFTPWrapper>((resolve, reject) => {
      client.sftp((err, channel) => (err ? reject(err) : resolve(channel)))
    })
    return { client, sftp, close }
  } catch (error) {
    close()
    throw error
  }
}

function readRemoteFile(sftp: SFTPWrapper, path: string): Promise<string> {
  return new Promise((resolve, reject) => {