block_timestamp,

tx_id,

f.value as signers,

instructions[0]:parsed:info:amount::float / POW(10,6) AS token_amount,

pre_token_balances[3]:mint::string as source_token,

address_name,

inner_instructions[0]:instructions[2]:parsed:info:mint::string as destination_chain_token,

instructions[1]:programId as contract_address,

ROW_NUMBER() OVER (partition by tx_id ORDER BY signers) row_num

from solana.core.fact_transactions t

left join solana.core.dim_labels l ON t.pre_token_balances[3]:mint::string = l.address,

table(flatten(input => signers)) f

where succeeded = 'TRUE' AND

instructions[1]:programId = 'SWiMDJYFUGj6cPrQ6QYYYWZtvXQdRChSVAygDZDsCHC' AND succeeded = 'TRUE' AND block_timestamp >= '2022-05-01' )

select

source_token,

case when source_token = 'BJUH9GJLaMSLV1E7B3SQLCy9eCfyr6zsrwGcpS2MkqR1' then 'SwimUSD Solana'

else address_name

end as token_name,

case

when token_name ilike '%ethereum%' then 'Ethereum chain'

when token_name ilike '%bsc%' then 'Binance chain'

else 'Solana chain'

end as chains,

sum(token_Amount) as token_volume

from T1

where row_num = '1'

group by 1, 2, 3