WITH cte_ca as (

select '6HP3PZ5DkCy6kEjS8CKPfeMCXgoxyTcdvEakzFyzpump' as ca

),

cte_price as (

select dateadd(HOUR, -5, block_timestamp) AS ts,

swap_from_amount,swap_to_amount,

case when swap_from_mint = 'So11111111111111111111111111111111111111112' then

case when swap_to_amount > 0 then round(((swap_from_amount / swap_to_amount) * 200 * 1000000000)/1000,0) else 0 end

else

case when swap_from_amount > 0 then round(((swap_to_amount / swap_from_amount) * 200 * 1000000000)/1000,0) else 0 end end as cap,

swap_from_mint,swap_to_mint,swap_program,tx_id

from solana.defi.fact_swaps

where (swap_from_mint = (select ca from cte_ca)

or swap_to_mint = (select ca from cte_ca)

)

order by block_timestamp asc

),

cte_stg as (

select

dateadd(HOUR, -5, s.block_timestamp) AS ts,

p.cap,