Function attachChildToStream

src/daemon/app-log-stream.ts:67–95

(
  child: StreamableChildProcess,
  stream: fs.WriteStream,
  options: {
    endStreamOnClose: boolean;
    writer: LineWriter;
  },
)

};

export function attachChildToStream(
  child: StreamableChildProcess,
  stream: fs.WriteStream,
  options: {
    endStreamOnClose: boolean;
    writer: LineWriter;
  },
): Promise<ExecResult> {
  const stdout = child.stdout;
  const stderr = child.stderr;
  if (!stdout || !stderr) {
    return Promise.resolve({ stdout: '', stderr: 'missing stdio pipes', exitCode: 1 });
  }
  stdout.setEncoding('utf8');
  stderr.setEncoding('utf8');
  stdout.on('data', options.writer.onChunk);
  stderr.on('data', options.writer.onChunk);
  stream.on('error', () => {
    if (!child.killed) child.kill('SIGKILL');
  });
  child.on('error', () => stream.destroy());
  return new Promise<ExecResult>((resolve) => {
    child.on('close', (code) => {
      options.writer.flush();
      if (options.endStreamOnClose) stream.end();
      resolve({ stdout: '', stderr: '', exitCode: code ?? 1 });
    });
  });
}