fix: history_ready event — frontend refetch apos replay completo

backend/mt5_collector.py

@@ -15,9 +15,10 @@ logging.basicConfig(level=logging.INFO, format="%(asctime)s [%(levelname)s] %(me
 logger = logging.getLogger("mt5_collector")
 
 class MT5Collector:
-    def __init__(self, aggregator: Aggregator, on_update_callback: Callable[[dict, Optional[dict]], Any]):
+    def __init__(self, aggregator: Aggregator, on_update_callback: Callable[[dict, Optional[dict]], Any], on_history_ready_callback: Callable = None):
         self.aggregator = aggregator
         self.on_update_callback = on_update_callback
+        self.on_history_ready_callback = on_history_ready_callback
         self.symbol = settings.MT5_SYMBOL
         self.running = False
         self.connected = False
@@ -177,6 +178,8 @@ class MT5Collector:
                 if not self._history_annotated and len(ticks) < 1000:
                     self._history_annotated = True
                     await self.annotate_history_bar_volume()
+                    if self.on_history_ready_callback:
+                        self.on_history_ready_callback()
 
                 if len(ticks) > 0:
                     logger.info(f"Fetched {len(ticks)} ticks starting at {ticks[0]['time_msc']}")

backend/server.py

@@ -44,8 +44,20 @@ def broadcast_update(active_json: dict, closed_json: Optional[dict]):
     for connection in list(active_connections):
         asyncio.create_task(safe_send(connection, message))
 
+def broadcast_history_ready():
+    """Notify all clients that historical replay is complete — they should refetch /history."""
+    if not active_connections:
+        return
+    async def _send():
+        for ws in list(active_connections):
+            try:
+                await ws.send_json({"type": "history_ready"})
+            except Exception:
+                active_connections.discard(ws)
+    asyncio.create_task(_send())
+
 # Initialize MT5 Collector
-collector = MT5Collector(aggregator, on_update_callback=broadcast_update)
+collector = MT5Collector(aggregator, on_update_callback=broadcast_update, on_history_ready_callback=broadcast_history_ready)
 
 async def _start_collector_delayed():
     """Wait a moment for the server to fully start, then begin polling MT5."""

frontend/src/App.jsx

@@ -78,7 +78,9 @@ export default function App() {
     
     if (msg.type === 'init') {
       setActiveCluster(msg.active);
-      fetchHistory(); // Sync history on connection
+      fetchHistory();
+    } else if (msg.type === 'history_ready') {
+      fetchHistory(); // Replay completo — busca histórico atualizado
     } else if (msg.type === 'tick') {
       setActiveCluster(msg.active);
       if (msg.active?.bid) setLastBid(msg.active.bid);