flat_logs as (

select

block_timestamp,

tx_hash,

receiver_id,

value as log,

try_parse_json(replace(log,'EVENT_JSON:','')) as log_json

from near.core.fact_receipts r,

lateral flatten(input => r.logs)

),

stader_logs as (

select

block_timestamp,

tx_hash,

receiver_id,

log_json:event as event,

log_json:data[0]:amount/pow(10,24) as amt,

log_json:data[0]:sender_id as from_id,

log_json:data[0]:receiver_id as to_id,

log_json:data[0]:msg as msg

from flat_logs

where true

and receiver_id in (

'v2-nearx.stader-labs.near',

'nearx.stader-labs.near'

)

and log_json:standard = 'nearx'

and log_json:event in (

'ft_transfer',

'ft_transfer_call'

)

select