use timestampMs

Author: stefangutica

src/crons/websocket/events.custom.gateway.ts

@@ -61,11 +61,9 @@ export class EventsCustomGateway {
 
   async pushEventsForTimestampMs(timestampMs: number): Promise<void> {
     try {
-      const timestamp = timestampMs / 1000;
-
       const allEvents = await this.eventsService.getEvents(
         new QueryPagination({ size: 10000 }),
-        new EventsFilter({ before: timestamp, after: timestamp }),
+        new EventsFilter({ before: timestampMs, after: timestampMs }),
       );
 
       const eventsFilteredForBroadcast: Map<string, Events[]> = new Map();

src/crons/websocket/transaction.custom.gateway.ts

@@ -54,9 +54,8 @@ export class TransactionsCustomGateway {
 
   async pushTransactionsForTimestampMs(timestampMs: number): Promise<void> {
     try {
-      const timestamp = timestampMs / 1000; // TODO: add support for timestampMs
       const allTransactions = await this.transactionService.getTransactions(
-        new TransactionFilter({ before: timestamp, after: timestamp }),
+        new TransactionFilter({ before: timestampMs, after: timestampMs }),
         new QueryPagination({ size: 10000 }) // TODO: handle pagination with more than 10k txs
       );