Function createLocalSSHSession

src/ssh/createSSHSession.ts:255–356

(config: {
  cwd?: string
  permissionMode?: string
  dangerouslySkipPermissions?: boolean
})

}

export async function createLocalSSHSession(config: {
  cwd?: string
  permissionMode?: string
  dangerouslySkipPermissions?: boolean
}): Promise<SSHSession> {
  const { proxy, authEnv } = await createAuthProxy()

  const cliArgs: string[] = [
    '--output-format',
    'stream-json',
    '--input-format',
    'stream-json',
    '-p',
  ]
  if (config.cwd) {
    cliArgs.push('--cwd', config.cwd)
  }
  if (config.permissionMode) {
    cliArgs.push('--permission-mode', config.permissionMode)
  }
  if (config.dangerouslySkipPermissions) {
    cliArgs.push('--dangerously-skip-permissions')
  }

  const spec = buildCliLaunch(cliArgs)

  let proc: Subprocess
  try {
    proc = Bun.spawn([spec.execPath, ...spec.args], {
      stdin: 'pipe',
      stdout: 'pipe',
      stderr: 'pipe',
      env: { ...spec.env, ...authEnv },
    })
  } catch (err) {
    proxy.stop()
    throw new SSHSessionError(
      `Failed to spawn local CLI process: ${err instanceof Error ? err.message : String(err)}`,
    )
  }

  logForDebugging('[SSH] local session spawned, waiting for init message...')

  const stderrChunks: string[] = []
  collectStderr(proc, stderrChunks)

  let remoteCwd: string
  try {
    remoteCwd = await waitForInit(proc, config.cwd)
  } catch (err) {
    proxy.stop()
    proc.kill()
    throw err
  }

  logForDebugging(`[SSH] local session initialized, remoteCwd=${remoteCwd}`)

  let currentProc = proc