目前只定義告警候選與人工審核流程；不建立 alert queue、不建立 review queue、不執行審核動作、不派送 Telegram、不呼叫 LLM、不寫 DB。${blockers ? `阻擋：${escapeHtml(blockers)}` : ''}
+ 目前只定義告警候選、人工審核流程與審核佇列資料契約；不建立 alert queue、不建立 review queue、不建立 review table、不執行審核動作、不派送 Telegram、不呼叫 LLM、不寫 DB。${blockers ? `阻擋：${escapeHtml(blockers)}` : ''}
dedupe=${escapeHtml(throttle.dedupe_window_hours || 'n/a')}h / telegram_daily=${escapeHtml(throttle.max_telegram_candidates_per_day || 0)} / ai_digest=${escapeHtml(throttle.max_ai_briefing_items_per_digest || 0)}
APPROVAL POLICY
${
diff --git a/tests/test_market_intel_skeleton.py b/tests/test_market_intel_skeleton.py
index 81ebc4b..64f5c57 100644
--- a/tests/test_market_intel_skeleton.py
+++ b/tests/test_market_intel_skeleton.py
@@ -477,6 +477,9 @@ def test_market_intel_preview_template_uses_safe_fetch_false_endpoint():
assert "data-market-intel-opportunity-alert-payload" in template
assert "data-market-intel-opportunity-alert-review" in template
assert "data-market-intel-opportunity-alert-actions" in template
+ assert "data-market-intel-opportunity-alert-queue-contract" in template
+ assert "data-market-intel-opportunity-alert-priority-lanes" in template
+ assert "data-market-intel-opportunity-alert-queue-indexes" in template
assert "data-market-intel-opportunity-alert-approval" in template
assert "data-market-intel-opportunity-alert-sequence" in template
assert "data-market-intel-migration" in template
@@ -527,7 +530,7 @@ def test_legacy_source_bridge_default_is_planned_only():
bridge = MarketIntelService().build_legacy_source_bridge()
assert bridge["mode"] == "legacy_source_bridge_planned"
- assert bridge["phase"] == "phase_40_deployment_readiness_modularized"
+ assert bridge["phase"] == "phase_41_alert_review_queue_contract"
assert bridge["execute_requested"] is False
assert bridge["read_only_query_executed"] is False
assert bridge["database_connection_opened"] is False
@@ -685,7 +688,7 @@ def test_mcp_tool_contract_preview_is_read_only_and_whitelisted():
contract = MarketIntelService().build_mcp_tool_contract()
assert contract["mode"] == "mcp_tool_contract_preview"
- assert contract["phase"] == "phase_40_deployment_readiness_modularized"
+ assert contract["phase"] == "phase_41_alert_review_queue_contract"
assert contract["caller"] == "market_intel"
assert contract["contract_ready"] is True
assert contract["blocked_reasons"] == []
@@ -818,7 +821,7 @@ def test_mcp_activation_runbook_route_is_preview_only():
assert response.status_code == 200
assert data["mode"] == "mcp_activation_runbook_preview"
- assert data["phase"] == "phase_40_deployment_readiness_modularized"
+ assert data["phase"] == "phase_41_alert_review_queue_contract"
assert data["deployment_actions_executed"] is False
assert data["docker_command_executed"] is False
assert data["ssh_command_executed"] is False
@@ -831,7 +834,7 @@ def test_mcp_fetch_gate_default_blocks_external_fetch():
gate = MarketIntelService().build_mcp_fetch_gate(fetch_requested=True)
assert gate["mode"] == "mcp_fetch_gate_planned"
- assert gate["phase"] == "phase_40_deployment_readiness_modularized"
+ assert gate["phase"] == "phase_41_alert_review_queue_contract"
assert gate["fetch_requested"] is True
assert gate["manual_fetch_gate_open"] is False
assert gate["network_request_allowed"] is False
@@ -901,7 +904,7 @@ def test_mcp_fetch_gate_route_is_preview_only():
assert response.status_code == 200
assert data["mode"] == "mcp_fetch_gate_planned"
- assert data["phase"] == "phase_40_deployment_readiness_modularized"
+ assert data["phase"] == "phase_41_alert_review_queue_contract"
assert data["fetch_requested"] is False
assert data["network_request_allowed"] is False
assert data["external_network_executed"] is False
@@ -913,7 +916,7 @@ def test_scheduler_plan_preview_blocks_job_attachment():
plan = MarketIntelService().build_scheduler_plan()
assert plan["mode"] == "scheduler_attach_plan_preview"
- assert plan["phase"] == "phase_40_deployment_readiness_modularized"
+ assert plan["phase"] == "phase_41_alert_review_queue_contract"
assert plan["ready_to_attach_scheduler"] is False
assert plan["scheduler_attached"] is False
assert plan["scheduler_registration_executed"] is False
@@ -951,7 +954,7 @@ def test_scheduler_plan_route_is_preview_only():
assert response.status_code == 200
assert data["mode"] == "scheduler_attach_plan_preview"
- assert data["phase"] == "phase_40_deployment_readiness_modularized"
+ assert data["phase"] == "phase_41_alert_review_queue_contract"
assert data["scheduler_registration_executed"] is False
assert data["crawler_job_started"] is False
assert data["external_network_executed"] is False
@@ -962,7 +965,7 @@ def test_match_review_plan_preview_blocks_auto_confirm():
plan = MarketIntelService().build_match_review_plan()
assert plan["mode"] == "match_review_plan_preview"
- assert plan["phase"] == "phase_40_deployment_readiness_modularized"
+ assert plan["phase"] == "phase_41_alert_review_queue_contract"
assert plan["ready_for_review_queue"] is False
assert plan["review_queue_created"] is False
assert plan["auto_match_executed"] is False
@@ -998,7 +1001,7 @@ def test_match_review_plan_route_is_preview_only():
assert response.status_code == 200
assert data["mode"] == "match_review_plan_preview"
- assert data["phase"] == "phase_40_deployment_readiness_modularized"
+ assert data["phase"] == "phase_41_alert_review_queue_contract"
assert data["review_queue_created"] is False
assert data["auto_confirm_executed"] is False
assert data["external_network_executed"] is False
@@ -1009,7 +1012,7 @@ def test_opportunity_plan_preview_blocks_alerts_and_ai_summary():
plan = MarketIntelService().build_opportunity_plan()
assert plan["mode"] == "opportunity_plan_preview"
- assert plan["phase"] == "phase_40_deployment_readiness_modularized"
+ assert plan["phase"] == "phase_41_alert_review_queue_contract"
assert plan["ready_for_opportunity_queue"] is False
assert plan["opportunity_queue_created"] is False
assert plan["threat_alert_dispatched"] is False
@@ -1050,7 +1053,7 @@ def test_opportunity_plan_route_is_preview_only():
assert response.status_code == 200
assert data["mode"] == "opportunity_plan_preview"
- assert data["phase"] == "phase_40_deployment_readiness_modularized"
+ assert data["phase"] == "phase_41_alert_review_queue_contract"
assert data["opportunity_queue_created"] is False
assert data["threat_alert_dispatched"] is False
assert data["ai_summary_generated"] is False
@@ -1061,7 +1064,7 @@ def test_opportunity_scoring_plan_preview_blocks_scoring_and_alerts():
plan = MarketIntelService().build_opportunity_scoring_plan()
assert plan["mode"] == "opportunity_scoring_plan_preview"
- assert plan["phase"] == "phase_40_deployment_readiness_modularized"
+ assert plan["phase"] == "phase_41_alert_review_queue_contract"
assert plan["ready_for_scoring_job"] is False
assert plan["scoring_job_created"] is False
assert plan["score_calculation_executed"] is False
@@ -1109,7 +1112,7 @@ def test_opportunity_scoring_plan_route_is_preview_only():
assert response.status_code == 200
assert data["mode"] == "opportunity_scoring_plan_preview"
- assert data["phase"] == "phase_40_deployment_readiness_modularized"
+ assert data["phase"] == "phase_41_alert_review_queue_contract"
assert data["scoring_job_created"] is False
assert data["score_calculation_executed"] is False
assert data["sample_scores_generated"] is False
@@ -1121,7 +1124,7 @@ def test_opportunity_evidence_plan_preview_blocks_queries_and_alerts():
plan = MarketIntelService().build_opportunity_evidence_plan()
assert plan["mode"] == "opportunity_evidence_plan_preview"
- assert plan["phase"] == "phase_40_deployment_readiness_modularized"
+ assert plan["phase"] == "phase_41_alert_review_queue_contract"
assert plan["ready_for_evidence_bundle"] is False
assert plan["evidence_bundle_created"] is False
assert plan["evidence_query_executed"] is False
@@ -1167,7 +1170,7 @@ def test_opportunity_evidence_plan_route_is_preview_only():
assert response.status_code == 200
assert data["mode"] == "opportunity_evidence_plan_preview"
- assert data["phase"] == "phase_40_deployment_readiness_modularized"
+ assert data["phase"] == "phase_41_alert_review_queue_contract"
assert data["evidence_bundle_created"] is False
assert data["evidence_query_executed"] is False
assert data["sample_evidence_generated"] is False
@@ -1180,11 +1183,14 @@ def test_opportunity_alert_plan_preview_blocks_dispatch_and_llm_calls():
plan = MarketIntelService().build_opportunity_alert_plan()
assert plan["mode"] == "opportunity_alert_plan_preview"
- assert plan["phase"] == "phase_40_deployment_readiness_modularized"
+ assert plan["phase"] == "phase_41_alert_review_queue_contract"
assert plan["ready_for_alert_candidates"] is False
assert plan["alert_candidate_created"] is False
assert plan["alert_queue_created"] is False
assert plan["review_queue_created"] is False
+ assert plan["review_queue_contract_defined"] is True
+ assert plan["review_queue_contract_written"] is False
+ assert plan["review_queue_table_created"] is False
assert plan["review_action_executed"] is False
assert plan["approval_record_written"] is False
assert plan["telegram_dispatched"] is False
@@ -1220,12 +1226,29 @@ def test_opportunity_alert_plan_preview_blocks_dispatch_and_llm_calls():
"reject",
"defer",
}
+ assert plan["review_queue_contract"]["table_name"] == "market_alert_review_queue"
+ assert "alert_candidate_id" in plan["review_queue_contract"]["required_fields"]
+ assert "reviewer_identity" in plan["review_queue_contract"]["audit_fields"]
+ assert "payment_or_shipping_data" in plan["review_queue_contract"]["forbidden_fields"]
+ assert {item["key"] for item in plan["review_priority_lanes"]} == {
+ "critical",
+ "high",
+ "medium",
+ "watch",
+ }
+ assert {item["key"] for item in plan["review_queue_indexes"]} == {
+ "idx_market_alert_review_queue_state_priority",
+ "ux_market_alert_review_queue_dedupe",
+ "idx_market_alert_review_queue_bundle",
+ }
assert plan["approval_policy"]["manual_approval_required_for_dispatch"] is True
assert plan["approval_policy"]["reviewer_identity_required"] is True
assert "evidence_bundle_ready" in plan["blocked_reasons"]
assert "scoring_job_ready" in plan["blocked_reasons"]
assert "operator_approval" in plan["blocked_reasons"]
assert "do_not_dispatch_telegram_from_alert_preview" in plan["safe_boundaries"]
+ assert "do_not_create_review_queue_table_from_preview" in plan["safe_boundaries"]
+ assert "do_not_write_review_queue_contract_from_preview" in plan["safe_boundaries"]
assert "do_not_call_llm_from_alert_preview" in plan["safe_boundaries"]
assert "customer_personal_data" in plan["payload_contract"]["forbidden_fields"]
@@ -1245,10 +1268,13 @@ def test_opportunity_alert_plan_route_is_preview_only():
assert response.status_code == 200
assert data["mode"] == "opportunity_alert_plan_preview"
- assert data["phase"] == "phase_40_deployment_readiness_modularized"
+ assert data["phase"] == "phase_41_alert_review_queue_contract"
assert data["alert_candidate_created"] is False
assert data["alert_queue_created"] is False
assert data["review_queue_created"] is False
+ assert data["review_queue_contract_defined"] is True
+ assert data["review_queue_contract_written"] is False
+ assert data["review_queue_table_created"] is False
assert data["review_action_executed"] is False
assert data["approval_record_written"] is False
assert data["telegram_dispatched"] is False
@@ -1320,7 +1346,7 @@ def test_mcp_deploy_preflight_route_is_preview_only():
assert response.status_code == 200
assert data["mode"] == "mcp_external_deploy_preflight_preview"
- assert data["phase"] == "phase_40_deployment_readiness_modularized"
+ assert data["phase"] == "phase_41_alert_review_queue_contract"
assert data["deployment_actions_executed"] is False
assert data["docker_command_executed"] is False
assert data["ssh_command_executed"] is False
@@ -1335,7 +1361,7 @@ def test_mcp_readiness_default_is_planned_only(monkeypatch):
readiness = MarketIntelService().build_mcp_readiness()
assert readiness["mode"] == "mcp_readiness_planned"
- assert readiness["phase"] == "phase_40_deployment_readiness_modularized"
+ assert readiness["phase"] == "phase_41_alert_review_queue_contract"
assert readiness["execute_requested"] is False
assert readiness["router_enabled"] is False
assert readiness["external_mcp_complete"] is False
@@ -1788,6 +1814,8 @@ def test_deployment_readiness_reports_app_only_release_gate():
assert readiness["opportunity_evidence_plan"]["evidence_query_executed"] is False
assert readiness["opportunity_evidence_plan"]["database_write_executed"] is False
assert readiness["opportunity_alert_plan"]["alert_candidate_created"] is False
+ assert readiness["opportunity_alert_plan"]["review_queue_contract_written"] is False
+ assert readiness["opportunity_alert_plan"]["review_queue_table_created"] is False
assert readiness["opportunity_alert_plan"]["review_action_executed"] is False
assert readiness["opportunity_alert_plan"]["approval_record_written"] is False
assert readiness["opportunity_alert_plan"]["telegram_dispatched"] is False