@@ -1704,6 +1730,7 @@
const mcpFetchCandidateQueueWriterReviewDecisionApprovalRoot = document.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-review-decision-approval]');
const mcpFetchCandidateQueueWriterReviewDecisionApprovalWriterPreflightRoot = document.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-review-decision-approval-writer-preflight]');
const mcpProfessionalSourceGovernanceRoot = document.querySelector('[data-market-intel-mcp-professional-source-governance]');
+ const mcpFetchTargetSourceGovernanceReviewRoot = document.querySelector('[data-market-intel-mcp-fetch-target-source-governance-review]');
const manualSampleRoot = document.querySelector('[data-market-intel-manual-sample]');
const sampleAcceptanceRoot = document.querySelector('[data-market-intel-sample-acceptance]');
const sampleReviewRoot = document.querySelector('[data-market-intel-sample-review]');
@@ -1720,7 +1747,7 @@
const liveInventoryRoot = document.querySelector('[data-market-intel-live-inventory]');
const approvalRoot = document.querySelector('[data-market-intel-approval]');
const deployRoot = document.querySelector('[data-market-intel-deploy]');
- if (!root && !writerRoot && !cliRoot && !dbProbeRoot && !seedDiffRoot && !legacyBridgeRoot && !mcpReadinessRoot && !mcpPreflightRoot && !mcpActivationRoot && !mcpFetchGateRoot && !mcpCompletionRoot && !mcpActivationEvidenceRoot && !mcpRuntimeSmokeRoot && !mcpRuntimePromotionRoot && !mcpManualFetchHandoffRoot && !mcpFetchTargetReviewRoot && !mcpFetchRunPackageRoot && !mcpFetchRunReadinessRoot && !mcpFetchRunReceiptRoot && !mcpFetchResultParserReviewRoot && !mcpFetchCandidateHandoffReviewRoot && !mcpFetchCandidateQueueReviewRoot && !mcpFetchCandidateQueueWriterPreflightRoot && !mcpFetchCandidateQueueWriterCliReviewRoot && !mcpFetchCandidateQueueWriterRunPackageReviewRoot && !mcpFetchCandidateQueueWriterRunReadinessRoot && !mcpFetchCandidateQueueWriterRunReceiptReviewRoot && !mcpFetchCandidateQueueWriterRunCloseoutReviewRoot && !mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot && !mcpFetchCandidateQueueWriterReviewHandoffRoot && !mcpFetchCandidateQueueWriterReviewInventoryRoot && !mcpFetchCandidateQueueWriterReviewDecisionRoot && !mcpFetchCandidateQueueWriterReviewDecisionApprovalRoot && !mcpFetchCandidateQueueWriterReviewDecisionApprovalWriterPreflightRoot && !mcpProfessionalSourceGovernanceRoot && !manualSampleRoot && !sampleAcceptanceRoot && !sampleReviewRoot && !schedulerRoot && !matchReviewRoot && !opportunityRoot && !opportunityScoringRoot && !opportunityEvidenceRoot && !opportunityAlertRoot && !migrationRoot && !migrationDrillRoot && !catalogReviewRoot && !liveSmokeRoot && !liveInventoryRoot && !approvalRoot && !deployRoot) return;
+ if (!root && !writerRoot && !cliRoot && !dbProbeRoot && !seedDiffRoot && !legacyBridgeRoot && !mcpReadinessRoot && !mcpPreflightRoot && !mcpActivationRoot && !mcpFetchGateRoot && !mcpCompletionRoot && !mcpActivationEvidenceRoot && !mcpRuntimeSmokeRoot && !mcpRuntimePromotionRoot && !mcpManualFetchHandoffRoot && !mcpFetchTargetReviewRoot && !mcpFetchRunPackageRoot && !mcpFetchRunReadinessRoot && !mcpFetchRunReceiptRoot && !mcpFetchResultParserReviewRoot && !mcpFetchCandidateHandoffReviewRoot && !mcpFetchCandidateQueueReviewRoot && !mcpFetchCandidateQueueWriterPreflightRoot && !mcpFetchCandidateQueueWriterCliReviewRoot && !mcpFetchCandidateQueueWriterRunPackageReviewRoot && !mcpFetchCandidateQueueWriterRunReadinessRoot && !mcpFetchCandidateQueueWriterRunReceiptReviewRoot && !mcpFetchCandidateQueueWriterRunCloseoutReviewRoot && !mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot && !mcpFetchCandidateQueueWriterReviewHandoffRoot && !mcpFetchCandidateQueueWriterReviewInventoryRoot && !mcpFetchCandidateQueueWriterReviewDecisionRoot && !mcpFetchCandidateQueueWriterReviewDecisionApprovalRoot && !mcpFetchCandidateQueueWriterReviewDecisionApprovalWriterPreflightRoot && !mcpProfessionalSourceGovernanceRoot && !mcpFetchTargetSourceGovernanceReviewRoot && !manualSampleRoot && !sampleAcceptanceRoot && !sampleReviewRoot && !schedulerRoot && !matchReviewRoot && !opportunityRoot && !opportunityScoringRoot && !opportunityEvidenceRoot && !opportunityAlertRoot && !migrationRoot && !migrationDrillRoot && !catalogReviewRoot && !liveSmokeRoot && !liveInventoryRoot && !approvalRoot && !deployRoot) return;
const meta = root ? root.querySelector('[data-market-intel-preview-meta]') : null;
const body = root ? root.querySelector('[data-market-intel-preview-body]') : null;
@@ -1911,6 +1938,12 @@
const mcpProfessionalSourceGovernanceReview = mcpProfessionalSourceGovernanceRoot ? mcpProfessionalSourceGovernanceRoot.querySelector('[data-market-intel-mcp-professional-source-governance-review]') : null;
const mcpProfessionalSourceGovernanceRefresh = mcpProfessionalSourceGovernanceRoot ? mcpProfessionalSourceGovernanceRoot.querySelector('[data-market-intel-mcp-professional-source-governance-refresh]') : null;
const mcpProfessionalSourceGovernanceEndpoint = "{{ url_for('market_intel.market_intel_mcp_professional_source_governance') }}";
+ const mcpFetchTargetSourceGovernanceReviewMeta = mcpFetchTargetSourceGovernanceReviewRoot ? mcpFetchTargetSourceGovernanceReviewRoot.querySelector('[data-market-intel-mcp-fetch-target-source-governance-review-meta]') : null;
+ const mcpFetchTargetSourceGovernanceReviewBody = mcpFetchTargetSourceGovernanceReviewRoot ? mcpFetchTargetSourceGovernanceReviewRoot.querySelector('[data-market-intel-mcp-fetch-target-source-governance-review-body]') : null;
+ const mcpFetchTargetSourceGovernanceReviewInput = mcpFetchTargetSourceGovernanceReviewRoot ? mcpFetchTargetSourceGovernanceReviewRoot.querySelector('[data-market-intel-mcp-fetch-target-source-governance-review-input]') : null;
+ const mcpFetchTargetSourceGovernanceReviewReview = mcpFetchTargetSourceGovernanceReviewRoot ? mcpFetchTargetSourceGovernanceReviewRoot.querySelector('[data-market-intel-mcp-fetch-target-source-governance-review-review]') : null;
+ const mcpFetchTargetSourceGovernanceReviewRefresh = mcpFetchTargetSourceGovernanceReviewRoot ? mcpFetchTargetSourceGovernanceReviewRoot.querySelector('[data-market-intel-mcp-fetch-target-source-governance-review-refresh]') : null;
+ const mcpFetchTargetSourceGovernanceReviewEndpoint = "{{ url_for('market_intel.market_intel_mcp_fetch_target_source_governance_review') }}";
const manualSampleMeta = manualSampleRoot ? manualSampleRoot.querySelector('[data-market-intel-manual-sample-meta]') : null;
const manualSampleBody = manualSampleRoot ? manualSampleRoot.querySelector('[data-market-intel-manual-sample-body]') : null;
const manualSampleRefresh = manualSampleRoot ? manualSampleRoot.querySelector('[data-market-intel-manual-sample-refresh]') : null;
@@ -5920,6 +5953,125 @@
}
};
+ const renderMcpFetchTargetSourceGovernanceReviewMeta = data => {
+ const alignment = data.source_alignment || {};
+ mcpFetchTargetSourceGovernanceReviewMeta.innerHTML = [
+ `mode=${data.mode || 'unknown'}`,
+ `accepted=${data.mcp_fetch_target_source_governance_review_accepted ? 'yes' : 'no'}`,
+ `gates=${data.passed_gate_count || 0}/${data.gate_count || 0}`,
+ `target_sources=${alignment.target_source_count || 0}`,
+ `governed=${alignment.governed_source_count || 0}`,
+ `missing=${(alignment.missing_governed_sources || []).length}`
+ ].map(item => `
${escapeHtml(item)}`).join('');
+ };
+
+ const renderMcpFetchTargetSourceGovernanceReviewBody = data => {
+ const alignment = data.source_alignment || {};
+ const gates = data.gates || [];
+ const missing = alignment.missing_governed_sources || [];
+ const targetSources = alignment.target_sources || [];
+ const sourceGovernance = data.professional_source_governance || {};
+ const targetReview = data.mcp_fetch_target_review || {};
+ const steps = data.next_operator_steps || [];
+ const renderCheck = (key, label, status) => `
+
+
+ ${escapeHtml(key)}
+ ${escapeHtml(label || '')}
+
+
${escapeHtml(status)}
+
+ `;
+ mcpFetchTargetSourceGovernanceReviewBody.innerHTML = `
+
此 bridge 只交叉審核 source governance 與 fetch target review：確認 target source_key 全部引用已治理公開來源；API 不抓外站、不讀 robots/sitemap、不寫 DB、不掛 scheduler。
+
+
+
BRIDGE GATES
+
${
+ gates.length
+ ? gates.map(item => renderCheck(item.key, item.label, item.passed ? 'PASS' : 'BLOCK')).join('')
+ : '
尚未提供 bridge gates。
'
+ }
+
+
+
SOURCE ALIGNMENT
+
${
+ targetSources.length
+ ? targetSources.map(source => renderCheck(
+ `${source.platform_code}:${source.source_key}`,
+ missing.some(item => item.platform_code === source.platform_code && item.source_key === source.source_key) ? 'missing governed source contract' : 'governed source contract matched',
+ missing.some(item => item.platform_code === source.platform_code && item.source_key === source.source_key) ? 'BLOCK' : 'READY'
+ )).join('')
+ : '
尚未提供 target source。
'
+ }
+
+
+
UPSTREAM REVIEWS
+
+ ${renderCheck('professional_source_governance', `mode=${sourceGovernance.mode || 'missing'} / accepted=${sourceGovernance.mcp_professional_source_governance_accepted ? 'yes' : 'no'}`, sourceGovernance.mcp_professional_source_governance_accepted ? 'PASS' : 'BLOCK')}
+ ${renderCheck('mcp_fetch_target_review', `mode=${targetReview.mode || 'missing'} / accepted=${targetReview.mcp_fetch_target_review_accepted ? 'yes' : 'no'}`, targetReview.mcp_fetch_target_review_accepted ? 'PASS' : 'BLOCK')}
+ ${renderCheck('api_boundary', 'no external fetch / no DB write / no CLI / no scheduler', data.network_request_allowed || data.api_writes_database || data.api_executes_cli || data.scheduler_attached ? 'BLOCK' : 'CLOSED')}
+
+
+
+
NEXT
+
+ ${steps.length ? steps.map((item, index) => renderCheck(`step_${index + 1}`, item, 'NEXT')).join('') : '
尚未提供下一步。
'}
+
+
+
+ `;
+ if (mcpFetchTargetSourceGovernanceReviewInput && !mcpFetchTargetSourceGovernanceReviewInput.value.trim() && data.sample_fetch_target_source_governance_review_package) {
+ mcpFetchTargetSourceGovernanceReviewInput.value = JSON.stringify(data.sample_fetch_target_source_governance_review_package, null, 2);
+ }
+ };
+
+ const loadMcpFetchTargetSourceGovernanceReview = async () => {
+ if (!mcpFetchTargetSourceGovernanceReviewMeta || !mcpFetchTargetSourceGovernanceReviewBody) return;
+ mcpFetchTargetSourceGovernanceReviewBody.innerHTML = '
讀取 Fetch Target Source Governance Review 中...
';
+ try {
+ const response = await fetch(mcpFetchTargetSourceGovernanceReviewEndpoint, { credentials: 'same-origin' });
+ if (!response.ok) throw new Error(`HTTP ${response.status}`);
+ const data = await response.json();
+ renderMcpFetchTargetSourceGovernanceReviewMeta(data);
+ renderMcpFetchTargetSourceGovernanceReviewBody(data);
+ } catch (error) {
+ mcpFetchTargetSourceGovernanceReviewMeta.innerHTML = '
error';
+ mcpFetchTargetSourceGovernanceReviewBody.innerHTML = `
Fetch Target Source Governance Review 讀取失敗：${escapeHtml(error.message)}
`;
+ }
+ };
+
+ const reviewMcpFetchTargetSourceGovernanceReview = async () => {
+ if (!mcpFetchTargetSourceGovernanceReviewMeta || !mcpFetchTargetSourceGovernanceReviewBody || !mcpFetchTargetSourceGovernanceReviewInput) return;
+ let parsed;
+ try {
+ parsed = JSON.parse(mcpFetchTargetSourceGovernanceReviewInput.value || '{}');
+ } catch (error) {
+ mcpFetchTargetSourceGovernanceReviewMeta.innerHTML = '
json_error';
+ mcpFetchTargetSourceGovernanceReviewBody.innerHTML = `
JSON 格式錯誤：${escapeHtml(error.message)}
`;
+ return;
+ }
+ mcpFetchTargetSourceGovernanceReviewBody.innerHTML = '
審核 Fetch Target Source Governance Review 中...
';
+ try {
+ const response = await fetch(mcpFetchTargetSourceGovernanceReviewEndpoint, {
+ method: 'POST',
+ credentials: 'same-origin',
+ headers: {
+ 'Content-Type': 'application/json',
+ 'X-CSRFToken': csrfToken
+ },
+ body: JSON.stringify({ fetch_target_source_governance_review_package: parsed })
+ });
+ const data = await response.json();
+ if (!response.ok && !data.mode) throw new Error(`HTTP ${response.status}`);
+ renderMcpFetchTargetSourceGovernanceReviewMeta(data);
+ renderMcpFetchTargetSourceGovernanceReviewBody(data);
+ } catch (error) {
+ mcpFetchTargetSourceGovernanceReviewMeta.innerHTML = '
error';
+ mcpFetchTargetSourceGovernanceReviewBody.innerHTML = `
Fetch Target Source Governance Review 審核失敗：${escapeHtml(error.message)}
`;
+ }
+ };
+
const renderManualSampleMeta = data => {
manualSampleMeta.innerHTML = [
`mode=${data.mode || 'unknown'}`,
@@ -15467,6 +15619,12 @@
if (mcpProfessionalSourceGovernanceReview) {
mcpProfessionalSourceGovernanceReview.addEventListener('click', reviewMcpProfessionalSourceGovernance);
}
+ if (mcpFetchTargetSourceGovernanceReviewRefresh) {
+ mcpFetchTargetSourceGovernanceReviewRefresh.addEventListener('click', loadMcpFetchTargetSourceGovernanceReview);
+ }
+ if (mcpFetchTargetSourceGovernanceReviewReview) {
+ mcpFetchTargetSourceGovernanceReviewReview.addEventListener('click', reviewMcpFetchTargetSourceGovernanceReview);
+ }
if (manualSampleRefresh) {
manualSampleRefresh.addEventListener('click', loadManualSample);
}
@@ -15745,6 +15903,7 @@
loadMcpFetchCandidateQueueWriterReviewDecisionApproval();
loadMcpFetchCandidateQueueWriterReviewDecisionApprovalWriterPreflight();
loadMcpProfessionalSourceGovernance();
+ loadMcpFetchTargetSourceGovernanceReview();
loadManualSample();
loadSampleAcceptance();
loadSampleReview();
diff --git a/tests/test_competitor_intel_cache.py b/tests/test_competitor_intel_cache.py
index a2d8d07..ee1619e 100644
--- a/tests/test_competitor_intel_cache.py
+++ b/tests/test_competitor_intel_cache.py
@@ -83,7 +83,7 @@ def test_competitor_coverage_counts_only_active_product_intersection():
"def _fetch_manual_review_summary", 1
)[0]
- assert "coverage:v11" in source
+ assert "coverage:v12" in source
assert "CATALOG_COMPARABLE_SCORE_FLOOR" in source
assert "rescore_accepted_count" in coverage_source
assert "(SELECT COUNT(*) FROM valid_competitor) AS valid_matches" not in coverage_source
@@ -104,8 +104,10 @@ def test_competitor_coverage_counts_only_active_product_intersection():
assert "\"decision_support_count\": decision_support_count" in coverage_source
assert "\"decision_support_rate\": round(decision_support_count / max(active, 1) * 100, 1)" in coverage_source
assert "\"catalog_comparable_count\": catalog_comparable_count" in coverage_source
- assert "CATALOG_COMPARABLE_SIGNAL_REASONS" in coverage_source
- assert "CATALOG_COMPARABLE_BLOCK_REASONS" in coverage_source
+ assert "_catalog_comparable_sql(\"la\")" in coverage_source
+ assert "CATALOG_COMPARABLE_SIGNAL_REASONS" in source
+ assert "CATALOG_COMPARABLE_IDENTITY_REASONS" in source
+ assert "CATALOG_COMPARABLE_BLOCK_REASONS" in source
assert "\"identity_coverage_matches\": valid" in coverage_source
assert "\"manual_closed_count\": manual_closed_count" in coverage_source
assert "\"last_decision_ready_crawled_at\": last_decision_ready_crawled_at" in coverage_source
@@ -186,6 +188,7 @@ def test_competitor_review_queue_is_canonical_unit_price_handoff():
def test_competitor_review_filters_split_low_score_operational_buckets():
from services.competitor_intel_repository import REVIEW_STATUS_FILTER_GROUPS
+ assert REVIEW_STATUS_FILTER_GROUPS["catalog_comparable"] == ("true_low_confidence",)
assert REVIEW_STATUS_FILTER_GROUPS["recoverable_low_score"] == ("recoverable_low_score",)
assert REVIEW_STATUS_FILTER_GROUPS["true_low_confidence"] == ("true_low_confidence",)
assert REVIEW_STATUS_FILTER_GROUPS["legacy_low_score"] == ("low_score", "refresh_low_score")
@@ -197,6 +200,41 @@ def test_competitor_review_filters_split_low_score_operational_buckets():
}
+def test_catalog_comparable_review_item_keeps_exact_match_guardrail():
+ from services.competitor_intel_repository import _format_competitor_review_item
+
+ item = _format_competitor_review_item({
+ "sku": "CAT-001",
+ "name": "DASHING DIVA Gloss Gel 美甲片 月影柔霧",
+ "momo_price": 699,
+ "attempt_status": "true_low_confidence",
+ "catalog_comparable": True,
+ "candidate_count": 3,
+ "best_competitor_product_id": "DABC-CATALOG",
+ "best_competitor_product_name": "DASHING DIVA Gloss Gel 美甲片 月影柔霧 任選",
+ "best_competitor_price": 599,
+ "best_match_score": 0.912,
+ "match_diagnostic_json": {
+ "match_type": "comparable",
+ "price_basis": "manual_review",
+ "alert_tier": "identity_review",
+ "reasons": [
+ "strong_product_line_match",
+ "variant_selection_review",
+ ],
+ },
+ })
+
+ assert item["review_bucket"] == "catalog_comparable"
+ assert item["status_label"] == "型錄/任選可比"
+ assert "型錄、任選" in item["action_label"]
+ envelope = item["decision_envelope"]
+ assert envelope["recommended_action"]["action"] == "review_catalog_comparable"
+ assert envelope["guardrails"]["can_auto_execute"] is False
+ assert envelope["guardrails"]["catalog_comparable"] is True
+ assert any(evidence["metric"] == "catalog_comparable" for evidence in envelope["evidence"])
+
+
def test_competitor_review_reasons_prefer_json_payload_labels():
from services.competitor_intel_repository import _format_competitor_review_item
diff --git a/tests/test_competitor_match_attempts_persistence.py b/tests/test_competitor_match_attempts_persistence.py
index c231946..76230be 100644
--- a/tests/test_competitor_match_attempts_persistence.py
+++ b/tests/test_competitor_match_attempts_persistence.py
@@ -69,6 +69,12 @@ def test_competitor_review_queue_starts_from_latest_attempts_not_all_products():
assert "JOIN products p" in review_cte_body
assert "JOIN LATERAL" in review_cte_body
assert "NOT EXISTS (" in review_cte_body
+ assert "cma.hard_veto" in review_cte_body
+ assert "cma.diagnostic_codes" in review_cte_body
+ assert "catalog_comparable" in review_cte_body
+ assert "_catalog_comparable_sql(\"la\")" in review_cte_body
+ assert "status_filter == \"catalog_comparable\"" in review_cte_body
+ assert "status_filter == \"true_low_confidence\"" in review_cte_body
assert "FROM latest_momo lm" not in review_cte_body
assert "valid_competitor AS" not in review_cte_body
diff --git a/tests/test_frontend_v2_assets.py b/tests/test_frontend_v2_assets.py
index 225a948..f878010 100644
--- a/tests/test_frontend_v2_assets.py
+++ b/tests/test_frontend_v2_assets.py
@@ -162,6 +162,8 @@ def test_dashboard_v2_is_production_default_and_uses_real_dashboard_data():
assert "unit_comparable_count" in route_source
assert "decision_support_rate" in route_source
assert "catalog_comparable_count" in route_source
+ assert "'catalog_comparable'" in route_source
+ assert "型錄可比" in route_source
assert "rescore_accepted_count" in route_source
assert "filter_type == 'pchome_review'" in route_source
assert "total_items = review_queue_total" in route_source
diff --git a/tests/test_market_intel_skeleton.py b/tests/test_market_intel_skeleton.py
index 97a6ff8..f633922 100644
--- a/tests/test_market_intel_skeleton.py
+++ b/tests/test_market_intel_skeleton.py
@@ -77,6 +77,9 @@ from services.market_intel.mcp_fetch_candidate_queue_writer_review_decision_appr
from services.market_intel.mcp_professional_source_governance import (
build_mcp_professional_source_governance_preview,
)
+from services.market_intel.mcp_fetch_target_source_governance_review import (
+ build_mcp_fetch_target_source_governance_review_preview,
+)
from services.market_intel.mcp_fetch_target_review import (
build_mcp_fetch_target_review_preview,
)
@@ -1395,6 +1398,23 @@ def test_market_intel_preview_template_uses_safe_fetch_false_endpoint():
"data-market-intel-mcp-professional-source-governance-next"
in template
)
+ assert (
+ "market_intel.market_intel_mcp_fetch_target_source_governance_review"
+ in template
+ )
+ assert "data-market-intel-mcp-fetch-target-source-governance-review" in template
+ assert (
+ "data-market-intel-mcp-fetch-target-source-governance-review-gates"
+ in template
+ )
+ assert (
+ "data-market-intel-mcp-fetch-target-source-governance-review-alignment"
+ in template
+ )
+ assert (
+ "data-market-intel-mcp-fetch-target-source-governance-review-next"
+ in template
+ )
assert "market_intel.market_intel_manual_sample_plan" in template
assert "market_intel.market_intel_manual_sample_acceptance" in template
assert "market_intel.market_intel_manual_sample_review" in template
@@ -22835,6 +22855,22 @@ def test_deployment_readiness_reports_app_only_release_gate():
readiness["mcp_professional_source_governance"]["api_fetches_source_url"]
is False
)
+ assert (
+ readiness["checks"][
+ "mcp_fetch_target_source_governance_review_preview_safe"
+ ]
+ is True
+ )
+ assert (
+ readiness["mcp_fetch_target_source_governance_review"]["mode"]
+ == "mcp_fetch_target_source_governance_review_preview"
+ )
+ assert (
+ readiness["mcp_fetch_target_source_governance_review"][
+ "api_fetches_source_url"
+ ]
+ is False
+ )
assert readiness["checks"]["scheduler_plan_preview_safe"] is True
assert readiness["checks"]["manual_sample_plan_preview_safe"] is True
assert readiness["checks"]["manual_sample_acceptance_preview_safe"] is True
@@ -23242,6 +23278,10 @@ def test_deployment_readiness_reports_app_only_release_gate():
"/api/market_intel/mcp_professional_source_governance"
in readiness["production_smoke_targets"]
)
+ assert (
+ "/api/market_intel/mcp_fetch_target_source_governance_review"
+ in readiness["production_smoke_targets"]
+ )
assert "/api/market_intel/scheduler_plan" in readiness["production_smoke_targets"]
assert "/api/market_intel/manual_sample_plan" in readiness["production_smoke_targets"]
assert "/api/market_intel/manual_sample_acceptance" in readiness["production_smoke_targets"]
@@ -23616,6 +23656,34 @@ def test_deployment_readiness_reports_app_only_release_gate():
assert readiness["mcp_fetch_target_review"]["api_writes_database"] is False
assert readiness["mcp_fetch_target_review"]["api_uses_external_network"] is False
assert readiness["mcp_fetch_target_review"]["scheduler_attached"] is False
+ assert (
+ readiness["mcp_fetch_target_source_governance_review"]["payload_persisted"]
+ is False
+ )
+ assert (
+ readiness["mcp_fetch_target_source_governance_review"][
+ "bridge_review_persisted"
+ ]
+ is False
+ )
+ assert (
+ readiness["mcp_fetch_target_source_governance_review"][
+ "network_request_allowed"
+ ]
+ is False
+ )
+ assert (
+ readiness["mcp_fetch_target_source_governance_review"]["api_writes_database"]
+ is False
+ )
+ assert (
+ readiness["mcp_fetch_target_source_governance_review"]["api_executes_cli"]
+ is False
+ )
+ assert (
+ readiness["mcp_fetch_target_source_governance_review"]["scheduler_attached"]
+ is False
+ )
assert readiness["mcp_fetch_run_package"]["mode"] == "mcp_fetch_run_package_preview"
assert readiness["mcp_fetch_run_package"]["run_payload_received"] is False
assert readiness["mcp_fetch_run_package"]["payload_persisted"] is False
@@ -28084,10 +28152,10 @@ def test_mcp_professional_source_governance_accepts_sample_package():
assert governance["blocked_reasons"] == []
assert governance["passed_gate_count"] == governance["gate_count"]
summary = governance["source_governance_summary"]
- assert summary["source_count"] == 4
+ assert summary["source_count"] == 8
assert summary["platform_count"] == 4
- assert summary["robots_checked_count"] == 4
- assert summary["structured_data_ready_count"] == 4
+ assert summary["robots_checked_count"] == 8
+ assert summary["structured_data_ready_count"] == 8
assert summary["min_crawl_delay_seconds"] >= 1
assert all(source["evidence_artifact_path_safe"] for source in governance["sources"])
assert all(source["snapshot_hash_required"] for source in governance["sources"])
@@ -28193,3 +28261,130 @@ def test_mcp_professional_source_governance_route_get_and_post_preview_only():
assert post_data["api_writes_database"] is False
assert post_data["payload_persisted"] is False
assert post_data["scheduler_attached"] is False
+
+
+def test_mcp_fetch_target_source_governance_review_preview_is_safe_without_payload():
+ review = build_mcp_fetch_target_source_governance_review_preview(
+ phase="phase_140_market_intel_professional_source_governance",
+ )
+
+ assert review["mode"] == "mcp_fetch_target_source_governance_review_preview"
+ assert review["phase"] == "phase_140_market_intel_professional_source_governance"
+ assert review["source_governance_package_received"] is False
+ assert review["target_review_package_received"] is False
+ assert review["mcp_fetch_target_source_governance_review_accepted"] is False
+ assert "professional_source_governance_package_received" in review["blocked_reasons"]
+ assert "fetch_target_review_package_received" in review["blocked_reasons"]
+ assert review["network_request_allowed"] is False
+ assert review["external_network_executed"] is False
+ assert review["fetch_executed"] is False
+ assert review["api_fetches_source_url"] is False
+ assert review["api_opens_database_connection"] is False
+ assert review["api_writes_database"] is False
+ assert review["api_executes_cli"] is False
+ assert review["scheduler_attached"] is False
+
+
+def test_mcp_fetch_target_source_governance_review_accepts_sample_package():
+ sample = (
+ build_mcp_fetch_target_source_governance_review_preview()
+ ["sample_fetch_target_source_governance_review_package"]
+ )
+ review = build_mcp_fetch_target_source_governance_review_preview(
+ professional_source_governance_package=sample[
+ "professional_source_governance_package"
+ ],
+ target_review_package=sample["target_review_package"],
+ operator_confirmations=sample["operator_confirmations"],
+ phase="phase_140_market_intel_professional_source_governance",
+ )
+
+ assert review["mode"] == "mcp_fetch_target_source_governance_review"
+ assert review["phase"] == "phase_140_market_intel_professional_source_governance"
+ assert review["mcp_fetch_target_source_governance_review_accepted"] is True
+ assert review["ready_for_manual_fetch_run_package_review"] is True
+ assert review["blocked_reasons"] == []
+ assert review["passed_gate_count"] == review["gate_count"]
+ assert review["source_alignment"]["target_source_count"] == 8
+ assert review["source_alignment"]["governed_source_count"] == 8
+ assert review["source_alignment"]["missing_governed_sources"] == []
+ assert review["source_alignment"]["all_target_sources_governed"] is True
+ assert review["professional_source_governance"][
+ "mcp_professional_source_governance_accepted"
+ ] is True
+ assert review["mcp_fetch_target_review"]["mcp_fetch_target_review_accepted"] is True
+ assert review["network_request_allowed"] is False
+ assert review["api_fetches_source_url"] is False
+ assert review["api_opens_database_connection"] is False
+ assert review["api_writes_database"] is False
+ assert review["api_executes_cli"] is False
+ assert review["scheduler_attached"] is False
+
+
+def test_mcp_fetch_target_source_governance_review_blocks_missing_source_contract():
+ sample = json.loads(
+ json.dumps(
+ build_mcp_fetch_target_source_governance_review_preview()
+ ["sample_fetch_target_source_governance_review_package"]
+ )
+ )
+ sources = sample["professional_source_governance_package"][
+ "operator_source_governance"
+ ]["sources"]
+ sample["professional_source_governance_package"]["operator_source_governance"][
+ "sources"
+ ] = [source for source in sources if source["source_key"] != "shopee_home"]
+
+ review = build_mcp_fetch_target_source_governance_review_preview(
+ professional_source_governance_package=sample[
+ "professional_source_governance_package"
+ ],
+ target_review_package=sample["target_review_package"],
+ operator_confirmations=sample["operator_confirmations"],
+ )
+
+ assert review["mcp_fetch_target_source_governance_review_accepted"] is False
+ assert "all_target_sources_governed" in review["blocked_reasons"]
+ assert review["source_alignment"]["missing_governed_sources"] == [
+ {"platform_code": "shopee", "source_key": "shopee_home"}
+ ]
+
+
+def test_mcp_fetch_target_source_governance_review_route_get_and_post_preview_only():
+ from routes.market_intel_routes import market_intel_bp
+
+ app = Flask(__name__)
+ app.secret_key = "test-secret"
+ app.register_blueprint(market_intel_bp)
+ client = app.test_client()
+ with client.session_transaction() as session:
+ session["logged_in"] = True
+
+ get_response = client.get(
+ "/api/market_intel/mcp_fetch_target_source_governance_review"
+ )
+ get_data = get_response.get_json()
+ sample = get_data["sample_fetch_target_source_governance_review_package"]
+ post_response = client.post(
+ "/api/market_intel/mcp_fetch_target_source_governance_review",
+ json={"fetch_target_source_governance_review_package": sample},
+ )
+ post_data = post_response.get_json()
+
+ assert get_response.status_code == 200
+ assert get_data["mode"] == "mcp_fetch_target_source_governance_review_preview"
+ assert get_data["phase"] == "phase_140_market_intel_professional_source_governance"
+ assert get_data["api_fetches_source_url"] is False
+ assert get_data["api_writes_database"] is False
+ assert post_response.status_code == 200
+ assert post_data["mode"] == "mcp_fetch_target_source_governance_review"
+ assert post_data["phase"] == "phase_140_market_intel_professional_source_governance"
+ assert post_data["mcp_fetch_target_source_governance_review_accepted"] is True
+ assert post_data["source_alignment"]["all_target_sources_governed"] is True
+ assert post_data["network_request_allowed"] is False
+ assert post_data["api_fetches_robots_txt"] is False
+ assert post_data["api_fetches_source_url"] is False
+ assert post_data["api_opens_database_connection"] is False
+ assert post_data["api_writes_database"] is False
+ assert post_data["payload_persisted"] is False
+ assert post_data["scheduler_attached"] is False