import requests, json

# 通过 Registry API 查询某个分类下的所有服务器
def discover_mcp_servers(category="web"):
    base = "https://registry.modelcontextprotocol.io/v0"
    resp = requests.get(f"{base}/servers", timeout=15)
    if resp.status_code == 200:
        servers = resp.json()
        # 按分类动态过滤
        filtered = [s for s in servers if category.lower() in s.get("tags", [])]
        return filtered
    return []

# 发现所有 web 相关的 MCP 服务器
web_servers = discover_mcp_servers("web")
print(f"发现 {len(web_servers)} 个 web MCP 服务器")
for s in web_servers[:5]:
    print(f"  - {s['name']}: {s['description']}")

import requests
from datetime import datetime, timedelta

def score_server_trust(server_name):
    base = "https://registry.modelcontextprotocol.io/v0"
    resp = requests.get(f"{base}/servers/{server_name}", timeout=15)
    if resp.status_code != 200:
        return {"trust": "unknown", "score": 0}

    data = resp.json()
    last_push = data.get("last_push", "")
    stars = data.get("github_stars", 0)
    verified = data.get("verified", False)

    # 计算可信度评分
    score = 0
    if verified: score += 40
    if stars > 1000: score += 30
    if stars > 10000: score += 20
    # 超过 90 天未更新则扣分
    try:
        push_date = datetime.fromisoformat(last_push.replace("Z", "+00:00"))
        if (datetime.now(push_date.tzinfo) - push_date).days > 90:
            score -= 25
    except:
        pass

    trust = "高" if score >= 60 else "中" if score >= 30 else "低"
    return {"trust": trust, "score": score, "verified": verified, "stars": stars}

# 使用前先检查可信度
trust = score_server_trust("modelcontextprotocol/python-sdk")
print(f"可信度等级：{trust['trust']}（评分：{trust['score']}）")
print(f"官方验证：{trust['verified']}，Stars：{trust['stars']}")

import requests, json

CAPABILITY_TAGS = {
    "browser": ["browser", "web", "playwright", "chrome"],
    "database": ["database", "postgres", "mysql", "sqlite"],
    "communication": ["slack", "discord", "email", "messaging"],
    "ai_ml": ["llm", "embedding", "vector", "model"],
    "filesystem": ["filesystem", "file", "storage", "s3"],
}

def find_servers_for_capability(capability, min_stars=100):
    base = "https://registry.modelcontextprotocol.io/v0"
    resp = requests.get(f"{base}/servers", timeout=15)
    if resp.status_code != 200:
        return []

    servers = resp.json()
    tags = CAPABILITY_TAGS.get(capability, [capability])

    candidates = []
    for s in servers:
        server_tags = [t.lower() for t in s.get("tags", [])]
        if any(t in server_tags for t in tags):
            if s.get("github_stars", 0) >= min_stars:
                candidates.append(s)

    # 按 Stars 降序排列
    candidates.sort(key=lambda x: x.get("github_stars", 0), reverse=True)
    return candidates

# 查找所有浏览器自动化 MCP 服务器
browser_servers = find_servers_for_capability("browser", min_stars=500)
print(f"浏览器能力服务器（发现 {len(browser_servers)} 个）：")
for s in browser_servers[:3]:
    print(f"  [{s.get('github_stars', 0)}★] {s['name']} - {s.get('description', '')[:60]}")

# 用 Docker 部署自托管 MCP Registry
git clone https://github.com/modelcontextprotocol/registry
cd registry

# 配置企业专用服务器
cat > .env << EOF
MCP_REGISTRY_ORG=your-company
MCP_REGISTRY_INTERNAL_SERVERS=internal-db,internal-slack,internal-notion
EOF

# 启动 Registry
make dev-compose
# Registry 在 http://localhost:8080 可用

import os

# 将 MCP 客户端指向内部 Registry
os.environ["MCP_REGISTRY_URL"] = "http://localhost:8080"

# MCP SDK 现在会优先查询内部 Registry，
# 找不到时再回退到公共 Registry
from modelcontextprotocol import Client

client = Client()
# 从内部 Registry 自动发现工具
await client.connect()

# Step 1: 在仓库根目录创建清单文件
# manifest.json
manifest = {
    "name": "my-company-mcp",
    "description": "公司内部工具的 MCP 服务器",
    "tags": ["internal", "company", "productivity"],
    "repository": "https://github.com/your-org/mcp-server",
    "categories": ["productivity", "internal"],
    "installation": "pip install my-company-mcp"
}

# Step 2: 通过 API 提交到 Registry
import requests

resp = requests.post(
    "https://registry.modelcontextprotocol.io/v0/servers",
    json=manifest,
    headers={"Content-Type": "application/json"},
    timeout=15
)
print(f"发布状态：{resp.status_code}", resp.json())