Function finishLine

src/proxy/mailbox/store.js:157–182

(hasNewline = false)

  };

  const finishLine = (hasNewline = false) => {
    const totalLineBytes = lineBytes + (hasNewline ? 1 : 0);
    if (dropping) {
      stats.overlong += 1;
      resetLine();
      return;
    }
    if (totalLineBytes > maxLineBytes) {
      stats.overlong += 1;
      resetLine();
      return;
    }
    if (lineBytes === 0) {
      resetLine();
      return;
    }
    const trimmed = Buffer.concat(parts, lineBytes).toString('utf8').trim();
    resetLine();
    if (!trimmed) return;
    try {
      onRow(JSON.parse(trimmed));
      stats.parsed += 1;
    } catch {
      stats.corrupt += 1;
    }
  };

  try {
    fd = fs.openSync(filePath, 'r');