fix: bind LongBridge paper commands to runtime scope

Co-Authored-By: Codex <noreply@openai.com>

Author: Pigbibi

application/paper_execution_command_consumer.py

@@ -213,6 +213,7 @@ def consume_due_paper_execution_commands(
     market_data_port: Any,
     runtime_release_receipt: Mapping[str, Any] | None,
     expected_strategy_release: StrategyReleaseIdentity | Mapping[str, object] | None,
+    expected_command_binding: Mapping[str, object] | None,
 ) -> dict[str, object]:
     """Claim and simulate due paper commands through the shared lifecycle."""
 
@@ -227,4 +228,5 @@ def consume_due_paper_execution_commands(
         ),
         runtime_release_receipt=runtime_release_receipt,
         expected_strategy_release=expected_strategy_release,
+        expected_command_binding=expected_command_binding,
     )

main.py

@@ -1027,6 +1027,11 @@ def run_paper_execution_command_consumer() -> bool:
             market_data_port=composer.broker_adapters.build_market_data_port(quote_context),
             runtime_release_receipt=config.runtime_release_receipt,
             expected_strategy_release=config.expected_strategy_release,
+            expected_command_binding={
+                "platform": "longbridge",
+                "account_scope": str(config.execution_state_account_scope or "unknown"),
+                "strategy_profile": str(config.strategy_profile or "unknown"),
+            },
         )
         report_status = "ok" if result.get("status") == "ok" else "skipped"
         finalize_runtime_report(

tests/test_paper_execution_command_consumer.py

@@ -104,6 +104,14 @@ def _portfolio(*, include_unmanaged: bool = False) -> PortfolioSnapshot:
     )
 
 
+def _command_binding() -> dict[str, str]:
+    return {
+        "platform": "longbridge",
+        "account_scope": "paper",
+        "strategy_profile": "soxl_soxx_trend_income",
+    }
+
+
 def test_paper_consumer_simulates_reconciled_orders_and_never_calls_an_execution_port(tmp_path: Path) -> None:
     store = ExecutionCommandStore(local_dir=tmp_path)
     command = _command()
@@ -118,6 +126,7 @@ def test_paper_consumer_simulates_reconciled_orders_and_never_calls_an_execution
         market_data_port=_MarketDataPort(),
         runtime_release_receipt=build_runtime_loaded_receipt(strategy_release=release),
         expected_strategy_release=release,
+        expected_command_binding=_command_binding(),
     )
 
     assert result["status"] == "ok"
@@ -169,6 +178,7 @@ def test_paper_consumer_requires_runtime_release_before_claiming(tmp_path: Path)
         market_data_port=_MarketDataPort(),
         runtime_release_receipt=None,
         expected_strategy_release=_release_identity(),
+        expected_command_binding=_command_binding(),
     )
 
     assert result["status"] == "blocked"
@@ -190,6 +200,7 @@ def test_paper_consumer_rejects_unbound_or_unreconciled_commands(tmp_path: Path)
         market_data_port=_MarketDataPort(),
         runtime_release_receipt=build_runtime_loaded_receipt(strategy_release=release),
         expected_strategy_release=release,
+        expected_command_binding=_command_binding(),
     )
 
     assert result["commands"][0]["status"] == "rejected"
@@ -217,6 +228,7 @@ def test_paper_consumer_rejects_risk_receipt_bound_to_another_decision(tmp_path:
         market_data_port=_MarketDataPort(),
         runtime_release_receipt=build_runtime_loaded_receipt(strategy_release=release),
         expected_strategy_release=release,
+        expected_command_binding=_command_binding(),
     )
 
     assert result["commands"][0]["status"] == "rejected"

tests/test_request_handling.py

@@ -475,6 +475,8 @@ def build_rebalance_config(self):
                     execution_command_store="command-store",
                     runtime_release_receipt={"attestation_state": "self_attested"},
                     expected_strategy_release={"release_id": "release-1"},
+                    execution_state_account_scope="paper-command-verify",
+                    strategy_profile=module.STRATEGY_PROFILE,
                 )
 
             def build_reporting_adapters(self):
@@ -510,6 +512,14 @@ def fake_consume(**kwargs):
         self.assertEqual(observed["consumer"]["store"], "command-store")
         self.assertEqual(observed["consumer"]["portfolio"], "portfolio-snapshot")
         self.assertEqual(observed["consumer"]["market_data_port"], "market-data-port")
+        self.assertEqual(
+            observed["consumer"]["expected_command_binding"],
+            {
+                "platform": "longbridge",
+                "account_scope": "paper-command-verify",
+                "strategy_profile": module.STRATEGY_PROFILE,
+            },
+        )
 
     def test_handle_probe_checks_account_snapshot_without_success_notification(self):
         module = load_module()