Function spawnPtyContractSession

src/testing/ptyContractHarness.ts:140–315

(
  commandArgs: readonly string[],
  options?: {
    readonly cwd?: string
    readonly env?: NodeJS.ProcessEnv
    readonly columns?: number
    readonly lines?: number
  },
)

}

export function spawnPtyContractSession(
  commandArgs: readonly string[],
  options?: {
    readonly cwd?: string
    readonly env?: NodeJS.ProcessEnv
    readonly columns?: number
    readonly lines?: number
  },
): PtyContractSession {
  const scriptPath = resolveScriptBinary()
  if (!scriptPath) {
    throw new Error('required command not found: script')
  }

  const columns = String(options?.columns ?? Number(DEFAULT_COLUMNS))
  const lines = String(options?.lines ?? Number(DEFAULT_LINES))
  const proc = Bun.spawn(
    [scriptPath, '-qefc', shellJoinArgs(commandArgs), '/dev/null'],
    {
      cwd: options?.cwd,
      env: createDeterministicPtyEnv(options?.env, columns, lines),
      stdin: 'pipe',
      stdout: 'pipe',
      stderr: 'pipe',
    },
  )

  let rawText = ''
  let visibleText = ''
  const waiters: Array<{
    readonly regex: RegExp
    readonly resolve: (match: RegExpMatchArray) => void
    readonly reject: (error: Error) => void
    readonly timer: ReturnType<typeof setTimeout>
  }> = []

  function maybeResolveWaiters(): void {
    for (let index = waiters.length - 1; index >= 0; index -= 1) {
      const waiter = waiters[index]
      const match = rawText.match(waiter.regex)
      if (!match) {
        continue
      }
      clearTimeout(waiter.timer)
      waiters.splice(index, 1)
      waiter.resolve(match)
    }
  }

  async function drainStream(
    stream: ReadableStream<Uint8Array>,
    onChunk: (chunk: string) => void,
  ): Promise<string> {
    const reader = stream.getReader()
    const decoder = new TextDecoder()
    let text = ''

    while (true) {