Розробка системи відстеження 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 у тому ж блоці, значить, маніпуляція. Ми використовуємо статистичний фільтр: раптове падіння без відповідного зростання обсягу — червоний прапор. Алгоритм автоматично ігнорує підозрілі лістинги, поки вони не підтвердяться на вторинному ринку.

Як ми будуємо 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, яка працює швидше за конкурентів.