Function processOutputLine

tools/gemini-cli-bot/metrics/index.ts:41–98

(line: string, results: string[])

);

function processOutputLine(line: string, results: string[]) {
  const trimmedLine = line.trim();
  if (!trimmedLine) return;

  let metricName = '';
  let metricValue = 0;

  try {
    const parsed = JSON.parse(trimmedLine);
    if (
      parsed &&
      typeof parsed === 'object' &&
      'metric' in parsed &&
      'value' in parsed
    ) {
      metricName = parsed.metric;
      metricValue = parseFloat(parsed.value);
      results.push(`${metricName},${metricValue}`);
    } else {
      const parts = trimmedLine.split(',');
      if (parts.length === 2) {
        metricName = parts[0];
        metricValue = parseFloat(parts[1]);
        results.push(trimmedLine);
      } else {
        results.push(trimmedLine);
        return; // Unable to parse for deltas
      }
    }
  } catch {
    const parts = trimmedLine.split(',');
    if (parts.length === 2) {
      metricName = parts[0];
      metricValue = parseFloat(parts[1]);
      results.push(trimmedLine);
    } else {
      results.push(trimmedLine);
      return; // Unable to parse for deltas
    }
  }

  // Calculate and append deltas if the metric is a valid number
  if (metricName && !isNaN(metricValue)) {
    const avg7d = getHistoricalAverage(metricName, 7);
    if (avg7d !== null) {
      results.push(
        `${metricName}_delta_7d,${(metricValue - avg7d).toFixed(2)}`,
      );
    }

    const avg30d = getHistoricalAverage(metricName, 30);
    if (avg30d !== null) {
      results.push(
        `${metricName}_delta_30d,${(metricValue - avg30d).toFixed(2)}`,
      );
    }
  }
}