Разработка дашборда мониторинга DePIN-сети

Разработка дашборда мониторинга DePIN-сети

DePIN (Decentralized Physical Infrastructure Networks) — это Helium, Filecoin, Hivemapper, GEODNET, io.net и десятки других протоколов, где физические устройства (hotspot, сенсор, GPU, антенна) майнят токены за предоставление реальных ресурсов. Дашборд мониторинга для DePIN — это не просто "показать баланс". Это real-time состояние оборудования, аптайм, накопленные rewards, position на карте, сравнение с соседними нодами.

Специфика данных DePIN-сетей

В отличие от DeFi, где данные полностью on-chain, DePIN-данные гибридны:

Для Helium: основные данные по устройствам доступны через Helium API (api.helium.io). Solana chain используется для токен-транзакций. Helium migration в 2023 году перенесла сеть на Solana — это важный контекст при интеграции со старыми источниками данных.

Архитектура дашборда

Data ingestion layer

DePIN Protocol APIs ──┐
Blockchain RPCs ───────┼──► Ingestion Service ──► TimescaleDB
WebSocket feeds ───────┘          │
                                  └──► Redis (realtime state)

TimescaleDB для time-series метрик: rewards по времени, аптайм, throughput. Redis для текущего состояния нод — быстрый доступ без SQL запросов на каждый refresh.

Пример: мониторинг Helium IoT hotspot

interface HotspotMetrics {
  address: string
  name: string
  lat: number
  lng: number
  status: "online" | "offline" | "relayed"
  lastPoC: Date
  rewardScale: number
  witnessCount: number
  dailyRewards: number  // HNT
  uptimePercent: number
}

class HeliumDataService {
  private baseUrl = "https://api.helium.io/v1"

  async getHotspotMetrics(hotspotAddress: string): Promise<HotspotMetrics> {
    const [hotspot, rewards, witnesses] = await Promise.all([
      this.fetch(`/hotspots/${hotspotAddress}`),
      this.fetch(`/hotspots/${hotspotAddress}/rewards/sum?min_time=-1%20day`),
      this.fetch(`/hotspots/${hotspotAddress}/witnesses`)
    ])

    return {
      address: hotspotAddress,
      name: hotspot.data.name,
      lat: hotspot.data.lat,
      lng: hotspot.data.lng,
      status: hotspot.data.status.online ? "online" : "offline",
      lastPoC: new Date(hotspot.data.last_poc_challenge),
      rewardScale: hotspot.data.reward_scale,
      witnessCount: witnesses.data.length,
      dailyRewards: rewards.data.total,
      uptimePercent: this.calculateUptime(hotspot.data)
    }
  }
}

Карта устройств

DePIN сети — это физическое покрытие территории. Карта — обязательный компонент. MapLibre GL или Deck.gl для рендеринга тысяч точек без performance деградации:

import { Map } from "maplibre-gl"
import { ScatterplotLayer } from "@deck.gl/layers"

const deviceLayer = new ScatterplotLayer({
  data: hotspots,
  getPosition: (d) => [d.lng, d.lat],
  getRadius: (d) => d.status === "online" ? 200 : 100,
  getFillColor: (d) => {
    if (d.status === "offline") return [255, 50, 50]
    if (d.rewardScale < 0.5) return [255, 165, 0]
    return [50, 205, 50]
  },
  pickable: true,
  onClick: ({ object }) => setSelectedHotspot(object)
})

Для гексагональных сеток (как в Helium H3 coverage) — H3-js библиотека от Uber:

import { h3ToGeo, kRing, polyfill } from "h3-js"

// Все H3 гексагоны в радиусе 2 от устройства
const neighbors = kRing(deviceH3Index, 2)

Realtime обновления

WebSocket для live данных

// Server (Node.js)
import { WebSocketServer } from "ws"

const wss = new WebSocketServer({ port: 8080 })

// Периодическое обновление активных устройств
setInterval(async () => {
  const updates = await fetchBatchMetrics(activeDeviceIds)
  const message = JSON.stringify({ type: "metrics_update", data: updates })

  wss.clients.forEach(client => {
    if (client.readyState === client.OPEN) client.send(message)
  })
}, 30000)  // каждые 30 секунд

// Client (React)
function useRealtimeMetrics(deviceId: string) {
  const [metrics, setMetrics] = useState<DeviceMetrics | null>(null)

  useEffect(() => {
    const ws = new WebSocket(WS_URL)
    ws.onmessage = (event) => {
      const { type, data } = JSON.parse(event.data)
      if (type === "metrics_update") {
        const deviceData = data.find(d => d.address === deviceId)
        if (deviceData) setMetrics(deviceData)
      }
    }
    return () => ws.close()
  }, [deviceId])

  return metrics
}

Ключевые виджеты дашборда

Rewards chart: area chart с накопленными rewards по дням/неделям/месяцам. recharts или visx для React. Данные из TimescaleDB через time_bucket агрегацию.

Uptime heatmap: GitHub contribution graph-стиль, где каждый день = ячейка с цветом по проценту аптайма. Моментально показывает паттерны проблем.

Network rank: позиция устройства относительно всей сети или географического кластера. Мотивирует оператора и помогает выявлять проблемы с оборудованием.

Alerts feed: последние события: устройство ушло offline, пропущен PoC, резкое падение rewards. Каждый алерт — с timestamp и контекстом.

ROI калькулятор: стоимость оборудования + электричество vs. накопленные rewards в USD по историческому курсу. Для мультиустройственных операторов — общий P&L.

Мультипротокольный дашборд

Оператор часто держит устройства нескольких сетей. Единый дашборд через адаптеры:

interface DePINAdapter {
  getDeviceMetrics(deviceId: string): Promise<DeviceMetrics>
  getRewardsHistory(deviceId: string, days: number): Promise<RewardPoint[]>
  getNetworkStats(): Promise<NetworkStats>
}

class HeliumAdapter implements DePINAdapter { /* ... */ }
class FilecoinAdapter implements DePINAdapter { /* ... */ }
class IoNetAdapter implements DePINAdapter { /* ... */ }

// Unified dashboard data
const allMetrics = await Promise.allSettled(
  devices.map(d => getAdapter(d.protocol).getDeviceMetrics(d.id))
)

Сроки разработки

День 1-2: Data ingestion layer, интеграция с API целевого протокола, TimescaleDB схема.

День 3: React дашборд — базовые виджеты (метрики, rewards chart, alerts).

День 4: Карта устройств, realtime WebSocket обновления.

День 5: Финальная полировка, мобильная адаптация, деплой.

Итого 3-5 дней для дашборда с картой, realtime данными и ключевыми метриками для одного протокола. Мультипротокольная поддержка добавляет 1-2 дня на адаптеры.