Function createFixture

src/testing/wrapperTmuxHarness.ts:58–107

(options: {
  readonly prefix: string
  readonly wrapperPath: string
  readonly envFactory: (
    configDir: string,
    tmpDir: string,
  ) => Promise<NodeJS.ProcessEnv>
  readonly expectedRows: readonly string[]
  readonly cwd?: string
  readonly height?: number
  readonly startupTimeoutMs?: number
  readonly startupBudgetMs?: number
})

}

function createFixture(options: {
  readonly prefix: string
  readonly wrapperPath: string
  readonly envFactory: (
    configDir: string,
    tmpDir: string,
  ) => Promise<NodeJS.ProcessEnv>
  readonly expectedRows: readonly string[]
  readonly cwd?: string
  readonly height?: number
  readonly startupTimeoutMs?: number
  readonly startupBudgetMs?: number
}): Promise<WrapperTmuxFixture> {
  const tmpDir = mkdtempSync(join(tmpdir(), options.prefix))
  const configDir = join(tmpDir, 'config')
  const launchScriptPath = join(tmpDir, 'launch-wrapper.sh')
  mkdirSync(configDir, { recursive: true })
  return options.envFactory(configDir, tmpDir).then(env => {
    writeEnvLaunchScript(
      launchScriptPath,
      options.wrapperPath,
      options.cwd ?? WRAPPER_HARNESS_REPO_ROOT,
      env,
    )

    const startedAt = Date.now()
    const session = createIsolatedTmuxSession({
      command: `bash ${shellQuote(launchScriptPath)}`,
      width: 120,
      height: options.height ?? 40,
    })

    return {
      tmpDir,
      configDir,
      session,
      cwd: options.cwd ?? WRAPPER_HARNESS_REPO_ROOT,
      startupTimeoutMs: options.startupTimeoutMs ?? 25_000,
      startupBudgetMs: options.startupBudgetMs ?? 18_000,
      expectedRows: options.expectedRows,
      getElapsedMs() {
        return Date.now() - startedAt
      },
      cleanup() {
        destroyIsolatedTmuxSession(session)
        rmSync(tmpDir, { recursive: true, force: true })
      },
    }
  })
}

export async function waitForWrapperTmuxRows(
  fixture: WrapperTmuxFixture,