Function normalizeNdjsonRun

tests/loadtest/tools/dashboard/app.js:431–522

(fileName, text)

}

function normalizeNdjsonRun(fileName, text) {
  const counts = new Map();
  const failures = new Map();
  const latencies = new Map();
  const allLatencies = [];

  text.split(/\r?\n/).forEach((line) => {
    const trimmed = line.trim();
    if (!trimmed) {
      return;
    }
    let obj;
    try {
      obj = JSON.parse(trimmed);
    } catch {
      return;
    }
    if (obj.type !== "Point") {
      return;
    }
    const timestamp = obj.data?.time;
    if (!timestamp) {
      return;
    }
    const bucket = floorMinute(timestamp);
    const value = toNumber(obj.data?.value);
    if (obj.metric === "http_reqs") {
      counts.set(bucket, (counts.get(bucket) || 0) + (value || 0));
    } else if (obj.metric === "http_req_failed") {
      failures.set(bucket, (failures.get(bucket) || 0) + (value || 0));
    } else if (obj.metric === "http_req_duration" && value !== null) {
      const values = latencies.get(bucket) || [];
      values.push(value);
      latencies.set(bucket, values);
      allLatencies.push(value);
    }
  });

  const minutes = [...new Set([...counts.keys(), ...latencies.keys()])].sort();
  const series = [];
  let totalRequests = 0;
  let totalFailures = 0;
  const apdexValues = [];

  minutes.forEach((minute) => {
    const lats = latencies.get(minute) || [];
    const requests = counts.get(minute) || lats.length;
    const failed = failures.get(minute) || 0;
    totalRequests += requests;
    totalFailures += failed;
    const apdex = computeApdex(lats);
    if (apdex !== null) {
      apdexValues.push(apdex);
    }
    series.push({
      minute,
      label: minute.slice(11),
      requests,