diff options
| -rw-r--r-- | packages/pipeline/src/data_sources/bloxy/index.ts | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/packages/pipeline/src/data_sources/bloxy/index.ts b/packages/pipeline/src/data_sources/bloxy/index.ts index 68764ca98..22ab195b3 100644 --- a/packages/pipeline/src/data_sources/bloxy/index.ts +++ b/packages/pipeline/src/data_sources/bloxy/index.ts @@ -78,10 +78,7 @@ export class BloxySource { public async getDexTradesAsync(lastSeenTimestamp: number): Promise<BloxyTrade[]> { const allTrades = await this._scrapeAllDexTradesAsync(lastSeenTimestamp); logUtils.log(`Removing duplicates from ${allTrades.length} entries`); - const uniqueTrades = R.uniqBy( - (trade: BloxyTrade) => `${trade.tradeIndex}-${trade.tx_hash}`, - allTrades, - ) as BloxyTrade[]; + const uniqueTrades = R.uniqBy((trade: BloxyTrade) => `${trade.tradeIndex}-${trade.tx_hash}`, allTrades); logUtils.log(`Removed ${allTrades.length - uniqueTrades.length} duplicate entries`); return uniqueTrades; } |