Real-Time Crypto Market Engine
A backend-optimized full-stack system for live monitoring, price comparison, and volume analysis across multiple crypto exchanges.
What This Is
This project is a real-time cryptocurrency data aggregator that collects, normalizes, and compares live order book and pricing data from multiple exchanges. It provides a backend-optimized system for monitoring price differences, analyzing volume trends, and visualizing order book depth — all in one live web interface. The goal of this project is to demonstrate skills in real-time systems architecture, backend development, and full-stack deployment using modern tools and practices.
Where is it going?
Select the tech stack and design the system architecture for the project.
Set up the ingestion engine and infrastructure for trade and candle data using a few exchanges.
Build the CalcStream service to aggregate live trades into OHLCV candles and allow for custom rolling averages.
Created a WebSocket server handle user subscriptions and stream real-time updates to the frontend.
Design and implement a responsive UI with real-time chart updates using WebSockets.
Onboard more exchanges for better market coverage and price comparison.
Expand the CalcStream service to support more custom rolling averages and indicators for analysis.
Investigate and implement AI modules to generate predictive analytics and trading signals.
Investigate and implement user authentication and authorization for secure access to the platform.
Add user accounts, saved preferences, and personalized data streams.
Add paper trading functionality to allow users to test strategies with simulated trades.
Enable secure real-money trading through exchange APIs with risk controls.
Improve the user interface with better visualizations and user experience.
Key Features
- Real-time order book aggregation
- Live price and volume analytics
- Dynamic spread calculation
- Scalable, containerized architecture
- Resource-efficient "idle mode"
Tech Stack
- Backend: TypeScript, Redis, InfluxDB
- Frontend: Next.js, React, TailwindCSS
- Deployment: Docker, Docker Compose, GitLab CI/CD
How It Works
Ingestion Service
Connects to multiple crypto exchanges via WebSockets, normalizes order book data, and stores it in Redis for real-time access. Pricing and volume metrics are streamed into InfluxDB.
Calc-Stream Service
Processes live data (e.g., price spread comparisons, volume surges) and updates Redis or InfluxDB accordingly. It includes an "idle mode" that pauses calculations when no users are viewing the frontend, saving compute resources.
WebSocket Service
Handles WebSocket connections from the frontend and forwards real-time data to the frontend. It will be responsible for handling WebSocket connections and storing user preferences.
Frontend (Next.js)
A responsive UI that displays real-time analytics, exchange comparisons, and a breakdown of how the system is architected. The frontend fetches live updates via API and renders them in a dashboard format.