crowetic/protocol
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

run linter

Browse Source
This commit is contained in:
fragosti
2019-01-30 10:30:50 -08:00
parent 7b4a0d4f8a
commit 4996ae8d9d
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
packages/pipeline/src/data_sources/bloxy/index.ts
View File

@@ -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;
}