select b.tx_hash, block, vault, rewards, incentive_token, name, amount from (

select tx_hash, ((utils.udf_hex_to_int(topics[2]))) as block, (utils.udf_hex_to_int(substr(data,3,64))::int)/1e18 as rewards,

concat('0x',substr(TOPICS[3], 27,64)) as vault

from berachain.testnet.fact_event_logs

where topics[0]='0x96b077538301034fee0c56fc41bbee8e61ddedc1029eeeaff049fd4db8fac18a'

and concat('0x',substr(TOPICS[1], 27,64))=lower('0x40495a781095932e2fc8dcca69f5e358711fdd41')

) b

join (

select tx_hash, contract_address as reward_vault, concat('0x',substr(TOPICS[2], 27,64)) as incentive_token, name,

(utils.udf_hex_to_int(substr(data,3,64))::int)/1e18 as bgt_emitted,

(utils.udf_hex_to_int(substr(data,67,64))::int)/(pow(1e1,decimals)) as amount

from berachain.testnet.fact_event_logs ip

join berachain.testnet.dim_contracts c on lower(concat('0x',substr(ip.TOPICS[2], 27,64)))=lower(c.address)

where topics[0]=('0xd53172319994f5af85b7efcb42b2c2c36672baa8560f64b2b0c1d7f009014332')

and concat('0x',substr(TOPICS[1], 27,64))=lower('0x40495a781095932e2fc8dcca69f5e358711fdd41') --use validator address, not operator address

)

i on b.tx_hash=i.tx_hash and lower(b.vault)=lower(i.reward_vault)

group by 1,2,3,4)

select tx_hash, block as block, token, validator_commission from (

select tx_hash, block, 'BGT' as token, validator_commission from BGT_rewards

union all

select tx_hash, cast(block as number) as block, name as token, amount from incentives

where sign(cast(block as number)-5048136) = 0

order by block desc