Real-time market intelligence across crypto, macro, forex, commodities, global equities, and options. NEXUS combines blockchain analytics, macroeconomic data, exchange rates, commodity futures, global stock quotes, and derivatives data into one terminal-style platform that runs primarily on free public APIs.

NEXUS is an open-source finance intelligence platform for traders, analysts, desks, and researchers who need cross-asset visibility without stitching together half a dozen terminals. It still includes the original crypto intelligence stack (whales, smart money, entities, memecoin scanner), but now also ships real macro calendars, FRED indicators, forex rates, commodities, global equities, and live Deribit options chains.

• Cross-Asset Terminal — Compare crypto, forex, commodities, indices, and macro indicators in one dashboard
• Macro Intelligence — FRED-backed rates, inflation, employment, growth, yield curve, and a real economic calendar
• Forex Monitoring — Major FX pairs with IDR priority and TradFi alert support
• Commodities Dashboard — Precious metals, energy, agriculture, industrial metals, and livestock futures
• Global Equities — Major stocks across US, Europe, Asia, Australia, Singapore, Canada, India, Korea, Taiwan, Brazil, and IDX
• Real Options Chain — BTC/ETH Deribit options with bid/ask, IV, Greeks, OI, and expiry tabs
• Structured Alerts — Price threshold, forex rate, macro event, whale, smart money, and prediction alerts
• Whale Wallet Tracking — Monitor large holders across 6 blockchain networks
• Smart Money Detection — AI-powered scoring identifies accumulation, distribution, and exit patterns
• Entity Mapping — Connect wallets to known entities (exchanges, funds, protocols, whales)
• DeFi Protocol Analytics — Track TVL, yields, protocol revenue, and sector dominance
• Meme Token Detection — Real-time Pump.fun / Raydium token creation with hype scoring engine
• DEX Sniper Scanner — /scanner page with sub-second WebSocket updates showing new liquidity pools with risk scoring

One command starts everything — PostgreSQL, Redis, database seeding, Next.js app, WebSocket server, and blockchain indexer:

git clone https://github.com/oyi77/1ai-nexus.git
cd 1ai-nexus/nexus
docker compose up --build

This boots 5 services:

Open http://localhost:4400 — login with admin / admin.

Production: https://tracker.aitradepulse.com

# Prerequisites: Node.js 20+, PostgreSQL 16, Redis 7
brew services start postgresql@16
docker-compose up -d redis

# Install and setup
npm install
npm run db:push
npm run db:seed

# Run
npm run dev          # Next.js on :4400
cd ws-server && npm run dev  # WebSocket on :4401
cd indexer && npm run dev    # Blockchain indexer

git clone https://github.com/oyi77/1ai-nexus.git
cd 1ai-nexus/nexus
cp .env.example .env
sed -i "s/NEXTAUTH_SECRET=.*/NEXTAUTH_SECRET=$(openssl rand -hex 32)/" .env
sed -i "s/POSTGRES_PASSWORD=.*/POSTGRES_PASSWORD=$(openssl rand -hex 16)/" .env
sed -i "s/NEXUS_API_KEYS=.*/NEXUS_API_KEYS=$(openssl rand -hex 32)/" .env
docker compose up -d --build
curl http://localhost:4400/api/v1/status

# Create bot via @BotFather, then:
echo "TELEGRAM_BOT_TOKEN=your-token" >> .env
docker compose restart web

docker compose exec postgres pg_dump -U nexus nexus > backup_$(date +%Y%m%d).sql

┌─────────────────────────────────────────────────────────┐
│                    NEXUS Platform                        │
├──────────────┬──────────────┬───────────────────────────┤
│  Next.js 16  │  WS Sidecar  │    Blockchain Indexer     │
│  (Port 4400) │  (Port 4401) │    (ETH/SOL/BTC/ARB/OP)  │
├──────────────┴──────────────┴───────────────────────────┤
│                    Redis Pub/Sub                         │
├─────────────────────────────────────────────────────────┤
│                    Prisma 6 ORM                          │
├─────────────────────────────────────────────────────────┤
│              PostgreSQL 16 + Redis 7                     │
└─────────────────────────────────────────────────────────┘

• Frontend: Next.js 16, React 19, Tailwind CSS 4, Recharts, Socket.io-client
• Backend: Next.js API Routes, Prisma 6 ORM, Zod validation
• Real-Time: Socket.io WebSocket sidecar, Redis Pub/Sub event bus
• Blockchain: Standard JSON-RPC subscriptions (eth_subscribe), Solana WebSocket API, Bitcoin REST polling, Alchemy Enhanced APIs, DeFiLlama, Etherscan, Helius, Jupiter
• Database: PostgreSQL 16, Redis 7
• Auth: NextAuth.js with credentials provider
• Infrastructure: Docker Compose, multi-stage builds

All endpoints use the standard { data, meta, error } envelope.

GET  /api/v1/alerts            — User alert configurations
POST /api/v1/alerts            — Create structured alert
PATCH /api/v1/alerts           — Toggle alert enabled/disabled
DELETE /api/v1/alerts?id=...   — Delete alert
GET  /api/v1/alerts/evaluate   — Evaluate active alerts against live data

GET  /api/v1/fear-greed        — Composite fear & greed with history
GET  /api/v1/macro             — FRED / Treasury / World Bank macro indicators
GET  /api/v1/calendar          — FRED release calendar + central bank schedules
GET  /api/v1/indonesia-macro   — Indonesia macro indicators + BI rate
GET  /api/v1/global-macro      — Multi-country macro snapshot
GET  /api/v1/forex             — FX rates (dedicated backend route)
GET  /api/v1/commodities       — Commodity futures snapshot by category
GET  /api/v1/equities          — Global equities and major indices
GET  /api/v1/correlations      — Cross-asset correlations
GET  /api/v1/gaps              — Cross-venue dislocations and kimchi premium
GET  /api/v1/stablecoins       — Stablecoin peg monitor

GET  /api/v1/market/prices     — Core crypto market snapshot
GET  /api/v1/news              — News feed
GET  /api/v1/flows             — Capital flow data
GET  /api/v1/smart-money       — Smart money signals and scores
GET  /api/v1/predictions       — Prediction market data
GET  /api/v1/defi/overview     — DeFi TVL / yields / fees overview
GET  /api/v1/revenue           — Protocol revenue snapshot
GET  /api/v1/yields            — Yield pools
GET  /api/v1/status            — Infra + data source health
GET  /api/v1/modules/fetch     — Generic module passthrough (internal/debug use)

Connect to ws://localhost:4401 with Bearer token (auth-protected namespaces require it; public namespaces don't):

import { io } from "socket.io-client";

const socket = io("http://localhost:4401", {
  auth: { token: "your-api-key" }
});

// Real-time trade events
socket.on("trade", (data) => {
  console.log(`${data.chain}: ${data.from} → ${data.to}`);
});

// Smart money signals
socket.on("smart-money", (signal) => {
  console.log(`${signal.type}: ${signal.entity} score=${signal.score}`);
});

/dexscreener — Real-time token boost data from DexScreener WebSocket

/memecoins — Raw DEX token activity (swap events + new token creation)

Scanner client example:

const ws = new WebSocket("wss://tracker-ws.aitradepulse.com/socket.io/?EIO=4&transport=websocket")
ws.onopen = () => {
  ws.send("40/dexscreener")  // subscribe to /dexscreener namespace
  ws.send("40/memecoins")    // subscribe to /memecoins namespace
}
ws.onmessage = (event) => {
  if (event.data.startsWith("42/dexscreener,")) {
    const [, data] = JSON.parse(event.data.slice(16))
    if (data[0] === "boost") console.log("Boosted token:", data[1])
  }
}

/trades, /alerts, /prices, /flows, /orderbook, /derivatives, /liquidations — require Bearer token.

nexus/
├── src/
│   ├── app/                    # Next.js App Router pages
│   │   ├── (dashboard)/        # Dashboard layout group
│   │   ├── api/                # REST API routes
│   │   ├── dashboard/          # Main dashboard
│   │   ├── entities/           # Entity explorer
│   │   ├── smart-money/        # Smart money signals
│   │   ├── flows/              # Capital flow visualization
│   │   ├── predictions/        # Prediction markets
│   │   ├── tokens/             # Token analytics
│   │   └── alerts/             # Alert management
│   ├── components/             # React components
│   │   ├── domain/             # Business domain components
│   │   ├── entity/             # Entity cards, graphs, tables
│   │   ├── predictions/        # Market cards, order books
│   │   └── ui/                 # Shared UI primitives
│   └── lib/                    # Shared utilities
│       ├── alerts/             # Alert engine (evaluator, delivery)
│       ├── api/                # API middleware (auth, rate-limit)
│       ├── events/             # Redis event publisher
│       └── ws/                 # WebSocket client
├── indexer/                    # Blockchain indexer (separate process)
│   ├── chains/                 # Chain-specific listeners
│   │   ├── ethereum.ts         # ETH/ARB/BASE/OP via eth_subscribe
│   │   ├── solana.ts           # SOL via accountSubscribe
│   │   └── bitcoin.ts          # BTC via Blockstream REST polling
│   ├── processors/             # Transaction decoding & smart money detection
│   └── publisher.ts            # Redis event publisher
├── ws-server/                  # WebSocket sidecar (separate process)
│   ├── server.ts               # Socket.io server with DexScreener WS + token scoring
│   ├── auth.ts                 # Bearer token authentication
│   ├── score.ts                # Token scoring engine (hype score 0-100)
│   ├── subscriber.ts           # Redis event subscriber
│   └── __tests__/              # Score engine unit tests
├── prisma/
│   ├── schema.prisma           # Database schema (12 models)
│   └── seed.ts                 # Seed script (50 entities, 500 markets)
└── docker-compose.yml          # Unified Docker Compose (5 services)

12 models covering the full intelligence stack:

• Entity — Tracked organizations (whales, funds, exchanges, protocols)
• Wallet — Blockchain addresses linked to entities
• Trade — Decoded on-chain transactions with smart money scoring
• Flow — Capital movement between entities
• Signal — Smart money detection events
• PredictionMarket — Crypto prediction markets
• MarketPosition — User positions in prediction markets
• Alert — User-configured alert conditions
• AlertDelivery — Alert webhook delivery log
• IndexerCheckpoint — Blockchain sync state per chain
• Token — Tracked token metadata
• User — Authentication and API key management

All configuration via environment variables. Zero required for local development with Docker Compose.

Override any RPC endpoint to use your own node infrastructure:

# .env
ETH_WS_URL=wss://your-own-eth-node.example.com
SOLANA_WS_URL=wss://your-own-solana-rpc.example.com

• Track whale wallet movements before they impact price
• Get real-time alerts when smart money accumulates or distributes
• Monitor capital flows between exchanges and DeFi protocols

• Map wallet clusters to known entities
• Analyze transaction patterns across multiple chains
• Build custom dashboards with real-time data feeds

• Integrate whale tracking into your trading bot via WebSocket API
• Build custom alert systems using the REST API
• Extend the indexer with new chains or transaction types

• Study whale behavior patterns and market impact
• Analyze smart money timing relative to price movements
• Track prediction market accuracy over time

1. Fork the repository
2. Create a feature branch: git checkout -b feature/my-feature
3. Make your changes
4. Run tests: npm test
5. Submit a pull request

MIT License — see LICENSE for details.

• PolyEdge Trading Bot — Plugin-based trading bot with NEXUS integration
• Blockstream API — Bitcoin blockchain explorer API
• Public Node — Free public blockchain RPC endpoints

Keywords: crypto whale tracker, on-chain analytics, blockchain intelligence, smart money detection, whale wallet tracking, DeFi analytics, real-time blockchain monitoring, Ethereum analytics, Solana analytics, Bitcoin analytics, crypto transaction tracker, whale alert, on-chain data platform, open-source crypto analytics