select

e.tx_hash,

-- e.origin_from_address as user_wallet,

-- event_inputs:value / pow(10, 18) as amount,

e.contract_address as pool_address,

-- t.contract_address as token_address,

-- e.*,

t.amount_usd as add_liquidity_usd,

0 as remove_liquidity_usd

from ethereum.core.fact_event_logs e join ethereum.core.ez_token_transfers t on e.tx_hash = t.tx_hash

where

e.origin_to_address = '0xd9e1ce17f2641f24ae83637ab66a2cca9c378b9f' and

-- event_name = 'Transfer' and

-- event_inputs:from::string = '0x0000000000000000000000000000000000000000' and

e.origin_function_signature in ('0xe8e33700', '0xf305d719') and

t.amount_usd > 0

union all

select

e.tx_hash,

-- e.origin_from_address as user_wallet,

-- event_inputs:value / pow(10, 18) as amount,

e.contract_address as pool_address,

-- 'ETH' as token_address,

-- e.*,

t.amount_usd as add_liquidity_usd,

0 as remove_liquidity_usd

from ethereum.core.fact_event_logs e join ethereum.core.ez_eth_transfers t on e.tx_hash = t.tx_hash

where

e.origin_to_address = '0xd9e1ce17f2641f24ae83637ab66a2cca9c378b9f' and

-- event_name = 'Transfer' and

-- event_inputs:from::string = '0x0000000000000000000000000000000000000000' and

e.origin_function_signature in ('0xe8e33700', '0xf305d719') and

t.amount_usd > 0

),

remove_liq as (