Разработка бота для мониторинга ликвидности
Uniswap v3 сделал управление ликвидностью активным занятием. LP-позиция в диапазоне $1800-$2200 по ETH/USDC отлично работала неделю — до тех пор, пока цена не вышла за границу, и позиция перестала зарабатывать fees, конвертировавшись полностью в один актив. Без мониторинга такое может оставаться незамеченным днями. Это прямые потери от упущенных комиссий и impermanent loss.
Что реально нужно отслеживать в пулах DEX
Uniswap v3: активность позиций и out-of-range события
Каждая позиция в Uniswap v3 задаётся (tokenId, tickLower, tickUpper). Пул хранит текущий tick — логарифмическую цену. Как только currentTick < tickLower или currentTick > tickUpper — позиция out-of-range, fees не начисляются.
Событие Swap в пуле emits новый tick. Бот подписывается на Swap через WebSocket (eth_subscribe("logs", {address: poolAddress, topics: [Swap.topic]})), декодирует tick из данных события и сравнивает с tickLower/tickUpper всех отслеживаемых позиций. Latency от события до уведомления — 100-500ms, что достаточно для информирования LP.
Дополнительно полезно отслеживать Mint и Burn события — они показывают, когда крупные LP входят или выходят из диапазона, что часто предшествует движению цены.
Curve: disbalance пула и de-peg мониторинг
В Curve StableSwap пул считается сбалансированным, когда доли активов близки к целевым (обычно равным). При сильном дисбалансе (например, 90% USDT и 10% USDC в 3pool) slippage при свопах резко растёт, а эффективный APY для LP падает.
Метрика для мониторинга: отклонение текущих балансов от идеальных. Вызов get_balances() + сравнение с total_supply() / N. Если один актив занимает >70% — алерт. Такое случалось с 3pool во время деpegging событий (USDC в марте 2023 кратковременно торговался по $0.87 на Curve).
The Graph для исторических данных
Для мониторинга TVL и объёмов пула в реальном времени используем The Graph subgraph Uniswap v3 (subgraph id: 5zvR82QoaXYFyDEKLZ9t6v9adgnptxYpKpSbxtgVENFV). GraphQL запрос каждые 60 секунд возвращает pool.totalValueLockedUSD, pool.volumeUSD, pool.feesUSD. Для крупных пулов с >$10M TVL это достаточно. Для мелких пулов с быстрыми изменениями — прямые события через WebSocket надёжнее.
Архитектура бота
Типичная система мониторинга состоит из трёх компонентов:
| Компонент | Технология | Задача |
|---|---|---|
| Event listener | ethers.js / viem WebSocket | Подписка на on-chain события |
| State aggregator | Node.js / Python | Агрегация и сравнение с порогами |
| Alert dispatcher | Telegram Bot API / PagerDuty | Уведомления по каналам |
Event listener подписывается через WebSocket на пулы из конфигурационного списка. При получении события декодирует данные через ABI и публикует в очередь (Redis Pub/Sub или in-memory queue).
State aggregator читает очередь, обновляет состояние пулов (текущий tick, balances, TVL) и проверяет условия алертов. Здесь же — периодический polling (каждые 30-60 секунд) для метрик, которые не emitят события (например, accumulated fees позиции через NonfungiblePositionManager.collect).
Alert dispatcher дедуплицирует алерты (один алерт в 5 минут по одной позиции), форматирует сообщение и отправляет в Telegram или webhook. Для production систем — PagerDuty с severity levels.
Расчёт accumulated fees без транзакции
Текущие накопленные fees LP-позиции можно посчитать off-chain, не делая collect (которая стоит газ). Формула из Uniswap v3 whitepaper через feeGrowthInside:
fees0 = liquidity * (feeGrowthInside0 - feeGrowthInside0Last) / 2^128
fees1 = liquidity * (feeGrowthInside1 - feeGrowthInside1Last) / 2^128
feeGrowthInside считается из данных пула по ticks — это статик-колл, не транзакция. Показывать пользователю накопленные fees в реальном времени полезно для принятия решений о rebalancing.
Стек и интеграции
viem (TypeScript) для on-chain взаимодействия — типизированные вызовы, встроенный ABI-декодер, поддержка multicall для батчинга запросов. The Graph для исторических данных и агрегированных метрик. Redis для state хранения между рестартами и дедупликации. Telegram Bot API как основной канал уведомлений.
Для многочейн мониторинга (Ethereum + Arbitrum + Optimism) — параллельные WebSocket подключения с одним агрегатором. Uniswap v3 развёрнут на всех трёх чейнах, адреса пулов разные, но ABI идентичен.
Процесс работы
Конфигурация (1 день). Список пулов, позиций, пороговые значения для алертов.
Разработка (3-5 дней). Event listener + state aggregator + Telegram/webhook интеграция. Тест на testnet (Sepolia с форкнутым Uniswap v3 state через Foundry vm.createFork).
Деплой. VPS с минимум 2 CPU / 4GB RAM, dedicated full node или Alchemy/QuickNode WebSocket endpoint. Мониторинг бота через pm2 + health check endpoint.
Ориентиры по срокам
Базовый бот (один DEX, Telegram алерты): 3-5 дней. Многочейн система с историческими метриками и dashboard: 2-3 недели.