SELECT

ft.block_timestamp,

ft.tx_hash,

ft.from_address,

ft.origin_from_address,

ft.to_address,

ft.origin_to_address,

utils.udf_hex_to_int(SUBSTR(topic_3, 3)) AS token_id, -- NFT ID

ftr.value,

ROW_NUMBER() OVER (PARTITION BY token_id ORDER BY ft.block_timestamp ASC, ft.tx_position ASC, ft.trace_index ASC) AS rn,

COUNT(DISTINCT ft.tx_hash) OVER (PARTITION BY el.topic_3) AS transfer_count -- Count how many times an NFT appears

FROM monad.testnet.fact_traces ft

INNER JOIN monad.testnet.fact_event_logs el

ON ft.tx_hash = el.tx_hash

INNER JOIN monad.testnet.fact_transactions ftr

ON ft.tx_hash = ftr.tx_hash

WHERE el.contract_address = LOWER('0xE8F0635591190Fb626F9D13C49b60626561Ed145') -- Replace with NFT contract address

AND el.topic_0 = '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef' -- Transfer event topic

AND ft.TX_SUCCEEDED = 'TRUE'

AND ft.TRACE_SUCCEEDED = 'TRUE'

),

balances AS (

SELECT

to_address AS wallet_address,

COUNT(token_id) AS nft_count -- NFTs received

FROM base

WHERE to_address != '0x0000000000000000000000000000000000000000' -- Exclude burn address

GROUP BY to_address

UNION ALL

SELECT

from_address AS wallet_address,