Function waitForInit

src/ssh/createSSHSession.ts:358–427

(
  proc: Subprocess,
  fallbackCwd?: string,
)

}

async function waitForInit(
  proc: Subprocess,
  fallbackCwd?: string,
): Promise<string> {
  const stdout = proc.stdout
  if (!stdout) {
    throw new SSHSessionError('Child process stdout is not readable')
  }

  const reader = (stdout as ReadableStream<Uint8Array>).getReader()
  const decoder = new TextDecoder()
  let buffer = ''
  const deadline = Date.now() + INIT_TIMEOUT_MS

  try {
    while (Date.now() < deadline) {
      const remaining = deadline - Date.now()
      const result = await Promise.race([
        reader.read(),
        new Promise<{ done: true; value: undefined }>((_, reject) =>
          setTimeout(
            () =>
              reject(
                new SSHSessionError(
                  'Remote CLI did not initialize within 30 seconds. Check SSH connectivity and remote binary.',
                ),
              ),
            remaining,
          ),
        ),
      ])

      if (result.done) {
        throw new SSHSessionError(
          'Child process exited before sending init message',
        )
      }

      buffer += decoder.decode(result.value, { stream: true })
      const lines = buffer.split('\n')
      buffer = lines.pop() ?? ''

      for (const line of lines) {
        const trimmed = line.trim()
        if (!trimmed) continue
        try {
          const msg = jsonParse(trimmed) as Record<string, unknown>
          if (msg.type === 'system' && msg.subtype === 'init') {
            reader.releaseLock()
            return (msg.cwd as string) || fallbackCwd || process.cwd()
          }
        } catch {
          // not valid JSON — skip
        }
      }
    }
  } catch (err) {
    reader.releaseLock()