flat_logs as (

select

block_timestamp,

tx_hash,

receiver_id,

value as log

from near.core.fact_receipts r,

lateral flatten(input => r.logs)

),

nep_tokens as (

select distinct

block_timestamp,

tx_hash,

receiver_id as token_contract,

'nep141' as type

from flat_logs

where true

and try_parse_json(replace(log,'EVENT_JSON:','')):standard::string = 'nep141'

select * from nep_tokens

order by block_timestamp asc

limit 100