@@ -479,10 +497,11 @@
const dbProbeRoot = document.querySelector('[data-market-intel-db-probe]');
const seedDiffRoot = document.querySelector('[data-market-intel-seed-diff]');
const legacyBridgeRoot = document.querySelector('[data-market-intel-legacy-bridge]');
+ const mcpReadinessRoot = document.querySelector('[data-market-intel-mcp-readiness]');
const migrationRoot = document.querySelector('[data-market-intel-migration]');
const approvalRoot = document.querySelector('[data-market-intel-approval]');
const deployRoot = document.querySelector('[data-market-intel-deploy]');
- if (!root && !writerRoot && !cliRoot && !dbProbeRoot && !seedDiffRoot && !legacyBridgeRoot && !migrationRoot && !approvalRoot && !deployRoot) return;
+ if (!root && !writerRoot && !cliRoot && !dbProbeRoot && !seedDiffRoot && !legacyBridgeRoot && !mcpReadinessRoot && !migrationRoot && !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;
@@ -508,6 +527,10 @@
const legacyBridgeBody = legacyBridgeRoot ? legacyBridgeRoot.querySelector('[data-market-intel-legacy-bridge-body]') : null;
const legacyBridgeRefresh = legacyBridgeRoot ? legacyBridgeRoot.querySelector('[data-market-intel-legacy-bridge-refresh]') : null;
const legacyBridgeEndpoint = "{{ url_for('market_intel.market_intel_legacy_source_bridge') }}?execute=false&limit=5";
+ const mcpReadinessMeta = mcpReadinessRoot ? mcpReadinessRoot.querySelector('[data-market-intel-mcp-readiness-meta]') : null;
+ const mcpReadinessBody = mcpReadinessRoot ? mcpReadinessRoot.querySelector('[data-market-intel-mcp-readiness-body]') : null;
+ const mcpReadinessRefresh = mcpReadinessRoot ? mcpReadinessRoot.querySelector('[data-market-intel-mcp-readiness-refresh]') : null;
+ const mcpReadinessEndpoint = "{{ url_for('market_intel.market_intel_mcp_readiness') }}?execute=false&timeout=3";
const migrationMeta = migrationRoot ? migrationRoot.querySelector('[data-market-intel-migration-meta]') : null;
const migrationBody = migrationRoot ? migrationRoot.querySelector('[data-market-intel-migration-body]') : null;
const migrationRefresh = migrationRoot ? migrationRoot.querySelector('[data-market-intel-migration-refresh]') : null;
@@ -842,6 +865,103 @@
}
};
+ const renderMcpReadinessMeta = data => {
+ mcpReadinessMeta.innerHTML = [
+ `mode=${data.mode || 'unknown'}`,
+ `router=${data.router_enabled ? 'on' : 'off'}`,
+ `external=${data.external_mcp_complete ? 'complete' : 'pending'}`,
+ `internal=${data.internal_mcp_complete ? 'complete' : 'pending'}`,
+ `market_tools=${data.market_intel_tool_count || 0}`
+ ].map(item => `
${escapeHtml(item)}`).join('');
+ };
+
+ const renderMcpReadinessBody = data => {
+ const blockers = (data.blocked_reasons || []).join(' / ');
+ const servers = data.server_statuses || [];
+ const checks = Object.entries(data.readiness_checks || {});
+ const expectedTools = data.expected_market_intel_tools || [];
+ const registeredCallers = data.registered_callers || [];
+ const telemetry = data.telemetry || {};
+ mcpReadinessBody.innerHTML = `
+
目前只做 MCP readiness planned preview；不自動呼叫外部平台、不建立 DB session、不寫入 telemetry。${blockers ? `阻擋：${escapeHtml(blockers)}` : ''}
+
+
+
EXTERNAL MCP SERVERS
+
${
+ servers.length
+ ? servers.map(item => `
+
+
+ ${escapeHtml(item.server)}
+ ${escapeHtml(item.base_url || 'not configured')}
+ ${escapeHtml(item.status || '')}
+
+
${item.healthy ? 'HEALTHY' : item.configured ? 'PENDING' : 'MISSING'}
+
+ `).join('')
+ : '
尚未提供 MCP server 狀態。
'
+ }
+
+
+
READINESS CHECKS
+
${
+ checks.length
+ ? checks.map(([name, passed]) => `
+
+
+ ${escapeHtml(name)}
+
+
${passed ? 'PASS' : 'BLOCK'}
+
+ `).join('')
+ : '
尚未提供 readiness checks。
'
+ }
+
+
+
INTERNAL TOOL CONTRACT
+
+
+
+ registered_callers
+ ${escapeHtml(registeredCallers.join(' / ') || 'none')}
+
+
${registeredCallers.length}
+
+
+
+ market_intel_expected_tools
+ ${escapeHtml(expectedTools.join(' / ') || 'none')}
+
+
${escapeHtml(data.market_intel_tool_count || 0)}
+
+
+
+ mcp_calls telemetry
+ ${escapeHtml(telemetry.mode || 'unknown')} / table=${telemetry.table_exists ? 'exists' : 'pending'}
+
+
${telemetry.read_only_query_executed ? 'QUERY' : 'PLANNED'}
+
+
+
+
+ `;
+ };
+
+ const loadMcpReadiness = async () => {
+ if (!mcpReadinessMeta || !mcpReadinessBody) return;
+ mcpReadinessBody.innerHTML = '
讀取 MCP 整合就緒度中...
';
+ try {
+ const response = await fetch(mcpReadinessEndpoint, { credentials: 'same-origin' });
+ if (!response.ok) throw new Error(`HTTP ${response.status}`);
+ const data = await response.json();
+ renderMcpReadinessMeta(data);
+ renderMcpReadinessBody(data);
+ } catch (error) {
+ mcpReadinessMeta.innerHTML = '
error';
+ mcpReadinessBody.innerHTML = `
MCP 就緒度讀取失敗：${escapeHtml(error.message)}
`;
+ }
+ };
+
const renderMigrationMeta = data => {
const seedWriter = data.command_plan && data.command_plan.seed_writer_command
? data.command_plan.seed_writer_command
@@ -1094,6 +1214,9 @@
if (legacyBridgeRefresh) {
legacyBridgeRefresh.addEventListener('click', loadLegacyBridge);
}
+ if (mcpReadinessRefresh) {
+ mcpReadinessRefresh.addEventListener('click', loadMcpReadiness);
+ }
if (migrationRefresh) {
migrationRefresh.addEventListener('click', loadMigration);
}
@@ -1109,6 +1232,7 @@
loadDbProbe();
loadSeedDiff();
loadLegacyBridge();
+ loadMcpReadiness();
loadMigration();
loadApproval();
loadDeploy();
diff --git a/tests/test_market_intel_skeleton.py b/tests/test_market_intel_skeleton.py
index ae1887d..79848ee 100644
--- a/tests/test_market_intel_skeleton.py
+++ b/tests/test_market_intel_skeleton.py
@@ -14,6 +14,7 @@ from services.market_intel.adapters import get_adapter, get_adapter_summaries
from services.market_intel.candidate_preview import build_candidate_preview_from_discovery
from services.market_intel.discovery_runner import ManualDiscoveryRunner
from services.market_intel.html_diagnostics import parse_html_diagnostics
+from services.market_intel.mcp_readiness import build_mcp_readiness_plan
from services.market_intel.platform_seed_db_diff import build_platform_seed_db_diff_plan
from services.market_intel.schema_db_probe import build_schema_db_probe_plan
@@ -381,6 +382,10 @@ def test_market_intel_preview_template_uses_safe_fetch_false_endpoint():
assert "data-market-intel-db-probe-body" in template
assert "data-market-intel-seed-diff" in template
assert "data-market-intel-seed-diff-body" in template
+ assert "data-market-intel-mcp-readiness" in template
+ assert "data-market-intel-mcp-servers" in template
+ assert "data-market-intel-mcp-checks" in template
+ assert "data-market-intel-mcp-tools" in template
assert "data-market-intel-migration" in template
assert "data-market-intel-migration-tables" in template
assert "data-market-intel-approval" in template
@@ -394,6 +399,7 @@ def test_market_intel_preview_template_uses_safe_fetch_false_endpoint():
assert "market_intel.market_intel_schema_db_probe" in template
assert "market_intel.market_intel_platform_seed_db_diff" in template
assert "market_intel.market_intel_legacy_source_bridge" in template
+ assert "market_intel.market_intel_mcp_readiness" in template
assert "market_intel.market_intel_migration_blueprint" in template
assert "market_intel.market_intel_write_approval_runbook" in template
assert "market_intel.market_intel_deployment_readiness" in template
@@ -419,7 +425,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_27_legacy_source_bridge_preview"
+ assert bridge["phase"] == "phase_28_mcp_readiness_preview"
assert bridge["execute_requested"] is False
assert bridge["read_only_query_executed"] is False
assert bridge["database_connection_opened"] is False
@@ -573,6 +579,140 @@ def test_legacy_source_bridge_read_only_sqlite_counts_sources():
)
+def test_mcp_readiness_default_is_planned_only(monkeypatch):
+ monkeypatch.delenv("MCP_ROUTER_ENABLED", raising=False)
+
+ readiness = MarketIntelService().build_mcp_readiness()
+
+ assert readiness["mode"] == "mcp_readiness_planned"
+ assert readiness["phase"] == "phase_28_mcp_readiness_preview"
+ assert readiness["execute_requested"] is False
+ assert readiness["router_enabled"] is False
+ assert readiness["external_mcp_complete"] is False
+ assert readiness["internal_mcp_complete"] is False
+ assert readiness["market_intel_mcp_integrated"] is False
+ assert readiness["database_session_created"] is False
+ assert readiness["database_write_executed"] is False
+ assert readiness["database_commit_executed"] is False
+ assert readiness["external_network_executed"] is False
+ assert readiness["scheduler_attached"] is False
+ assert readiness["writes_executed"] is False
+ assert readiness["would_write_database"] is False
+ assert readiness["telemetry"]["read_only_query_executed"] is False
+ assert readiness["telemetry"]["database_session_created"] is False
+ assert readiness["telemetry"]["database_write_executed"] is False
+ assert readiness["readiness_checks"]["base_callers_registered"] is True
+ assert readiness["readiness_checks"]["market_intel_caller_registered"] is False
+ assert readiness["readiness_checks"]["market_intel_tools_registered"] is False
+ assert len(readiness["server_statuses"]) == 4
+ assert all(item["health_checked"] is False for item in readiness["server_statuses"])
+ assert all(item["healthy"] is False for item in readiness["server_statuses"])
+ assert "execute_false_planned_only" in readiness["blocked_reasons"]
+
+
+def test_mcp_readiness_sqlite_read_only_counts_telemetry(monkeypatch):
+ monkeypatch.delenv("MCP_ROUTER_ENABLED", raising=False)
+ monkeypatch.setattr(
+ "services.market_intel.mcp_readiness._health_check_servers",
+ lambda base_hosts, timeout_sec: [
+ {
+ "server": "postgres",
+ "base_url": "http://127.0.0.1:3001",
+ "configured": True,
+ "health_checked": True,
+ "healthy": False,
+ "status": "error",
+ "error_message": "test skipped network",
+ },
+ {
+ "server": "omnisearch",
+ "base_url": "http://127.0.0.1:3003",
+ "configured": True,
+ "health_checked": True,
+ "healthy": False,
+ "status": "error",
+ "error_message": "test skipped network",
+ },
+ {
+ "server": "firecrawl",
+ "base_url": "http://127.0.0.1:3002",
+ "configured": True,
+ "health_checked": True,
+ "healthy": False,
+ "status": "error",
+ "error_message": "test skipped network",
+ },
+ {
+ "server": "filesystem",
+ "base_url": "http://127.0.0.1:3004",
+ "configured": True,
+ "health_checked": True,
+ "healthy": False,
+ "status": "error",
+ "error_message": "test skipped network",
+ },
+ ],
+ )
+ engine = create_engine("sqlite:///:memory:")
+ with engine.begin() as conn:
+ conn.execute(
+ text(
+ """
+ CREATE TABLE mcp_calls (
+ id INTEGER PRIMARY KEY,
+ server TEXT,
+ called_at TEXT
+ )
+ """
+ )
+ )
+ conn.execute(
+ text(
+ """
+ INSERT INTO mcp_calls (server, called_at)
+ VALUES
+ ('omnisearch', '2026-05-18 10:00:00'),
+ ('omnisearch', '2026-05-18 10:05:00'),
+ ('postgres', '2026-05-18 10:10:00')
+ """
+ )
+ )
+
+ readiness = build_mcp_readiness_plan(
+ execute_requested=True,
+ timeout_sec=1,
+ engine=engine,
+ database_type="sqlite",
+ )
+
+ assert readiness["mode"] == "mcp_readiness_read_only"
+ assert readiness["execute_requested"] is True
+ assert readiness["router_enabled"] is False
+ assert readiness["external_mcp_complete"] is False
+ assert readiness["internal_mcp_complete"] is False
+ assert readiness["telemetry"]["mode"] == "mcp_telemetry_read_only"
+ assert readiness["telemetry"]["table_exists"] is True
+ assert readiness["telemetry"]["total_calls"] == 3
+ assert readiness["telemetry"]["recent_24h_calls"] == 3
+ assert readiness["telemetry"]["read_only_query_executed"] is True
+ assert readiness["telemetry"]["database_session_created"] is False
+ assert readiness["telemetry"]["database_write_executed"] is False
+ assert readiness["telemetry"]["database_commit_executed"] is False
+ assert readiness["database_session_created"] is False
+ assert readiness["database_write_executed"] is False
+ assert readiness["database_commit_executed"] is False
+ assert readiness["scheduler_attached"] is False
+ assert readiness["writes_executed"] is False
+ assert readiness["would_write_database"] is False
+ assert readiness["server_statuses"][0]["health_checked"] is True
+ assert {item["server"]: item["calls"] for item in readiness["telemetry"]["server_counts"]} == {
+ "omnisearch": 2,
+ "postgres": 1,
+ }
+ assert "mcp_router_enabled" in readiness["blocked_reasons"]
+ assert "market_intel_caller_registered" in readiness["blocked_reasons"]
+
+
def test_market_intel_schema_smoke_checks_platform_columns():
smoke = MarketIntelService().build_schema_smoke()["schema_smoke"]
@@ -821,6 +961,7 @@ def test_deployment_readiness_reports_app_only_release_gate():
assert readiness["checks"]["schema_db_probe_planned_safe"] is True
assert readiness["checks"]["platform_seed_db_diff_planned_safe"] is True
assert readiness["checks"]["legacy_source_bridge_planned_safe"] is True
+ assert readiness["checks"]["mcp_readiness_planned_safe"] is True
assert readiness["checks"]["writer_plan_dry_run_only"] is True
assert readiness["writer_plan_summary"]["writes_executed"] is False
assert "readiness_checks_not_all_passed" not in readiness["blocked_reasons"]
@@ -836,6 +977,7 @@ def test_deployment_readiness_reports_app_only_release_gate():
assert "/api/market_intel/deployment_readiness" in readiness["production_smoke_targets"]
assert "/api/market_intel/platform_seed_db_diff" in readiness["production_smoke_targets"]
assert "/api/market_intel/legacy_source_bridge" in readiness["production_smoke_targets"]
+ assert "/api/market_intel/mcp_readiness" in readiness["production_smoke_targets"]
assert readiness["write_approval_runbook"]["ready_for_real_write"] is False
assert readiness["write_approval_runbook"]["writes_executed"] is False
assert readiness["migration_blueprint"]["migration_executed"] is False
@@ -844,6 +986,8 @@ def test_deployment_readiness_reports_app_only_release_gate():
assert readiness["schema_db_probe"]["read_only_query_executed"] is False
assert readiness["platform_seed_db_diff"]["read_only_query_executed"] is False
assert readiness["legacy_source_bridge"]["read_only_query_executed"] is False
+ assert readiness["mcp_readiness"]["mode"] == "mcp_readiness_planned"
+ assert readiness["mcp_readiness"]["telemetry"]["read_only_query_executed"] is False
def test_write_approval_runbook_is_read_only_and_blocks_real_write():