select pool_address,

select pool_address,

pool_name,

token0,

token1

from ethereum.core.dim_dex_liquidity_pools

where platform = 'sushiswap'

),

liquidity_data as (

select block_timestamp,

event_inputs:amount0::numeric as amount0,

event_inputs:amount1::numeric as amount1,

contract_address as pool_address,

origin_from_address as provider,

tx_hash,

case when event_name = 'Burn' then 'Liquidity Removed'

when event_name = 'Mint' then 'Liquidity Added'

else null

end as liquidity_event

from ethereum.core.fact_event_logs

where contract_address in (select pool_address from sushiswap_pools_data)

and liquidity_event is not null

and block_timestamp >= '2022-09-01' and block_timestamp <= '2022-09-30'

),

pool_and_token_data as (

select a.*,

b.pool_name,

b.token0,

b.token1,

c.symbol as symbol_token0,

d.symbol as symbol_token1,

c.amount_usd as _amount_usd_token0,

d.amount_usd as _amount_usd_token1