Function normalizeCsvRun

tests/loadtest/tools/dashboard/app.js:379–429

(fileName, text)

}

function normalizeCsvRun(fileName, text) {
  const [headerLine, ...lines] = text.split(/\r?\n/).filter(Boolean);
  const headers = headerLine.split(",");
  const series = [];
  let totalRequests = 0;
  let successWeight = 0;

  lines.forEach((line) => {
    const cols = line.split(",");
    const row = Object.fromEntries(headers.map((header, index) => [header, cols[index] ?? ""]));
    const requests = toNumber(row.requests) || 0;
    const successRate = clamp01(toNumber(row.success_ratio));
    totalRequests += requests;
    if (successRate !== null) {
      successWeight += successRate * requests;
    }
    series.push({
      minute: row.minute,
      label: row.minute,
      requests,
      tpm: toNumber(row.tpm) ?? requests,
      successRate,
      p50Ms: toNumber(row.p50_ms),
      p95Ms: toNumber(row.p95_ms),
      p99Ms: toNumber(row.p99_ms),
      apdex: clamp01(toNumber(row.apdex)),
    });
  });

  return finalizeRun({
    id: `upload:${fileName}`,
    name: fileName.replace(/\.[^.]+$/, ""),
    source: fileName,
    kind: "minute_csv",
    collectedAt: new Date().toISOString(),
    durationMs: series.length ? series.length * 60 * 1000 : null,
    overview: {
      requestsTotal: totalRequests || null,
      throughputPerMinute: series.length ? totalRequests / series.length : null,
      successRate: totalRequests ? successWeight / totalRequests : null,
      p50Ms: lastDefined(series, "p50Ms"),
      p95Ms: lastDefined(series, "p95Ms"),
      p99Ms: lastDefined(series, "p99Ms"),
      peakTpm: series.length ? Math.max(...series.map((point) => point.tpm || 0)) : null,
      apdex: mean(series.map((point) => point.apdex)),
    },
    thresholds: [],
    checks: [],
    series,
  });
}

function normalizeNdjsonRun(fileName, text) {
  const counts = new Map();