diff --git a/modules/repositories/events/events-repository.ts b/modules/repositories/events/events-repository.ts index f62b80ca5..4760f9e4e 100644 --- a/modules/repositories/events/events-repository.ts +++ b/modules/repositories/events/events-repository.ts @@ -219,6 +219,21 @@ export const eventsRepository = { return swaps as SwapEvent[]; }, + getAllEventsForTimeRange: async (chain: Chain, poolId: string, startTime?: number, endTime?: number) => { + const events = await prisma.prismaPoolEvent.findMany({ + where: { + chain, + poolId, + blockTimestamp: { + ...(startTime ? { gte: startTime } : {}), + ...(endTime ? { lte: endTime } : {}), + }, + }, + orderBy, + }); + + return events as (SwapEvent | JoinExitEvent)[]; + }, getTokenFlows: async ( chain: Chain, poolId: string,