Update ranker_logging.py

ranker_logging.py

@@ -238,7 +238,7 @@ class RankerLogger:
 
     def trade_open(self, trade_id: str, asset: str, direction: str, price: float, qty: float):
         """Log trade opening."""
-        metadata = {"trade_id": trade_id, "price": price, "qty": qty}
+        metadata = {"trade_id": trade_id, "price": price, "qty": qty, "direction": direction}
         self._log(LogLevel.INFO, EventCategory.TRADE,
                   f"TRADE OPENED | ID={trade_id} | Dir={direction} | Entry={price:.4f} | Qty={qty:.6f}",
                   asset=asset, metadata=metadata)
@@ -332,6 +332,70 @@ class RankerLogger:
                 "logs": entries
             }, f, indent=2)
 
+    @staticmethod
+    def make_trade_ws_hook(ws_send_fn):
+        """
+        Factory for the on_event callback that forwards TRADE log entries to the
+        Executo Hub via WebSocket.
+
+        Usage in your executor space ranker:
+
+            import asyncio, json
+            from ranker_logging import RankerLogger
+
+            async def connect_to_hub():
+                # ws = your websockets/websocket-client connection to the hub
+                ranker_logger = RankerLogger(
+                    name="QuasarAXRVI_V75",
+                    on_event=RankerLogger.make_trade_ws_hook(
+                        lambda payload: asyncio.create_task(ws.send(json.dumps(payload)))
+                    )
+                )
+
+        Args:
+            ws_send_fn: callable(dict) → sends a dict as JSON to the hub WS publisher.
+                        Can be a coroutine wrapper or sync function.
+        """
+        def _hook(entry: dict) -> None:
+            if entry.get("category") != "TRADE":
+                return
+            msg  = entry.get("message", "")
+            meta = entry.get("metadata") or {}
+            ts   = entry.get("timestamp", "")
+
+            if "TRADE OPENED" in msg:
+                payload = {
+                    "type": "trade_opened",
+                    "data": {
+                        "trade_id":  meta.get("trade_id"),
+                        "asset":     entry.get("asset"),
+                        "direction": meta.get("direction", "?"),
+                        "entry":     meta.get("price"),
+                        "qty":       meta.get("qty", 0.0),
+                        "opened_at": ts,
+                    },
+                }
+            elif "TRADE CLOSED" in msg:
+                payload = {
+                    "type": "trade_closed",
+                    "data": {
+                        "trade_id":  meta.get("trade_id"),
+                        "asset":     entry.get("asset"),
+                        "pnl":       meta.get("pnl", 0.0),
+                        "exit_price": meta.get("exit_price"),
+                        "closed_at": ts,
+                    },
+                }
+            else:
+                return
+
+            try:
+                ws_send_fn(payload)
+            except Exception:
+                pass   # never let a WS error crash the ranker
+
+        return _hook
+
 
 class RankerLogBridge:
     """