目前只定義告警候選 gate；不建立 alert queue、不派送 Telegram、不呼叫 LLM、不寫 DB。${blockers ? `阻擋：${escapeHtml(blockers)}` : ''}
+ 目前只定義告警候選與人工審核流程；不建立 alert queue、不建立 review queue、不執行審核動作、不派送 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)}
OPERATOR SEQUENCE
${
diff --git a/tests/test_market_intel_skeleton.py b/tests/test_market_intel_skeleton.py
index 646c47e..a149284 100644
--- a/tests/test_market_intel_skeleton.py
+++ b/tests/test_market_intel_skeleton.py
@@ -475,6 +475,9 @@ def test_market_intel_preview_template_uses_safe_fetch_false_endpoint():
assert "data-market-intel-opportunity-alert-channels" in template
assert "data-market-intel-opportunity-alert-escalation" in template
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-approval" in template
assert "data-market-intel-opportunity-alert-sequence" in template
assert "data-market-intel-migration" in template
assert "data-market-intel-migration-tables" in template
@@ -524,7 +527,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_38_opportunity_alert_plan_preview"
+ assert bridge["phase"] == "phase_39_opportunity_alert_review_preview"
assert bridge["execute_requested"] is False
assert bridge["read_only_query_executed"] is False
assert bridge["database_connection_opened"] is False
@@ -682,7 +685,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_38_opportunity_alert_plan_preview"
+ assert contract["phase"] == "phase_39_opportunity_alert_review_preview"
assert contract["caller"] == "market_intel"
assert contract["contract_ready"] is True
assert contract["blocked_reasons"] == []
@@ -815,7 +818,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_38_opportunity_alert_plan_preview"
+ assert data["phase"] == "phase_39_opportunity_alert_review_preview"
assert data["deployment_actions_executed"] is False
assert data["docker_command_executed"] is False
assert data["ssh_command_executed"] is False
@@ -828,7 +831,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_38_opportunity_alert_plan_preview"
+ assert gate["phase"] == "phase_39_opportunity_alert_review_preview"
assert gate["fetch_requested"] is True
assert gate["manual_fetch_gate_open"] is False
assert gate["network_request_allowed"] is False
@@ -898,7 +901,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_38_opportunity_alert_plan_preview"
+ assert data["phase"] == "phase_39_opportunity_alert_review_preview"
assert data["fetch_requested"] is False
assert data["network_request_allowed"] is False
assert data["external_network_executed"] is False
@@ -910,7 +913,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_38_opportunity_alert_plan_preview"
+ assert plan["phase"] == "phase_39_opportunity_alert_review_preview"
assert plan["ready_to_attach_scheduler"] is False
assert plan["scheduler_attached"] is False
assert plan["scheduler_registration_executed"] is False
@@ -948,7 +951,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_38_opportunity_alert_plan_preview"
+ assert data["phase"] == "phase_39_opportunity_alert_review_preview"
assert data["scheduler_registration_executed"] is False
assert data["crawler_job_started"] is False
assert data["external_network_executed"] is False
@@ -959,7 +962,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_38_opportunity_alert_plan_preview"
+ assert plan["phase"] == "phase_39_opportunity_alert_review_preview"
assert plan["ready_for_review_queue"] is False
assert plan["review_queue_created"] is False
assert plan["auto_match_executed"] is False
@@ -995,7 +998,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_38_opportunity_alert_plan_preview"
+ assert data["phase"] == "phase_39_opportunity_alert_review_preview"
assert data["review_queue_created"] is False
assert data["auto_confirm_executed"] is False
assert data["external_network_executed"] is False
@@ -1006,7 +1009,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_38_opportunity_alert_plan_preview"
+ assert plan["phase"] == "phase_39_opportunity_alert_review_preview"
assert plan["ready_for_opportunity_queue"] is False
assert plan["opportunity_queue_created"] is False
assert plan["threat_alert_dispatched"] is False
@@ -1047,7 +1050,7 @@ def test_opportunity_plan_route_is_preview_only():
assert response.status_code == 200
assert data["mode"] == "opportunity_plan_preview"
- assert data["phase"] == "phase_38_opportunity_alert_plan_preview"
+ assert data["phase"] == "phase_39_opportunity_alert_review_preview"
assert data["opportunity_queue_created"] is False
assert data["threat_alert_dispatched"] is False
assert data["ai_summary_generated"] is False
@@ -1058,7 +1061,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_38_opportunity_alert_plan_preview"
+ assert plan["phase"] == "phase_39_opportunity_alert_review_preview"
assert plan["ready_for_scoring_job"] is False
assert plan["scoring_job_created"] is False
assert plan["score_calculation_executed"] is False
@@ -1106,7 +1109,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_38_opportunity_alert_plan_preview"
+ assert data["phase"] == "phase_39_opportunity_alert_review_preview"
assert data["scoring_job_created"] is False
assert data["score_calculation_executed"] is False
assert data["sample_scores_generated"] is False
@@ -1118,7 +1121,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_38_opportunity_alert_plan_preview"
+ assert plan["phase"] == "phase_39_opportunity_alert_review_preview"
assert plan["ready_for_evidence_bundle"] is False
assert plan["evidence_bundle_created"] is False
assert plan["evidence_query_executed"] is False
@@ -1164,7 +1167,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_38_opportunity_alert_plan_preview"
+ assert data["phase"] == "phase_39_opportunity_alert_review_preview"
assert data["evidence_bundle_created"] is False
assert data["evidence_query_executed"] is False
assert data["sample_evidence_generated"] is False
@@ -1177,10 +1180,13 @@ 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_38_opportunity_alert_plan_preview"
+ assert plan["phase"] == "phase_39_opportunity_alert_review_preview"
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_action_executed"] is False
+ assert plan["approval_record_written"] is False
assert plan["telegram_dispatched"] is False
assert plan["ai_summary_generated"] is False
assert plan["llm_call_executed"] is False
@@ -1199,6 +1205,23 @@ def test_opportunity_alert_plan_preview_blocks_dispatch_and_llm_calls():
"telegram_candidate",
"ai_briefing_candidate",
}
+ assert plan["review_state_count"] == 6
+ assert {item["key"] for item in plan["review_states"]} == {
+ "draft",
+ "needs_review",
+ "approved_for_digest",
+ "approved_for_telegram",
+ "rejected",
+ "deferred",
+ }
+ assert {item["key"] for item in plan["review_actions"]} == {
+ "approve_digest",
+ "approve_telegram",
+ "reject",
+ "defer",
+ }
+ 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"]
@@ -1222,9 +1245,12 @@ 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_38_opportunity_alert_plan_preview"
+ assert data["phase"] == "phase_39_opportunity_alert_review_preview"
assert data["alert_candidate_created"] is False
assert data["alert_queue_created"] is False
+ assert data["review_queue_created"] is False
+ assert data["review_action_executed"] is False
+ assert data["approval_record_written"] is False
assert data["telegram_dispatched"] is False
assert data["llm_call_executed"] is False
assert data["database_write_executed"] is False
@@ -1294,7 +1320,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_38_opportunity_alert_plan_preview"
+ assert data["phase"] == "phase_39_opportunity_alert_review_preview"
assert data["deployment_actions_executed"] is False
assert data["docker_command_executed"] is False
assert data["ssh_command_executed"] is False
@@ -1309,7 +1335,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_38_opportunity_alert_plan_preview"
+ assert readiness["phase"] == "phase_39_opportunity_alert_review_preview"
assert readiness["execute_requested"] is False
assert readiness["router_enabled"] is False
assert readiness["external_mcp_complete"] is False
@@ -1762,6 +1788,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_action_executed"] is False
+ assert readiness["opportunity_alert_plan"]["approval_record_written"] is False
assert readiness["opportunity_alert_plan"]["telegram_dispatched"] is False
assert readiness["opportunity_alert_plan"]["llm_call_executed"] is False
assert readiness["opportunity_alert_plan"]["database_write_executed"] is False