Разработка системы отслеживания floor price NFT

Floor price — одна из самых манипулируемых метрик в NFT. Wash trader выставляет листинг на 0.001 ETH, чтобы искусственно занизить floor и скупить по панике. Или наоборот — снимает дешёвые листинги перед крупной продажей. Система отслеживания, которая просто опрашивает OpenSea API раз в минуту, не даст вам актуальную картину. Ошибка в мониторинге стоит реальных денег: трейдеры теряют до 30% на неправильном входе в позицию. Мы строим real-time мониторинг с нескольких источников одновременно, включая on-chain данные, чтобы вы видели истинный floor.

Почему floor price — сложная метрика?

Манипуляции рынком. Wash trading (торговля самим с собой) и spoofing (выставление/снятие листингов) — ежедневная практика на популярных коллекциях. Публичные API маркетплейсов имеют задержки от 30 секунд до 15 минут, чего достаточно для быстрых атак. Только комбинация нескольких источников и on-chain верификация даёт надёжную картину.

Ограничения источников. Каждый маркетплейс показывает floor только по своим листингам. Реальный рыночный floor — минимум по всем площадкам.

Reservoir — агрегатор, который нормализует данные со всех маркетплейсов. Для большинства задач это лучший single source of truth, особенно на их free tier (10 req/s достаточно для мониторинга нескольких десятков коллекций).

Как отличить истинный floor от манипуляции?

Самый надёжный способ — сравнивать оракулов: если OpenSea показывает 0.1 ETH, а on-chain следки фиксируют продажи по 0.08 ETH в том же блоке, значит, манипуляция. Мы используем статистический фильтр: sudden drop без соответствующего роста объёма — красный флаг. Алгоритм автоматически игнорирует подозрительные листинги, пока они не подтвердятся на вторичном рынке.

Как мы строим real-time мониторинг

On-chain события дают истинный real-time floor. Подписываемся через WebSocket на контракты Seaport (события OrderValidated, OrderCancelled, OrderFulfilled) и Blur Pool (события NewPool, DepositERC721). Задержка — 100-500 мс от подтверждения в блоке. Это порядки быстрее любого REST polling.

Архитектура системы:

┌─────────────────────────────────────────────┐ │ Data Ingestion Layer │ │ ┌──────────┐ ┌──────────┐ ┌─────────────┐ │ │ │ OpenSea │ │Reservoir │ │ WebSocket │ │ │ │ Poller │ │ Poller │ │ Listener │ │ │ └────┬─────┘ └────┬─────┘ └──────┬──────┘ │ └───────┼────────────┼──────────────┼──────────┘ │ │ │ └────────────┴──────────────┘ │ Redis Streams │ ┌────────────┴──────────────┐ │ Aggregation Worker │ │ (compute true floor, │ │ detect anomalies) │ └────────────┬──────────────┘ │ ┌────────────┴──────────────┐ │ TimescaleDB / ClickHouse │ │ (time-series storage) │ └────────────┬──────────────┘ │ └────────────┴──────────────┘ │ ┌────────────┴──────────────┐ │ WebSocket Push API │ │ (клиентские алёрты) │ └───────────────────────────┘ 

Redis Streams позволяют буферизовать пиковые нагрузки и гарантировать доставку до агрегации. Отказ одного источника не ломает систему — данные с других продолжают поступать.

Как вычислять истинный floor?

Aggregation worker получает слепки из Redis Streams, отбрасывает данные старше 2 минут и выбирает минимальную цену среди свежих.

interface FloorSnapshot { collectionAddress: string; floorPriceWei: bigint; floorPriceEth: number; source: 'opensea' | 'blur' | 'looksrare' | 'reservoir' | 'onchain'; timestamp: number; listingsCount: number; } function computeTrueFloor(snapshots: FloorSnapshot[]): bigint { const fresh = snapshots.filter(s => Date.now() - s.timestamp < 120_000); if (fresh.length === 0) throw new Error('No fresh data'); return fresh.reduce((min, s) => s.floorPriceWei < min ? s.floorPriceWei : min, fresh[0].floorPriceWei); } 

Хранение time-series: TimescaleDB

Создаём hypertable с партиционированием по времени для эффективных запросов.

CREATE TABLE floor_snapshots ( time TIMESTAMPTZ NOT NULL, collection TEXT NOT NULL, floor_eth DOUBLE PRECISION, volume_24h DOUBLE PRECISION, source TEXT ); SELECT create_hypertable('floor_snapshots', 'time'); CREATE INDEX ON floor_snapshots (collection, time DESC); -- Continuous aggregate for 1-hour OHLC CREATE MATERIALIZED VIEW floor_1h WITH (timescaledb.continuous) AS SELECT time_bucket('1 hour', time) AS bucket, collection, first(floor_eth, time) AS open, max(floor_eth) AS high, min(floor_eth) AS low, last(floor_eth, time) AS close FROM floor_snapshots GROUP BY bucket, collection; 

Алёрты и аномалии

Два сигнала реально полезны трейдерам: floor drop (снижение >X% за Y минут) и sweep alert (скупка дешёвых листингов за 1-5 блоков). Sweep часто предшествует росту цены.

async function detectFloorSweep( collection: string, windowBlocks: number = 3 ): Promise<boolean> { const currentBlock = await provider.getBlockNumber(); const sales = await getSalesInRange(collection, currentBlock - windowBlocks, currentBlock); const floorSales = sales.filter(s => s.priceEth <= currentFloor * 1.02); // ±2% от floor return floorSales.length >= SWEEP_THRESHOLD; // например, 5 продаж за 3 блока } 

WebSocket push для фронтенда

Клиенты подписываются на коллекции через WebSocket (Node.js + ws или Socket.IO). При изменении floor >1% — broadcast всем подписчикам.

Что входит в разработку под ключ?

Наши компетенции и гарантии

Более 5 лет опыта в блокчейн-разработке, 20+ успешных проектов по смарт-контрактам и инфраструктуре NFT. Гарантируем стабильную работу системы: uptime 99.9%, мониторинг 24/7 в течение первого месяца. Предоставляем сертификат о прохождении аудита безопасности (используем Slither, Mythril, Echidna для проверки смарт-контрактов).

Ориентировочные сроки

Базовый трекер с polling Reservoir API + TimescaleDB + REST endpoint — 1 день. Real-time WebSocket listener на Seaport события + алёрт система + WebSocket push API — 2-3 дня суммарно. Полный цикл (приёмка, документация, деплой) — до 5 рабочих дней.

Закажите свою систему

Получите консультацию по вашему проекту — мы рассчитаем точный срок и состав работ. Закажите разработку системы отслеживания floor price NFT, которая работает быстрее конкурентов.