SELECT tx_hash

, block_timestamp

, CASE

WHEN contract_address = '0x7ceb23fd6bc0add59e62ac25578270cff1b9f619' THEN '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2' --weth

WHEN contract_address = '0x8f3cf7ad23cd3cadbd9735aff958023239c6a063' THEN '0x6b175474e89094c44da98b954eedeac495271d0f' -- dai

WHEN contract_address = '0x2791bca1f2de4661ed88a30c99a7a9449aa84174' THEN '0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48' -- usdc

WHEN contract_address = '0x70c006878a5a50ed185ac4c87d837633923de296' THEN '0x557b933a7c2c45672b610f8954a3deb39a51a8ca' -- revv

END AS eth_asset_address

, event_inputs:value AS asset_amount

FROM polygon.core.fact_event_logs

WHERE topics[0]::STRING = '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef'

AND event_inputs:to IN ('0x5b3256965e7c3cf26e11fcaf296dfc8807c01073','0x8de9c5a032463c561423387a9648c5c7bcc5bc90')

AND block_timestamp >= CURRENT_DATE - 30

),

buyers AS (

SELECT event_inputs:to AS buyer

, SUM(price*asset_amount*pow(10, -1*decimals)) AS usd_fees

, COUNT(*) AS sales

FROM sale_data sale

JOIN ethereum.core.fact_hourly_token_prices

ON DATE_TRUNC('HOUR', block_timestamp) = HOUR

AND eth_asset_address = token_address

JOIN polygon.core.fact_event_logs logs

ON sale.tx_hash = logs.tx_hash

WHERE (logs.topics[0]::STRING = '0xc3d58168c5ae7397731d063d5bbf3d657854427343f4c083240f7aacaa2d0f62') OR

(topics[0]::STRING = '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef'

AND contract_address NOT IN ('0x7ceb23fd6bc0add59e62ac25578270cff1b9f619','0x8f3cf7ad23cd3cadbd9735aff958023239c6a063','0x2791bca1f2de4661ed88a30c99a7a9449aa84174','0x70c006878a5a50ed185ac4c87d837633923de296'))

GROUP BY 1

HAVING buyer IS NOT NULL

),

top10 AS (

SELECT *

, row_number() OVER (ORDER BY usd_fees DESC) AS rank

FROM buyers

ORDER BY rank