Class EventRepository

src/repositories/event-repository.ts:41–509

}

export class EventRepository implements IEventRepository {
  public constructor(
    private readonly masterDbClient: DatabaseClient,
    private readonly readReplicaDbClient: DatabaseClient,
  ) {}

  public findByFilters(filters: SubscriptionFilter[]): IQueryResult<DBEvent[]> {
    logger('querying for %o', filters)
    if (!Array.isArray(filters) || !filters.length) {
      throw new Error('Filters cannot be empty')
    }
    const queries = filters.map((currentFilter) => {
      const builder = this.readReplicaDbClient<DBEvent>('events')

      const isTagQuery = this.applyFilterConditions(builder, currentFilter)

      if (typeof currentFilter.limit === 'number') {
        builder.limit(currentFilter.limit).orderBy('event_created_at', 'DESC').orderBy('event_id', 'asc')
      } else {
        builder.limit(DEFAULT_FILTER_LIMIT).orderBy('event_created_at', 'asc').orderBy('event_id', 'asc')
      }

      if (isTagQuery) {
        builder.select('events.*')
      }

      return builder
    })

    const [query, ...subqueries] = queries
    if (subqueries.length) {
      query.union(subqueries, true)
    }

    return query
  }

  public async countByFilters(filters: SubscriptionFilter[]): Promise<number> {
    logger('counting events for %o', filters)

    if (!Array.isArray(filters) || !filters.length) {
      throw new Error('Filters cannot be empty')
    }

    const now = Math.floor(Date.now() / 1000)

    const queries = filters.map((currentFilter) => {
      const builder = this.readReplicaDbClient<DBEvent>('events').select('events.event_id')

      const isTagQuery = this.applyFilterConditions(builder, currentFilter)

      if (typeof currentFilter.limit === 'number') {
        builder.limit(currentFilter.limit).orderBy('event_created_at', 'DESC').orderBy('event_id', 'asc')
      }

      if (isTagQuery) {
        builder.select('events.event_id')
      }