Function executeAggregateChart

packages/db/src/engine/index.ts:84–350

(
  input: IReportInput
)

 * Executes a simplified pipeline: normalize -> fetch aggregate -> format
 */
export async function executeAggregateChart(
  input: IReportInput
): Promise<FinalChart> {
  // Stage 1: Normalize input
  const normalized = await normalize(input);

  // Handle subscription end date limit
  const endDate = await getOrganizationSubscriptionChartEndDate(
    input.projectId,
    normalized.endDate
  );
  if (endDate) {
    normalized.endDate = endDate;
  }

  const { timezone } = await getSettingsForProject(normalized.projectId);

  // Stage 2: Fetch aggregate data for current period (event series only)
  const fetchedSeries: ConcreteSeries[] = [];

  for (let i = 0; i < normalized.series.length; i++) {
    const definition = normalized.series[i]!;

    if (definition.type !== 'event') {
      // Skip formulas - they'll be computed in the next stage
      continue;
    }

    const event = definition as IChartEventItem & { type: 'event' };

    // Build query input
    const queryInput = {
      event: {
        id: event.id,
        name: event.name,
        segment: event.segment,
        filters: event.filters,
        displayName: event.displayName,
        property: event.property,
      },
      projectId: normalized.projectId,
      startDate: normalized.startDate,
      endDate: normalized.endDate,
      breakdowns: normalized.breakdowns,
      limit: normalized.limit,
      metric: normalized.metric,
      previous: normalized.previous,
      timezone,
    };

    // Execute aggregate query
    let queryResult = await chQuery<ISerieDataItem>(
      await getAggregateChartSql(queryInput),
      {
        session_timezone: timezone,
      }
    );