Expose structured LongBridge dry-run order previews

Author: Pigbibi

application/execution_service.py

@@ -247,6 +247,7 @@ class ExecutionCycleResult:
     skip_logs: tuple[str, ...]
     note_logs: tuple[str, ...]
     action_done: bool
+    dry_run_orders: tuple[dict, ...] = ()
 
 
 DEFAULT_SAFE_HAVEN_CASH_SUBSTITUTE_THRESHOLD_USD = 1000.0
@@ -257,6 +258,13 @@ def _noop_sleep(_seconds):
     return None
 
 
+def _coerce_order_quantity(value):
+    try:
+        return float(str(value).replace(",", "").strip())
+    except (TypeError, ValueError):
+        return value
+
+
 def _safe_haven_cash_symbols(*, portfolio: dict, allocation: dict) -> tuple[str, ...]:
     symbols: list[str] = []
     for symbol in allocation.get("safe_haven_symbols", ()):
@@ -565,6 +573,7 @@ def execute_rebalance_cycle(
     logs: list[str] = []
     skip_logs: list[str] = []
     note_logs: list[str] = []
+    dry_run_orders: list[dict] = []
     small_account_cash_note_keys: set[str] = set()
     action_done = False
     sell_submitted = False
@@ -678,6 +687,18 @@ def record_dry_run(symbol, side, quantity, price, *, order_type):
         price_text = f"${price:.2f}" if price is not None else translator("order_type_market")
         side_key = "side_buy" if str(side).lower() == "buy" else "side_sell"
         order_type_key = "order_type_limit" if order_type == "limit" else "order_type_market"
+        order_payload = {
+            "symbol": str(symbol or "").strip().upper(),
+            "side": str(side or "").strip().lower(),
+            "quantity": _coerce_order_quantity(quantity),
+            "order_type": str(order_type or "").strip().lower(),
+            "status": "dry_run",
+        }
+        if price is not None:
+            order_payload["price"] = round(float(price), 4)
+            if order_type == "limit":
+                order_payload["limit_price"] = round(float(price), 4)
+        dry_run_orders.append(order_payload)
         message = translator(
             "dry_run_order",
             side=translator(side_key),
@@ -1110,4 +1131,5 @@ def record_dry_run(symbol, side, quantity, price, *, order_type):
         skip_logs=tuple(skip_logs),
         note_logs=tuple(note_logs),
         action_done=action_done,
+        dry_run_orders=tuple(dry_run_orders),
     )

main.py

@@ -132,16 +132,20 @@ def _summarize_cycle_result_for_report(cycle_result, *, dry_run: bool) -> dict:
     logs = tuple(getattr(cycle_result, "logs", ()) or ())
     skip_logs = tuple(getattr(cycle_result, "skip_logs", ()) or ())
     note_logs = tuple(getattr(cycle_result, "note_logs", ()) or ())
+    dry_run_orders = tuple(getattr(cycle_result, "dry_run_orders", ()) or ())
     order_events_count = len(logs)
-    orders_previewed_count = order_events_count if dry_run else 0
-    return {
+    orders_previewed_count = len(dry_run_orders) if dry_run_orders else (order_events_count if dry_run else 0)
+    summary = {
         "action_done": bool(getattr(cycle_result, "action_done", False)),
         "order_events_count": order_events_count,
         "orders_previewed_count": orders_previewed_count,
         "orders_skipped_count": len(skip_logs),
         "notes_count": len(note_logs),
         "dry_run_order_preview_available": bool(dry_run and orders_previewed_count > 0),
     }
+    if dry_run_orders:
+        summary["orders_previewed"] = [dict(order) for order in dry_run_orders]
+    return summary
 
 
 signal_text = build_signal_text(t)

tests/test_rebalance_service.py

@@ -380,6 +380,9 @@ def estimate_max_purchase_quantity(_trade_context, symbol, **_kwargs):
         self.assertIn("02800.HK", joined_logs)
         self.assertIn("03033.HK", joined_logs)
         self.assertNotIn(".US", joined_logs)
+        self.assertGreaterEqual(len(result.dry_run_orders), 1)
+        self.assertTrue(all(order["status"] == "dry_run" for order in result.dry_run_orders))
+        self.assertTrue(all(order["symbol"].endswith(".HK") for order in result.dry_run_orders))
 
     def test_run_strategy_prefers_portfolio_port_runtime_path(self):
         sent_messages = []

tests/test_request_handling.py

@@ -582,6 +582,10 @@ def test_cycle_result_summary_counts_dry_run_order_previews(self):
             skip_logs=("skip",),
             note_logs=("note",),
             action_done=True,
+            dry_run_orders=(
+                {"symbol": "02800.HK", "side": "buy", "quantity": 100, "status": "dry_run"},
+                {"symbol": "03033.HK", "side": "buy", "quantity": 200, "status": "dry_run"},
+            ),
         )
 
         summary = module._summarize_cycle_result_for_report(cycle_result, dry_run=True)
@@ -592,6 +596,7 @@ def test_cycle_result_summary_counts_dry_run_order_previews(self):
         self.assertEqual(summary["orders_skipped_count"], 1)
         self.assertEqual(summary["notes_count"], 1)
         self.assertTrue(summary["dry_run_order_preview_available"])
+        self.assertEqual(summary["orders_previewed"][0]["symbol"], "02800.HK")
 
 
 if __name__ == "__main__":