Function waitForServer

test/e2e/next-analyze/next-analyze.test.ts:92–138

(process: ChildProcess, timeoutMs: number = 30000)

})

function waitForServer(process: ChildProcess, timeoutMs: number = 30000) {
  const serverUrlPromise = new Promise<string>((resolve, reject) => {
    const timeout = setTimeout(() => {
      process.stdout.off('data', onStdout)
      process.off('error', onError)
      process.off('exit', onExit)
      reject(new Error('Server did not start within timeout'))
    }, timeoutMs)

    function onStdout(data: Buffer) {
      const urlMatch = data.toString().match(/http:\/\/[^\s]+/)
      if (urlMatch) {
        clearTimeout(timeout)
        process.stdout.off('data', onStdout)
        process.off('error', onError)
        process.off('exit', onExit)
        resolve(urlMatch[0])
      }
    }

    function onError(error: Error) {
      clearTimeout(timeout)
      process.stdout.off('data', onStdout)
      process.off('error', onError)
      process.off('exit', onExit)
      reject(error)
    }

    function onExit(code: number) {
      clearTimeout(timeout)
      process.stdout.off('data', onStdout)
      process.off('error', onError)
      process.off('exit', onExit)
      reject(
        new Error(
          `Server process exited with code ${code} before URL was emitted`
        )
      )
    }

    process.stdout.on('data', onStdout)
    process.on('error', onError)
    process.on('exit', onExit)
  })

  return serverUrlPromise
}