Function createLineWriter

src/daemon/app-log-stream.ts:26–56

(
  stream: fs.WriteStream,
  options: { redactionPatterns: RegExp[]; includeTokens?: string[] },
)

type LineWriter = { onChunk: (chunk: string) => void; flush: () => void };

export function createLineWriter(
  stream: fs.WriteStream,
  options: { redactionPatterns: RegExp[]; includeTokens?: string[] },
): LineWriter {
  const includeTokens = options.includeTokens?.filter((token) => token.length > 0) ?? [];
  let pending = '';

  const writeLine = (line: string): void => {
    if (includeTokens.length > 0) {
      const shouldInclude = includeTokens.some((token) => line.includes(token));
      if (!shouldInclude) return;
    }
    stream.write(redactChunk(line, options.redactionPatterns));
  };

  return {
    onChunk: (chunk: string) => {
      const combined = `${pending}${chunk}`;
      const lines = combined.split('\n');
      pending = lines.pop() ?? '';
      for (const line of lines) {
        writeLine(`${line}\n`);
      }
    },
    flush: () => {
      if (!pending) return;
      writeLine(pending);
      pending = '';
    },
  };
}

type StreamableChildProcess = {
  killed: boolean;