feat: implement Redis for distributed rate limiting and caching (#171, #85)

Author: elizabetheonoja-art

.env.example

@@ -1,9 +1,9 @@
 # Database Configuration
 DATABASE_URL="postgresql://postgres:password@localhost:5432/tradeflow?schema=public"
 
-# Alternative Database Configuration (for TypeORM)
-DB_HOST=localhost
-DB_PORT=5432
-DB_USERNAME=postgres
-DB_PASSWORD=password
-DB_DATABASE=tradeflow
+# Redis Configuration
+REDIS_URL="redis://localhost:6379"
+
+# Security Configuration
+JWT_SECRET="generate-a-safe-secret-key-here"
+ADMIN_PASSWORD="TradeFlow2026!"

config/redis.js

@@ -0,0 +1,23 @@
+/**
+ * Centralized Redis Client Connection
+ * Shared across API instances for rate limiting and price caching
+ */
+const Redis = require('ioredis');
+
+// In a real production deployment, this URL would come from environment
+const REDIS_URL = process.env.REDIS_URL || 'redis://localhost:6379';
+
+const redisClient = new Redis(REDIS_URL, {
+    maxRetriesPerRequest: null,
+    enableReadyCheck: true
+});
+
+redisClient.on('connect', () => {
+    console.log('🚀 Redis Connection Established - Synchronization Active');
+});
+
+redisClient.on('error', (err) => {
+    console.error('⚠️ Redis Connection Failed:', err.message);
+});
+
+module.exports = redisClient;

package-lock.json

@@ -31,6 +31,7 @@
     "start:ws": "node server.js"
   },
   "dependencies": {
+    "@nest-lab/throttler-storage-redis": "^1.2.0",
     "@nestjs/common": "^10.4.22",
     "@nestjs/config": "^3.2.3",
     "@nestjs/core": "^10.4.22",
@@ -43,9 +44,11 @@
     "@types/jsonwebtoken": "^9.0.10",
     "axios": "^1.13.6",
     "class-validator": "^0.14.4",
+    "ioredis": "^5.10.1",
     "jsonwebtoken": "^9.0.3",
     "pg": "^8.11.0",
     "prisma": "^5.19.1",
+    "rate-limit-redis": "^4.3.1",
     "reflect-metadata": "^0.2.2",
     "rxjs": "^7.8.2",
     "swagger-ui-express": "^5.0.0",

package.json

@@ -1,6 +1,8 @@
 import { Module, NestModule, MiddlewareConsumer, RequestMethod } from '@nestjs/common';
 import { APP_GUARD, APP_FILTER } from '@nestjs/core';
 import { ThrottlerModule, ThrottlerGuard } from '@nestjs/throttler';
+import { ThrottlerStorageRedisService } from '@nest-lab/throttler-storage-redis';
+import Redis from 'ioredis';
 import { AppController } from './app.controller';
 import { AppService } from './app.service';
 import { HealthModule } from './health/health.module';
@@ -17,7 +19,23 @@ import { JwtMiddleware } from './common/middleware/jwt.middleware';
 import { WebhookController } from './webhooks/webhook.controller';
 
 @Module({
-  imports: [PrismaModule, HealthModule, RiskModule, AuthModule, AnalyticsModule, SwapModule, TokensModule, OgModule],
+  imports: [
+    PrismaModule, 
+    HealthModule, 
+    RiskModule, 
+    AuthModule, 
+    AnalyticsModule, 
+    SwapModule, 
+    TokensModule, 
+    OgModule,
+    ThrottlerModule.forRoot({
+      throttlers: [{
+        ttl: 60000,
+        limit: 10,
+      }],
+      storage: new ThrottlerStorageRedisService(new Redis(process.env.REDIS_URL || 'redis://localhost:6379'))
+    }),
+  ],
   controllers: [AppController, WebhookController],
   providers: [
     AppService,