Function aggregateForLineGraph

src/core/utils/visualization/visualizationUtils.ts:648–763

(
  rows: any[],
  xField: string,
  yField: string,
  aggregationMethod: AggregationType = 'sum'
)

 * Line graphs always need data bucketing regardless of duplicates
 */
export const aggregateForLineGraph = (
  rows: any[],
  xField: string,
  yField: string,
  aggregationMethod: AggregationType = 'sum'
): any[] => {
  // Group all data points by x-axis value
  const buckets = new Map<string, { sum: number, count: number, values: number[], min: number, max: number }>();
  
  rows.forEach(row => {
    const xValue = String(row[xField] || '');
    const yValue = parseFloat(row[yField]) || 0;
    
    if (!buckets.has(xValue)) {
      buckets.set(xValue, { 
        sum: 0, 
        count: 0, 
        values: [], 
        min: Number.MAX_VALUE, 
        max: Number.MIN_VALUE 
      });
    }
    
    const bucket = buckets.get(xValue)!;
    bucket.sum += yValue;
    bucket.count += 1;
    bucket.values.push(yValue);
    bucket.min = Math.min(bucket.min, yValue);
    bucket.max = Math.max(bucket.max, yValue);
  });
  
  // Convert buckets to array format based on aggregation method
  const aggregatedData = Array.from(buckets.entries()).map(([xValue, bucket]) => {
    let aggregatedValue: number;
    
    switch (aggregationMethod) {
      case 'count':
        aggregatedValue = bucket.count;
        break;
      case 'sum':
        aggregatedValue = bucket.sum;
        break;
      case 'average':
        aggregatedValue = bucket.count > 0 ? bucket.sum / bucket.count : 0;
        break;
      case 'min':
        aggregatedValue = bucket.min === Number.MAX_VALUE ? 0 : bucket.min;
        break;
      case 'max':
        aggregatedValue = bucket.max === Number.MIN_VALUE ? 0 : bucket.max;
        break;
      case 'distinct':
        aggregatedValue = new Set(bucket.values).size;
        break;
      default:
        aggregatedValue = bucket.sum;
    }