with

tables as (

blocK_timestamp,

tx_hash,

tx:receipt as receipt,

tx:public_key as public_key,

tx:signer_id as signer_id,

tx:receiver_id as receiver_id

FROM near.core.fact_transactions

),----------------------------------------------------------------------------------------------------------------

tabl as (

SELECT

block_timestamp,

tx_hash,

public_key,

signer_id,

receiver_id,

seq,key,path,index,

replace(value:outcome:logs[0], '\\') as logs,

check_json(logs) as checks

FROM tables,

table(flatten(input => receipt))

),----------------------------------------------------------------------------------------------------------------

g as (

SELECT

block_timestamp,

tx_hash,

public_key,

signer_id,

receiver_id,

try_parse_json(logs) as parse_logs,

parse_logs:type as type,

parse_logs:params:buyer_id as buyer_id,

parse_logs:params:owner_id as owner_id,