Merge pull request #12 from redhat-ai-tools/revert-11-mcp-python-sdk

Revert "switch from fastmcp to mcp"

Author: maorfr

requirements.txt

@@ -1,2 +1,2 @@
 httpx==0.28.1
-mcp==1.10.1
+fastmcp==2.8.0

slack_mcp_server.py

@@ -2,8 +2,6 @@
 from typing import Any
 import httpx
 from mcp.server.fastmcp import FastMCP
-import asyncio
-from starlette.responses import PlainTextResponse
 
 SLACK_API_BASE = "https://slack.com/api"
 MCP_TRANSPORT = os.environ.get("MCP_TRANSPORT", "stdio")
@@ -13,16 +11,6 @@
     "slack", settings={"host": "127.0.0.1" if MCP_TRANSPORT == "stdio" else "0.0.0.0"}
 )
 
-# Global metrics store
-metrics = {
-    'get_channel_history_total': 0,
-    'post_message_total': 0,
-    'post_command_total': 0,
-    'add_reaction_total': 0,
-    'whoami_total': 0,
-    'join_channel_total': 0,
-}
-metrics_lock = asyncio.Lock()
 
 async def make_request(
     url: str, payload: dict[str, Any] | None = None
@@ -61,8 +49,6 @@ async def log_to_slack(message: str):
 @mcp.tool()
 async def get_channel_history(channel_id: str) -> str:
     """Get the history of a channel."""
-    async with metrics_lock:
-        metrics['get_channel_history_total'] += 1
     await log_to_slack(f"Getting history of channel <#{channel_id}>")
     url = f"{SLACK_API_BASE}/conversations.history"
     payload = {"channel": channel_id}
@@ -76,8 +62,6 @@ async def post_message(
     channel_id: str, message: str, thread_ts: str = "", skip_log: bool = False
 ) -> str:
     """Post a message to a channel."""
-    async with metrics_lock:
-        metrics['post_message_total'] += 1
     if not skip_log:
         await log_to_slack(f"Posting message to channel <#{channel_id}>: {message}")
     await join_channel(channel_id, skip_log=skip_log)
@@ -94,8 +78,6 @@ async def post_command(
     channel_id: str, command: str, text: str, skip_log: bool = False
 ) -> str:
     """Post a command to a channel."""
-    async with metrics_lock:
-        metrics['post_command_total'] += 1
     if not skip_log:
         await log_to_slack(
             f"Posting command to channel <#{channel_id}>: {command} {text}"
@@ -110,8 +92,6 @@ async def post_command(
 @mcp.tool()
 async def add_reaction(channel_id: str, message_ts: str, reaction: str) -> str:
     """Add a reaction to a message."""
-    async with metrics_lock:
-        metrics['add_reaction_total'] += 1
     await log_to_slack(
         f"Adding reaction to message {message_ts} in channel <#{channel_id}>: :{reaction}:"
     )
@@ -124,8 +104,6 @@ async def add_reaction(channel_id: str, message_ts: str, reaction: str) -> str:
 @mcp.tool()
 async def whoami() -> str:
     """Checks authentication & identity."""
-    async with metrics_lock:
-        metrics['whoami_total'] += 1
     await log_to_slack("Checking authentication & identity")
     url = f"{SLACK_API_BASE}/auth.test"
     data = await make_request(url)
@@ -135,8 +113,6 @@ async def whoami() -> str:
 @mcp.tool()
 async def join_channel(channel_id: str, skip_log: bool = False) -> str:
     """Join a channel."""
-    async with metrics_lock:
-        metrics['join_channel_total'] += 1
     if not skip_log:
         await log_to_slack(f"Joining channel <#{channel_id}>")
     url = f"{SLACK_API_BASE}/conversations.join"
@@ -145,12 +121,5 @@ async def join_channel(channel_id: str, skip_log: bool = False) -> str:
     return data.get("ok")
 
 
-@mcp.custom_route("/metrics", methods=["GET"])
-async def metrics_endpoint(request):
-    async with metrics_lock:
-        lines = [f"{k} {v}" for k, v in metrics.items()]
-    return PlainTextResponse("\n".join(lines) + "\n", media_type="text/plain")
-
-
 if __name__ == "__main__":
     mcp.run(transport=MCP_TRANSPORT)