Function findAvailablePortWithReservation

tests/e2e/helpers/app-launcher.js:31–84

(
  startPort = DEFAULT_START_PORT,
  maxRetries = DEFAULT_MAX_PORT_RETRIES,
  currentRetry = 0,
  options = {}
)

}

async function findAvailablePortWithReservation(
  startPort = DEFAULT_START_PORT,
  maxRetries = DEFAULT_MAX_PORT_RETRIES,
  currentRetry = 0,
  options = {}
) {
  const createServer = options.createServer || net.createServer
  const listenTimeoutMs = options.listenTimeoutMs ?? DEFAULT_PORT_PROBE_TIMEOUT_MS
  const lastErrorCode = options.lastErrorCode

  if (currentRetry >= maxRetries) {
    const errorSuffix = lastErrorCode ? ` Last error: ${lastErrorCode}.` : ''
    throw new Error(
      `Unable to find available port after ${maxRetries} attempts (tried ports ${startPort}-${startPort + maxRetries - 1}).${errorSuffix}`
    )
  }

  const port = startPort + currentRetry
  const result = await new Promise((resolve) => {
    const server = createServer()
    let completed = false
    let timer = null

    const done = (value) => {
      if (completed) return
      completed = true
      if (timer) clearTimeout(timer)
      resolve(value)
    }

    server.on('error', (error) => {
      safeCloseServer(server)
      done({ ok: false, errorCode: error?.code || 'UNKNOWN' })
    })

    server.listen(port, () => {
      done({ ok: true, port, reservationServer: server })
    })

    timer = setTimeout(() => {
      safeCloseServer(server)
      done({ ok: false, errorCode: 'TIMEOUT' })
    }, listenTimeoutMs)
  })

  if (result.ok) {
    return { port: result.port, reservationServer: result.reservationServer }
  }

  return findAvailablePortWithReservation(startPort, maxRetries, currentRetry + 1, {
    ...options,
    lastErrorCode: result.errorCode,
  })
}

async function terminateProcess(proc, { forceKillTimeoutMs = DEFAULT_FORCE_KILL_TIMEOUT_MS } = {}) {
  if (!proc) return