fix: remove legacy RebalancingService and migrate WebSocket broadcast to AutoRebalancerService

backend/src/index.ts

@@ -8,7 +8,6 @@ import { v1Router } from './api/v1Router.js'
 import { errorHandler, notFound } from './middleware/errorHandler.js'
 import { legacyApiDeprecation } from './middleware/legacyApiDeprecation.js'
 import { globalRateLimiter } from './middleware/rateLimit.js'
-import { RebalancingService } from './monitoring/rebalancer.js'
 import { AutoRebalancerService } from './services/autoRebalancer.js'
 import { logger } from './utils/logger.js'
 import { databaseService } from './services/databaseService.js'
@@ -226,14 +225,8 @@ wss.on('connection', (ws) => {
     })
 })
 
-// Start existing rebalancing service (now queue-backed, no cron)
-try {
-    const rebalancingService = new RebalancingService(wss)
-    rebalancingService.start()
-    console.log('[REBALANCING-SERVICE] Monitoring service started (queue-backed)')
-} catch (error) {
-    console.error('Failed to start rebalancing service:', error)
-}
+// Wire wss into autoRebalancer so it can push real-time portfolio events to clients
+autoRebalancer.setWss(wss)
 
 // Start server
 server.listen(port, async () => {

backend/src/services/autoRebalancer.ts

@@ -1,3 +1,4 @@
+import { WebSocketServer } from 'ws'
 import { StellarService } from './stellar.js'
 import { ReflectorService } from './reflector.js'
 import { rebalanceHistoryService } from './serviceContainer.js'
@@ -12,6 +13,7 @@ export class AutoRebalancerService {
     private stellarService: StellarService
     private reflectorService: ReflectorService
     private isRunning = false
+    private wss: WebSocketServer | null = null
 
     // Configuration (kept for getStatus() compatibility)
     private readonly CHECK_INTERVAL = 30 * 60 * 1000        // 30 minutes
@@ -136,4 +138,56 @@ export class AutoRebalancerService {
             }
         }
     }
+
+    /**
+     * Inject the WebSocket server so portfolio events can be pushed to clients.
+     * Called from index.ts once wss is available.
+     */
+    setWss(wss: WebSocketServer): void {
+        this.wss = wss
+    }
+
+    /**
+     * Returns true once setWss() has been called.
+     */
+    hasWss(): boolean {
+        return this.wss !== null
+    }
+
+    // ─── WebSocket broadcasting ──────────────────────────────────────────────
+
+    /**
+     * Push a portfolio-specific event to all connected WebSocket clients.
+     */
+    notifyClients(portfolioId: string, event: string, data: Record<string, unknown> = {}): void {
+        if (!this.wss) return
+        const message = JSON.stringify({
+            type: 'portfolio_update',
+            portfolioId,
+            event,
+            data,
+            timestamp: new Date().toISOString(),
+        })
+        this.wss.clients.forEach(client => {
+            if (client.readyState === 1) client.send(message)
+        })
+        logger.info(`[AUTO-REBALANCER] Pushed "${event}" event to WebSocket clients`, { portfolioId })
+    }
+
+    /**
+     * Broadcast a market-wide event to all connected WebSocket clients.
+     */
+    broadcastToAllClients(event: string, data: Record<string, unknown> = {}): void {
+        if (!this.wss) return
+        const message = JSON.stringify({
+            type: 'market_update',
+            event,
+            data,
+            timestamp: new Date().toISOString(),
+        })
+        this.wss.clients.forEach(client => {
+            if (client.readyState === 1) client.send(message)
+        })
+        logger.info(`[AUTO-REBALANCER] Broadcast "${event}" to all WebSocket clients`)
+    }
 }