Aggregations

const activeUsers = await client.queryBuilder()
  .collection('users')
  .whereField('active').equals(true)
  .count();
// Returns: number

const totalRevenue = await client.queryBuilder()
  .collection('orders')
  .whereField('status').equals('completed')
  .sumBy('amount');
// Returns: number

const avgPrice = await client.queryBuilder()
  .collection('products')
  .whereField('category').equals('electronics')
  .avgBy('price');
// Returns: number

const highestPrice = await client.queryBuilder()
  .collection('products')
  .maxBy('price');
// Returns: T | null

const lowestPrice = await client.queryBuilder()
  .collection('products')
  .minBy('price');
// Returns: T | null

const categories = await client.queryBuilder()
  .collection('products')
  .distinctBy('category');
// Returns: string[]

const uniqueCategories = await client.queryBuilder()
  .collection('products')
  .countDistinct('category');
// Returns: number

// Count users by country
const usersByCountry = await client.queryBuilder()
  .collection('users')
  .groupBy('country')
  .count();
// Returns: { "USA": 150, "UK": 75, "Germany": 50 }

// Sum order amounts by category
const salesByCategory = await client.queryBuilder()
  .collection('orders')
  .whereField('status').equals('completed')
  .groupBy('category')
  .sumBy('amount');
// Returns: { "electronics": 50000, "clothing": 25000 }

// Average rating by product
const avgRatingByProduct = await client.queryBuilder()
  .collection('reviews')
  .groupBy('productId')
  .avgBy('rating');
// Returns: { "prod_1": 4.5, "prod_2": 3.8 }

const maxPriceByCategory = await client.queryBuilder()
  .collection('products')
  .groupBy('category')
  .maxBy('price');
// Returns: { "electronics": 999, "books": 49 }

// Group by nested field
const ordersByRegion = await client.queryBuilder()
  .collection('orders')
  .groupBy('customer.address.region')
  .sumBy('total');
// Returns: { "West": 10000, "East": 8500 }

// Sum revenue for completed orders in Q4 2024
const q4Revenue = await client.queryBuilder()
  .collection('orders')
  .find(b => [
    b.field('status').equals('completed'),
    b.field('createdAt').greaterThanOrEqual('2024-10-01'),
    b.field('createdAt').lessThanOrEqual('2024-12-31'),
  ])
  .sumBy('amount');

// Average rating for verified reviews only
const verifiedAvg = await client.queryBuilder()
  .collection('reviews')
  .whereField('verified').isTrue()
  .avgBy('rating');

// Dashboard metrics for an e-commerce app
async function getDashboardMetrics() {
  const [
    totalOrders,
    totalRevenue,
    avgOrderValue,
    ordersByStatus,
    revenueByCategory
  ] = await Promise.all([
    client.queryBuilder()
      .collection('orders')
      .count(),

    client.queryBuilder()
      .collection('orders')
      .whereField('status').equals('completed')
      .sumBy('total'),

    client.queryBuilder()
      .collection('orders')
      .whereField('status').equals('completed')
      .avgBy('total'),

    client.queryBuilder()
      .collection('orders')
      .groupBy('status')
      .count(),

    client.queryBuilder()
      .collection('orders')
      .whereField('status').equals('completed')
      .groupBy('category')
      .sumBy('total')
  ]);

  return {
    totalOrders,
    totalRevenue,
    avgOrderValue,
    ordersByStatus,
    revenueByCategory
  };
}