select

block_timestamp,

tx_hash,

'0x' || substr(parse_json(topics)[1]::string, -40) as account,

contract_address as rv_address,

utils.udf_hex_to_int(data) / power(10, 18) as staked_amount

from berachain.testnet.fact_event_logs

where

topics[0] = '0x9e71bc8eea02a63969f509818f2dafb9254532904319f9dbda79b67bd34a5f3d' -- Staked event signature

and tx_succeeded = 'TRUE'

),

withdrawal_events as (

select

block_timestamp,

tx_hash,

'0x' || substr(parse_json(topics)[1]::string, -40) as account,

contract_address as rv_address,

utils.udf_hex_to_int(data) / power(10, 18) as withdrawn_amount

from berachain.testnet.fact_event_logs

where

topics[0] = '0x7084f5476618d8e60b11ef0d7d3f06914655adb8793e28ff7f018d4c76d505d5' -- Withdraw event signature

and tx_succeeded = 'TRUE'

),

users_rv_data_raw as (

select

block_timestamp,

tx_hash,

account,

rv_address,

staked_amount as amount

from staked_events

union all