Function streamToLines

packages/db/src/buffers/event-buffer.test.ts:16–22

Drain an object-mode Readable into an array of line strings. event-buffer * yields each JSONEachRow row as its own string chunk; the @clickhouse/client * adds the trailing '\n' itself via encodeJSON. So in production each `\n` is * added by the client, but here we just collect chunks 1:1.

(stream: Readable)

 *  adds the trailing '\n' itself via encodeJSON. So in production each `\n` is
 *  added by the client, but here we just collect chunks 1:1. */
async function streamToLines(stream: Readable): Promise<string[]> {
  const lines: string[] = [];
  for await (const chunk of stream) {
    lines.push(typeof chunk === 'string' ? chunk : chunk.toString('utf8'));
  }
  return lines;
}

const redis = getRedisCache();