1- import { getAddressKey } from '@cowprotocol/cow-sdk'
1+ import { areAddressesEqual , getAddressKey } from '@cowprotocol/cow-sdk'
22import { logger } from '@cowprotocol/shared'
33import { DuneRepository } from '@cowprotocol/repositories'
44import {
@@ -47,7 +47,7 @@ export class AffiliateStatsServiceImpl implements AffiliateStatsService {
4747 mapRow : normalizeTraderStatsRow ,
4848 } )
4949
50- const filtered = rows . filter ( ( row ) => getAddressKey ( row . trader_address ) === normalizedAddress )
50+ const filtered = rows . filter ( ( row ) => areAddressesEqual ( row . trader_address , normalizedAddress ) )
5151
5252 return { rows : filtered , lastUpdatedAt }
5353 }
@@ -73,7 +73,7 @@ export class AffiliateStatsServiceImpl implements AffiliateStatsService {
7373 typeAssertion : isTraderActivityRowRaw ,
7474 mapRow : normalizeTraderActivityRow ,
7575 } )
76- const filteredRows = duneRows . filter ( ( row ) => getAddressKey ( row . trader_address ) === normalizedAddress )
76+ const filteredRows = duneRows . filter ( ( row ) => areAddressesEqual ( row . trader_address , normalizedAddress ) )
7777 const rows = filteredRows . slice ( 0 , DEFAULT_TRADER_ACTIVITY_LIMIT )
7878
7979 this . setCache ( cacheKey , rows , lastUpdatedAt )
@@ -94,7 +94,7 @@ export class AffiliateStatsServiceImpl implements AffiliateStatsService {
9494 mapRow : normalizeAffiliateStatsRow ,
9595 } )
9696
97- const filtered = rows . filter ( ( row ) => getAddressKey ( row . affiliate_address ) === normalizedAddress )
97+ const filtered = rows . filter ( ( row ) => areAddressesEqual ( row . affiliate_address , normalizedAddress ) )
9898
9999 return { rows : filtered , lastUpdatedAt }
100100 }
0 commit comments