SELECT

t.tx_fee AS fee_in_avax

FROM

avalanche.core.fact_transactions t

JOIN

avalanche.defi.ez_dex_swaps s

ON

t.tx_hash = s.tx_hash

WHERE

t.status = 'SUCCESS'

AND t.block_timestamp >= DATE_TRUNC('month', CURRENT_DATE)

AND t.block_timestamp < DATE_TRUNC('month', CURRENT_DATE) + INTERVAL '1 MONTH'

),

AVAXPrice AS (

SELECT

MEDIAN(price) AS avax_price

FROM

avalanche.price.ez_prices_hourly

WHERE

symbol = 'AVAX'

AND hour >= DATE_TRUNC('month', CURRENT_DATE)

AND hour < DATE_TRUNC('month', CURRENT_DATE) + INTERVAL '1 MONTH'

SELECT

SUM(sf.fee_in_avax) AS total_swap_fees_in_avax,

SUM(sf.fee_in_avax) * ap.avax_price AS total_swap_fees_in_usd

FROM

SwapFees sf

CROSS JOIN

AVAXPrice ap;