with eth_data as (

with eth_liquid as (

with liquid_flows as (

--deposits

SELECT

date_trunc('month', block_timestamp) as dmonth

, 'deposits' as label

, SUM(ETH_AMOUNT) as token_amount

from ethereum.defi.ez_liquid_staking_deposits

GROUP BY dmonth, label

UNION ALL

SELECT

date_trunc('month', block_timestamp) as dmonth

, 'withdraws' as label

, SUM(ETH_AMOUNT) as token_amount

from ethereum.defi.ez_liquid_staking_withdrawals

GROUP BY dmonth, label

)

,

refine as (

SELECT

dmonth

, SUM(CASE WHEN label = 'deposits' THEN token_amount ELSE token_amount*(-1) END) as net_flow

, SUM(net_flow) OVER (ORDER BY DMONTH ASC) as liquid_stake_cumulative

from liquid_flows

GROUP BY dmonth

)

SELECT

dmonth

, liquid_stake_cumulative as liquid_stake