select pool_id, token1, token2 from (

values

('0x9fe38345d91411ea0eab3d6753a9843f2a1a09612211dabd718bdee32fe6e240', 'APT', 'USDC'),

('0x56e73c59c98fc198ac1cb7cc125d42b3f29408c3e81464c1383a95e1878bf5f6', 'APT', 'USDC'),

('0xce131db3fb4f52c4a1526e2cf1d8a5383a6c5c0beaa610c277856a8721a9b5a3', 'APT', 'amAPT'),

('0xd1db51da33bedc2b84dd7d385835d7ba26664bcf6a9a2e4727fe5464d8d10724', 'APT', 'WETH'),

('0x528011ba8b1309b100a93f3985501239c10e380a3b3af26d00a76c45e5dbb311', 'APT', 'amAPT'),

('0x925660b8618394809f89f8002e2926600c775221f43bf1919782b297a79400d8', 'APT', 'USDC'),

('0xd3894aca06d5f42b27c89e6f448114b3ed6a1ba07f992a58b2126c71dd83c127', 'USDT', 'USDC'),

('0x18269b1090d668fbbc01902fa6a5ac6e75565d61860ddae636ac89741c883cbc', 'APT', 'USDT'),

('0xfbcd47491f4e2ba0c309dd7e297cb5ce805689b05fd95377d9bfa4a11eafdd2e', 'USDT', 'USDC')

) as t(pool_id, token1, token2)

),

base_swaps as (

select

*,

ROW_NUMBER() OVER (PARTITION BY tx_hash ORDER BY event_index) as rn

from (

select

block_timestamp,

tx_hash,

event_index,

event_data:amount_in::float as amount_in,

event_data:amount_out::float as amount_out,

event_data:fee_amount::float as fee_amount,

event_data:pool_id::string as pool,

pt.token1,

pt.token2,

case

when event_data:from_token:inner = '0xa' then 'APT'

when event_data:from_token:inner = '0xae02f68520afd221a5cd6fda6f5500afedab8d0a2e19a916d6d8bc2b36e758db' then 'WETH'

when event_data:from_token:inner = '0xa259be733b6a759909f92815927fa213904df6540519568692caf0b068fe8e62' then 'amAPT'

when event_data:from_token:inner = '0x357b0b74bc833e95a115ad22604854d6b0fca151cecd94111770e5d6ffc9dc2b' then 'USDT'

else 'USDC'