diff options
| author | fragosti <francesco.agosti93@gmail.com> | 2019-01-31 02:30:50 +0800 |
|---|---|---|
| committer | fragosti <francesco.agosti93@gmail.com> | 2019-01-31 02:30:50 +0800 |
| commit | 4996ae8d9d90c138776d6660965289ae7aba18de (patch) | |
| tree | 0590c1d365ed9ea22b3799d9bfcc3e3ab5a44049 | |
| parent | 7b4a0d4f8aff373b632983400d28dfdce602114a (diff) | |
| download | dexon-0x-contracts-4996ae8d9d90c138776d6660965289ae7aba18de.tar.gz dexon-0x-contracts-4996ae8d9d90c138776d6660965289ae7aba18de.tar.zst dexon-0x-contracts-4996ae8d9d90c138776d6660965289ae7aba18de.zip | |
run linter
| -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; } |