list1 as (

select

month,

validator_address,

sum(token_flow) as token_flow_total

from (

select

date_trunc('month', block_timestamp) as month,

redelegate_source_validator_address as validator_address,

sum(-1 * (amount / pow(10, 6))) as token_flow,

count(distinct(tx_id)) as tx_number

from osmosis.core.fact_staking

where 1 = 1

and redelegate_source_validator_address is not null

and currency = 'uosmo'

and tx_status = 'SUCCEEDED'

group by month, redelegate_source_validator_address

union

select

date_trunc('month', block_timestamp) as month,

validator_address,

sum(iff(action = 'undelegate', -1, 1) * (amount / pow(10, 6))) as token_flow,

count(distinct(tx_id)) as tx_number

from osmosis.core.fact_staking

where 1 = 1

and redelegate_source_validator_address is null

and currency = 'uosmo'

and tx_status = 'SUCCEEDED'

group by month, validator_address

)

group by month, validator_address

),

list2 as (