修正市場情報 operator drill API gate

routes/market_intel_review_routes.py

@@ -241,80 +241,6 @@ def _build_review_decision_transaction_stack(
     )
 
 
-def _live_inventory_from_postwrite_smoke(postwrite_smoke_result):
-    postwrite_smoke_result = (
-        postwrite_smoke_result if isinstance(postwrite_smoke_result, dict) else {}
-    )
-    row_summaries = postwrite_smoke_result.get("row_summaries") or []
-    return {
-        "mode": "live_db_inventory_from_postwrite_smoke_preview",
-        "summary_ready": bool(postwrite_smoke_result.get("postwrite_smoke_passed")),
-        "read_only_query_executed": bool(
-            postwrite_smoke_result.get("read_only_query_executed")
-        ),
-        "database_connection_opened": False,
-        "database_session_created": False,
-        "database_write_executed": False,
-        "database_commit_executed": False,
-        "external_network_executed": False,
-        "scheduler_attached": False,
-        "writes_executed": False,
-        "would_write_database": False,
-        "total_rows": postwrite_smoke_result.get("found_count"),
-        "alert_review_state_breakdown": [],
-        "table_statuses": [
-            {
-                "table": "market_alert_review_queue",
-                "exists": bool(row_summaries),
-                "row_count": len(row_summaries),
-                "status": "from_postwrite_smoke_result",
-            }
-        ],
-    }
-
-
-def _build_review_decision_transaction_stack_from_postwrite_evidence(
-    *,
-    service,
-    sample_result,
-    payload_error,
-    operator_evidence,
-    writer_output,
-    postwrite_smoke_result,
-    limit,
-):
-    transaction_preview, handoff = _build_closeout_stack(
-        service=service,
-        sample_result=sample_result,
-        payload_error=payload_error,
-        operator_evidence=operator_evidence,
-        writer_output=writer_output,
-        postwrite_smoke_result=postwrite_smoke_result,
-        limit=limit,
-    )
-    inventory = build_candidate_queue_review_inventory(
-        review_handoff=handoff,
-        postwrite_smoke=postwrite_smoke_result,
-        live_db_inventory=_live_inventory_from_postwrite_smoke(
-            postwrite_smoke_result
-        ),
-        operator_evidence=operator_evidence,
-        execute_requested=False,
-    )
-    decision = build_candidate_queue_review_decision(
-        review_inventory=inventory,
-        operator_evidence=operator_evidence,
-    )
-    approval = build_candidate_queue_review_decision_approval(
-        review_decision=decision,
-        operator_evidence=operator_evidence,
-    )
-    return build_candidate_queue_review_decision_transaction(
-        decision_approval=approval,
-        operator_evidence=operator_evidence,
-    )
-
-
 @market_intel_review_bp.route(
     "/api/market_intel/manual_sample_review/candidate_queue_review_inventory",
     methods=["POST"],
@@ -525,7 +451,7 @@ def market_intel_manual_sample_candidate_queue_review_decision_writer_postwrite_
     sample_result, operator_evidence, writer_output, smoke_result, payload_error, limit = (
         _extract_run_payload()
     )
-    transaction = _build_review_decision_transaction_stack_from_postwrite_evidence(
+    transaction = _build_review_decision_transaction_stack(
         service=service,
         sample_result=sample_result,
         payload_error=payload_error,
@@ -533,6 +459,7 @@ def market_intel_manual_sample_candidate_queue_review_decision_writer_postwrite_
         writer_output=writer_output,
         postwrite_smoke_result=smoke_result,
         limit=limit,
+        execute_requested=False,
     )
     data = build_candidate_queue_review_decision_writer_postwrite_smoke(
         transaction_preview=transaction,
@@ -553,7 +480,7 @@ def market_intel_manual_sample_candidate_queue_review_decision_writer_operator_d
     sample_result, operator_evidence, writer_output, smoke_result, payload_error, limit = (
         _extract_run_payload()
     )
-    transaction = _build_review_decision_transaction_stack_from_postwrite_evidence(
+    transaction = _build_review_decision_transaction_stack(
         service=service,
         sample_result=sample_result,
         payload_error=payload_error,
@@ -561,6 +488,7 @@ def market_intel_manual_sample_candidate_queue_review_decision_writer_operator_d
         writer_output=writer_output,
         postwrite_smoke_result=smoke_result,
         limit=limit,
+        execute_requested=False,
     )
     writer_status = build_candidate_queue_review_decision_writer_cli_plan(
         transaction_preview=transaction,