On-chain diver 🤿

Вкатываемся в Flipside (аналог дюны с бесплатным апи)
Пост 4 из 4

📝 Для создания таблицы активности по конкретному токену на основе сделок на DEX'ах, мы подготовим две вспомогательные таблицы: одну для покупок (raw_buys), другую для продаж (raw_sells). Эти таблицы будут содержать информацию о сделках, где пользователи покупали или продавали указанный токен за ETH.

В таблице сделок есть две очень важных переменных - token_in и token_out т.е. токен на входе, который отправлял пользователь (продавал) в обмен на токен, который получал на выходе, который он купил. Для нашей задачи:

- raw_buys будет содержать сделки, где пользователи покупали указанный токен за ETH.
- raw_sells будет содержать сделки, где пользователи продавали указанный токен за ETH.

Поскольку Flipside обрабатывает данные с задержкой и цены в долларах для сделок не появятся сразу, нам нужно будет подтянуть цены WETH из другой таблицы и умножить их на количество токенов WETH для каждой сделки, чтобы получить сумму сделки в долларах.

with eth_prices as(
select 
  hour,
  token_address,
  symbol,
  price
from 
  ethereum.price.ez_prices_hourly
where 
  token_address = '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2'
and 
  hour::date >= current_date - 7
),
raw_sells as(
  select 
    block_number,
    tx_hash,
    block_timestamp,
    origin_from_address wallet,
    '🔴 sell' type,
    symbol_in sold_token,
    amount_in sold_amount,
    symbol_out bought_token,
    amount_out bought_amount,
    round(amount_out * last_value(price) ignore nulls over (order by eth_prices.hour desc), 2) as amount_usd
  from 
    ethereum.defi.ez_dex_swaps swaps
  left join 
    eth_prices
  on 
    date_trunc('hour', swaps.block_timestamp) = eth_prices.hour
  and 
    swaps.symbol_out = eth_prices.symbol
  where 
    token_in = '{{token_address}}'
),
raw_buys as(
select 
  block_number,
  tx_hash,
  block_timestamp,
  origin_from_address wallet,
  '🟢 buy' type,
  symbol_in sold_token,
  amount_in sold_amount,
  symbol_out bought_token,
  amount_out bought_amount,
  round(amount_in * last_value(price) ignore nulls over (order by eth_prices.hour desc), 2) as amount_usd
from 
  ethereum.defi.ez_dex_swaps swaps
left join 
  eth_prices
on 
  date_trunc('hour', swaps.block_timestamp) = eth_prices.hour
and 
  swaps.symbol_in = eth_prices.symbol
where 
  token_out = '{{token_address}}'
)

select * from raw_buys
union all
select * from raw_sells
order by block_timestamp desc

Я объединил указанные запросы в дашборде, который вы можете самостоятельно протестировать после входа на сайт и настроить под свои данные. В таблицах также можно провалиться и изучить код. Все таблицы и графики интерактивные, данные из таблиц можно копировать. В самой таблице в левом нижнем углу есть строка поиска, которая поможет найти значения любого столбца (важно: адреса в Flipside хранятся в нижнем регистре, поэтому если вы введете адрес с большими буквами, таблица не отфильтруется).

📚Содержимое постов также добавлено в гайд по ончейн аналитике

Индексер сделок Raydium/pump.fun Solana с прямым доcтупом к базе clickhouse

👍12

1.87K viewsedited 20:55