SELECT

block_timestamp,

tx_id,

tx_to as to_address,

'SOL' as symbol,

amount,

0 as amount_usd,

0 as current_amount_usd

FROM solana.core.fact_transfers as a

LEFT JOIN (

SELECT

RECORDED_HOUR::date as date,

symbol,

AVG(close) as price_usd,

LAST_VALUE(price_usd) OVER (PARTITION BY symbol ORDER BY DATE) as current_price

FROM solana.core.fact_token_prices_hourly

WHERE date >= '2022-07-01'

AND symbol LIKE 'SOL'

GROUP BY date, symbol

) p

ON p.date = block_timestamp::date

WHERE tx_from IN ('DwEAXyPRtEJyxtWNCStsfd2sVabzTXmRDzE1Sv6cyjcU', '4GsmCJ1c69BD7iX2BqPYB4Jy4a35gG8mjpuM7dPEqijG')

AND tx_to IN ('9w31QPPhzK6J4jdhJ4GqW5znAyrqipypk21XTuYEFxEQ', 'A9qLNSEcQCtjgJueNFqiyUFMxntD3i98LqsSznA9Neny', 'ANyhL1DYzSNhL2sCrzmigqwTE7SJrqFgfgDL5bc8PdNF', '9XnhcxqYX8URSYXVgCuS3DF39KLw3a8MBTrLkRXRXiJS')

order by block_timestamp

), flow_payments as (

SELECT

block_timestamp,

-- block_height,

tx_id,

-- event_contract,

event_data:to as to_address,

-- token,

symbol,

event_data:amount as amount,

amount * avg_price_usd as amount_usd,