Function spawnAndWaitForStdout

tests/setup/globalSetup.ts:53–90

(
  command: string,
  args: string[],
  predicate: (stdout: string) => boolean
)

}

function spawnAndWaitForStdout(
  command: string,
  args: string[],
  predicate: (stdout: string) => boolean
): DeferredPromise<ChildProcess> {
  const promise = new DeferredPromise<ChildProcess>();
  const io = spawn(command, args, {
    env: {
      ...process.env,
      NODE_ENV: 'test',
    },
  });
  let stdout = Buffer.from('');

  io.stdout.on('data', (raw: Buffer) => {
    console.log(raw.toString('utf8'));
    stdout = Buffer.concat([stdout, raw]);

    if (predicate(raw.toString('utf8'))) {
      promise.resolve(io);
    }
  });

  io.stderr.on('data', (raw: Buffer) => {
    console.error(stdout.toString('utf8'));
    promise.reject(new Error(raw.toString('utf8')));
    io.kill(1);
  });

  io.once('error', (error) => promise.reject(error));
  io.once('exit', (code) => {
    if (code !== 0) {
      promise.reject(new Error(format('Process "%s %j" exited with code %d', command, args, code)));
    }
  });

  return promise;
}