wehub-resource-sync
37 lines
990 B
Python
37 lines
990 B
Python
#!/usr/bin/env python3
|
|
"""Local smoke check for Horizon MCP integration."""
|
|
|
|
from __future__ import annotations
|
|
|
|
import asyncio
|
|
import json
|
|
|
|
from src.mcp.horizon_adapter import resolve_horizon_path
|
|
from src.mcp.server import hz_get_metrics
|
|
from src.mcp.service import HorizonPipelineService
|
|
|
|
|
|
async def _main() -> None:
|
|
horizon_path = resolve_horizon_path()
|
|
service = HorizonPipelineService()
|
|
validation = await service.validate_config(
|
|
horizon_path=str(horizon_path),
|
|
check_env=False,
|
|
)
|
|
metrics = hz_get_metrics()
|
|
|
|
payload = {
|
|
"ok": True,
|
|
"horizon_path": str(horizon_path),
|
|
"config_path": validation["config_path"],
|
|
"enabled_sources": validation["enabled_sources"],
|
|
"languages": validation["ai"]["languages"],
|
|
"metrics_ok": metrics["ok"],
|
|
"metrics_tool": metrics["tool"],
|
|
}
|
|
print(json.dumps(payload, ensure_ascii=False, indent=2))
|
|
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(_main())
|