Function computeAggregateValue

packages/infra/src/Store/Memory.ts:172–207

(rows: readonly T[], agg: AggregateIrExpression)

}

const computeAggregateValue = <T extends FieldValues>(rows: readonly T[], agg: AggregateIrExpression): unknown => {
  switch (agg._tag) {
    case "agg-count":
      return rows.length
    case "agg-count-when": {
      const filter = agg.filter
      const matches = filter.length === 0 ? () => true : (row: unknown) => codeFilter3_(filter, row)
      return rows.filter((row) => matches(row)).length
    }
    case "agg-sum":
      return rows.reduce<number>((acc, row) => {
        const v = get(row, agg.field)
        return acc + (typeof v === "number" ? v : Number(v) || 0)
      }, 0)
    case "agg-min": {
      let min: unknown = undefined
      for (const row of rows) {
        const v = get(row, agg.field)
        if (v == null) continue
        if (min === undefined || v < (min as any)) min = v
      }
      return min ?? null
    }
    case "agg-max": {
      let max: unknown = undefined
      for (const row of rows) {
        const v = get(row, agg.field)
        if (v == null) continue
        if (max === undefined || v > (max as any)) max = v
      }
      return max ?? null
    }
    default:
      return assertUnreachable(agg)
  }
}

export function memFilter<T extends FieldValues, U extends keyof T = never>(f: FilterArgs<T, U>) {
  type M = U extends undefined ? T : Pick<T, U>