min(block_timestamp) as earliest_swap_time

FROM ethereum.sushi.ez_swaps

WHERE symbol_out = 'SUSHI'

GROUP BY tx_to),

first_event AS (

SELECT tx.origin_from_address,

min(tx.block_timestamp) as first_event_time

FROM ethereum.core.fact_event_logs tx

JOIN new_sushi_buyers

ON tx.origin_from_address = new_sushi_buyers.tx_to

AND date_trunc('hour', tx.block_timestamp) = date_trunc('hour', new_sushi_buyers.earliest_swap_time)

WHERE tx.block_timestamp > new_sushi_buyers.earliest_swap_time

GROUP BY 1

SELECT

contract_name,

CASE

WHEN event_inputs:from = first_event.origin_from_address THEN 'Transfer to others'

WHEN event_inputs:to = first_event.origin_from_address THEN 'Receive from others' ELSE NULL END as transfer_type,

count(transfer_type) as transfer_type_num,

row_number() over (partition by transfer_type order by transfer_type_num desc) as index

FROM ethereum.core.fact_event_logs tx

JOIN first_event

ON tx.origin_from_address = first_event.origin_from_address AND tx.block_timestamp = first_event.first_event_time

WHERE event_name = 'Transfer' AND transfer_type IS NOT NULL

GROUP BY contract_name, transfer_type

QUALIFY index <= 10

ORDER BY index