price_list as (

select token_contract,

symbol,

avg(price_usd) as price

from flow.core.fact_prices

group by token_contract, symbol

),

blocto_wallets as (

select

distinct(tx_id),

block_timestamp::date as date,

event_contract,

event_type,

proposer

from flow.core.fact_events a

join flow.core.fact_transactions b

using(tx_id)

where b.tx_succeeded = 1

and block_timestamp::date >= '{{ date }}'

and event_contract = 'A.39e42c67cc851cfb.EmeraldIdentityDapper'

),

wallet_token_transfer as (

select

tr.tx_id,

block_timestamp::date as date,

amount,

price_list.price,

tr.token_contract,

recipient

from flow.core.ez_token_transfers tr

join blocto_wallets

join price_list