SELECT

swapper,

SUM(swap_amount_usd) AS total_volume,

COUNT(tx_id) AS tx_count

FROM (

SELECT swapper, tx_id, swap_from_amount_usd AS swap_amount_usd FROM solana.marinade.ez_swaps WHERE swap_from_symbol = 'MSOL' AND Block_timestamp >= '2024-01-01'

UNION ALL

SELECT swapper, tx_id, swap_to_amount_usd AS swap_amount_usd FROM solana.marinade.ez_swaps WHERE swap_to_symbol = 'MSOL' AND Block_timestamp >= '2024-01-01'

) AS combined_swaps

GROUP BY swapper

SELECT

swapper,

tx_count,

total_volume

FROM swapper_volume

ORDER BY tx_count DESC

limit 50;