feat(cluster): add MCP server to work with Platform

Author: fubuloubu

setup.py

@@ -3,6 +3,9 @@
 from setuptools import find_packages, setup
 
 extras_require = {
+    "mcp": [
+        "mcp[cli]",  # MCP Server & AI Computer Use
+    ],
     "test": [  # `test` GitHub Action jobs uses this
         "pytest>=6.0",  # Core testing package
         "pytest-xdist",  # Multi-process runner
@@ -44,6 +47,7 @@
     + extras_require["doc"]
     + extras_require["release"]
     + extras_require["dev"]
+    + extras_require["mcp"]
 )
 
 with open("./README.md") as readme:

silverback/cluster/mcp.py

@@ -0,0 +1,63 @@
+from collections.abc import AsyncIterator
+from contextlib import asynccontextmanager
+from dataclasses import dataclass
+
+from fief_client import Fief
+from fief_client.integrations.cli import FiefAuth
+from mcp.server.fastmcp import Context, FastMCP
+
+from silverback.cluster.client import PlatformClient
+from silverback.cluster.settings import PROFILE_PATH, PlatformProfile, ProfileSettings
+from silverback.cluster.types import ClusterHealth
+
+
+@dataclass
+class AppContext:
+    platform: PlatformClient
+
+
+@asynccontextmanager
+async def lifespan(server: FastMCP) -> AsyncIterator[AppContext]:
+    settings = ProfileSettings.from_config_file()
+
+    # TODO: Allow loading arbitrary profiles
+    profile = settings.profile["staging"]
+    assert isinstance(profile, PlatformProfile)
+
+    auth = FiefAuth(
+        Fief(
+            settings.auth[profile.auth].host,
+            settings.auth[profile.auth].client_id,
+        ),
+        str(PROFILE_PATH.parent / f"{profile.auth}.json"),
+    )
+    platform = PlatformClient(
+        base_url=profile.host,
+        cookies=dict(session=auth.access_token_info()["access_token"]),
+    )
+    yield AppContext(platform=platform)
+
+
+mcp = FastMCP("silverback", dependencies=["silverback"], lifespan=lifespan)
+
+
+@mcp.resource("workspace://")
+def list_workspaces(ctx: Context) -> list[str]:
+    """Get the list of all available Workspaces"""
+    platform = ctx.request_context.lifespan_context["platform"]
+    return list(platform.workspaces)
+
+
+@mcp.resource("workspace://{workspace_name}")
+def list_clusters(workspace_name: str, ctx: Context) -> list[str]:
+    """Get the list of all Cluster names in a specific Workspace."""
+    platform = ctx.request_context.lifespan_context["platform"]
+    return list(platform.workspaces[workspace_name].clusters)
+
+
+@mcp.resource("cluster://{workspace_name}/{cluster_name}/health")
+def cluster_health(workspace_name: str, cluster_name: str, ctx: Context) -> ClusterHealth:
+    """Obtain the health of Bots and Networks in connected Cluster."""
+    platform = ctx.request_context.lifespan_context["platform"]
+    cluster = platform.get_cluster_client(workspace_name, cluster_name)
+    return cluster.health