Skip to main content

Aggregate Events

Query aggregate statistics for blockchain events.

Query Structure​

query GetEventsAggregate($where: events_bool_exp) {
  events_aggregate(where: $where) {
    aggregate {
      count
      max {
        block_number
        block_timestamp
      }
      min {
        block_number
        block_timestamp
      }
    }
  }
}

Variables​

{
  "where": {
    "type": { "_eq": "AtomCreated" },
    "block_timestamp": { "_gte": "2024-01-01T00:00:00Z" }
  }
}

Use Cases​

Protocol Statistics​

async function getProtocolEventStats() {
  const query = `
    query GetEventStats {
      atoms: events_aggregate(where: { type: { _eq: "AtomCreated" } }) {
        aggregate { count }
      }
      triples: events_aggregate(where: { type: { _eq: "TripleCreated" } }) {
        aggregate { count }
      }
      deposits: events_aggregate(where: { type: { _eq: "Deposited" } }) {
        aggregate { count }
      }
      redemptions: events_aggregate(where: { type: { _eq: "Redeemed" } }) {
        aggregate { count }
      }
    }
  `

  const data = await client.request(query)

  return {
    totalAtoms: data.atoms.aggregate.count,
    totalTriples: data.triples.aggregate.count,
    totalDeposits: data.deposits.aggregate.count,
    totalRedemptions: data.redemptions.aggregate.count
  }
}

Daily Event Counts​

async function getDailyEventCounts(date: Date) {
  const startOfDay = new Date(date)
  startOfDay.setHours(0, 0, 0, 0)

  const endOfDay = new Date(date)
  endOfDay.setHours(23, 59, 59, 999)

  const query = `
    query GetDailyEvents($start: timestamptz!, $end: timestamptz!) {
      events_aggregate(where: {
        block_timestamp: { _gte: $start, _lte: $end }
      }) {
        aggregate {
          count
        }
      }
    }
  `

  return client.request(query, {
    start: startOfDay.toISOString(),
    end: endOfDay.toISOString()
  })
}