select

tx_hash,

block_timestamp,

old_owner_id as sender_address,

amount_raw as sent_amount,

token_id as sent_token

from near.defi.fact_intents

where log_event = 'mt_transfer'

and RECEIPT_SUCCEEDED = TRUE

qualify row_number() over (partition by tx_hash, log_index order by log_event_index desc) = 1

),

receiver_transactions as (

select

tx_hash,

block_timestamp,

new_owner_id as receiver_address,

token_id as received_token

from near.defi.fact_intents

where log_event = 'mt_transfer'

and RECEIPT_SUCCEEDED = TRUE

qualify row_number() over (partition by tx_hash, log_index order by log_event_index asc) = 1

),

swap_details as (

select

s.tx_hash,

s.block_timestamp,

s.sender_address,

s.sent_amount,

split(s.sent_token, ':')[1] :: string as input_token,

split(r.received_token, ':')[1] :: string as output_token

from sender_transactions s

left join receiver_transactions r using(tx_hash)

where split(s.sent_token, ':')[1] :: string != split(r.received_token, ':')[1] :: string

or r.received_token is null

),