El motor · Operativo
Nexus — el motor de inteligencia de datos.
Ingesta, normalización, enriquecimiento, cómputo y servicio de datos on-chain de múltiples DEX de Solana — en tiempo real. Parseo determinista verificado contra la blockchain.
Pipeline
Del validador a tu stack — en cinco etapas.
Una única ruta normalizada desde el estado bruto de Solana hasta APIs, streams en tiempo real y alertas inteligentes.
2.4M
events / day
126K
wallets tracked
8.7K
tokens tracked
Ingesta
Yellowstone gRPC
Normalización
Parser determinista
Cómputo
ClickHouse + PostgreSQL + Redis
Consulta
REST + WebSocket
Alertas
Notificaciones en tiempo real
$ pipeline.nexus // operativo
Capacidades
Siete capas, un único motor.
Ingesta en tiempo real
El estado de Solana se transmite a través de Yellowstone gRPC, capturando transacciones de swap en múltiples exchanges descentralizados desde el borde del validador.
Los eventos se filtran por protocolo y se normalizan en un esquema consistente de 20 campos según llegan — sin ETL por lotes, sin esperas nocturnas.
// specs
- latencia
- sub-segundo
- cadena
- solana mainnet
- protocolo
- yellowstone gRPC
- estado
- operativo
Normalización determinista
Un parser propietario identifica al trader, los tokens intercambiados y las cantidades exactas de cada swap — usando un método determinista basado en el firmante de la transacción y los cambios de balance.
El mismo método funciona en todos los protocolos DEX soportados porque se basa en propiedades del protocolo Solana, no en heurísticas específicas de cada DEX. Cada campo está verificado contra la blockchain.
// specs
- dex soportados
- múltiples protocolos
- método
- determinista
- verificación
- campo a campo vs RPC
- lenguaje
- node.js
Capa de cómputo
Diez workers independientes procesan el stream de eventos normalizado en paralelo. El enriquecimiento de precios calcula precios de tokens a partir de ratios de swap. El seguimiento de posiciones FIFO calcula el P&L realizado de cada wallet.
La agregación de métricas produce rankings en múltiples ventanas temporales. Cada worker es stateless y event-driven — la complejidad está en las reglas, no en el runtime.
// specs
- workers
- 10 independientes
- métricas
- wallets + tokens
- ventanas
- 7 ventanas temporales
- rankings
- 58 leaderboards
Almacenamiento
Los eventos de swap inmutables se almacenan en un motor analítico columnar optimizado para consultas de agregación. El estado calculado — métricas de wallets, métricas de tokens, evaluaciones de riesgo — vive en una base de datos relacional con garantías ACID.
Los rankings precalculados y la caché en tiempo real se sirven desde un almacén en memoria con lecturas sub-milisegundo.
// specs
- analítica
- motor columnar
- estado
- relacional (primario + réplica)
- caché
- almacén en memoria
- retención
- configurable
Consulta y API
Los endpoints REST sirven perfiles de wallets, analítica de tokens, rankings y evaluaciones de riesgo. Una petición de perfil ejecuta ocho queries en paralelo y devuelve la imagen completa de una wallet en menos de 50 milisegundos.
Los canales WebSocket entregan alertas en tiempo real por usuario con entrega sub-segundo.
// specs
- acceso
- rest + websocket
- auth
- sesión + claves api
- endpoints
- 135+
- latencia
- < 50ms
Evaluación de riesgo
Un motor de evaluación de riesgo independiente analiza el comportamiento de wallets mediante cinco detectores de fraude modulares: wash trading, bots de sandwich, anomalía de cero pérdidas, frecuencia extrema y dominancia de token único.
Cada flag de riesgo incluye la evidencia específica que lo disparó — los números, umbrales y patrones observados. La frecuencia de evaluación se adapta a la antigüedad de la wallet: las nuevas se comprueban cada 5 minutos, las establecidas cada 6 horas.
// specs
- detectores
- 5 modulares
- evidencia
- auditable por flag
- tiers
- frecuencia adaptativa
- historial
- log de transiciones
Observabilidad y seguridad
La plataforma opera en una red privada segmentada en siete capas aisladas con espacios de direcciones dedicados. Las credenciales se gestionan mediante un almacén cifrado y se inyectan en tiempo de despliegue — nunca se almacenan en código.
La monitorización cubre métricas de sistema, métricas de aplicación y métricas de negocio a través de un stack de observabilidad completo con dashboards, agregación de logs y alertas operativas.
// specs
- red
- 7 capas aisladas
- secretos
- almacén cifrado
- monitorización
- stack completo
- acceso
- basado en roles