Function waitForAnyProcessOutputToMatch

tests/e2e/utils/process.ts:215–256

(
  match: RegExp,
  timeout = 30000,
)

}

export async function waitForAnyProcessOutputToMatch(
  match: RegExp,
  timeout = 30000,
): Promise<ProcessOutput> {
  let timeoutId: ReturnType<typeof setTimeout> | null = null;

  // Race between _all_ processes, and the timeout. First one to resolve/reject wins.
  const timeoutPromise: Promise<ProcessOutput> = new Promise((_resolve, reject) => {
    // Wait for 30 seconds and timeout.
    timeoutId = setTimeout(() => {
      reject(new Error(`Waiting for ${match} timed out (timeout: ${timeout}msec)...`));
    }, timeout);
  });

  const matchPromises: Promise<ProcessOutput>[] = _processes.map(
    (childProcess) =>
      new Promise((resolve) => {
        let stdout = '';
        let stderr = '';

        childProcess.stdout!.on('data', (data: Buffer) => {
          stdout += data.toString();
          if (stripVTControlCharacters(stdout).match(match)) {
            resolve({ stdout, stderr });
          }
        });

        childProcess.stderr!.on('data', (data: Buffer) => {
          stderr += data.toString();
          if (stripVTControlCharacters(stderr).match(match)) {
            resolve({ stdout, stderr });
          }
        });
      }),
  );

  const matchingProcess = await Promise.race(matchPromises.concat([timeoutPromise]));
  if (timeoutId !== null) {
    clearTimeout(timeoutId);
  }
  return matchingProcess;
}

/**
 * Kills a process by PID