SELECT DISTINCT tx_id

FROM ethereum.udm_events

WHERE contract_address IN (SELECT

DISTINCT pool_address

FROM ethereum.dex_liquidity_pools

WHERE platform = 'sushiswap')

and ORIGIN_FUNCTION_NAME like 'addLiquidity%'

),unstake_tx as(

SELECT DISTINCT tx_id

FROM ethereum.udm_events

WHERE contract_address IN (SELECT

DISTINCT pool_address

FROM ethereum.dex_liquidity_pools

WHERE platform = 'sushiswap')

and ORIGIN_FUNCTION_NAME like 'removeLiquidity%'

),stake_amount as(

SELECT

origin_address as stakers,

SUM(amount_usd) as stake_amount_in_usd

FROM ethereum.udm_events

WHERE tx_id IN (SELECT distinct tx_id FROM stake_tx)

GROUP BY 1

), unstake_amount as (

SELECT

origin_address as unstakers,

-SUM(amount_usd) as unstake_amount_in_usd

FROM ethereum.udm_events

WHERE tx_id IN (SELECT distinct tx_id FROM unstake_tx)

GROUP BY 1

), top10_stakers as (

SELECT

stake_amount.stakers as stakers, unstake_amount_in_usd+stake_amount_in_usd as net_stake_amount

FROM stake_amount,unstake_amount

WHERE stake_amount.stakers=unstake_amount.unstakers and net_stake_amount IS not NULL

ORDER BY net_stake_amount DESC