feat: upgrade to MCP 1.10.1 with streamable HTTP transport (#41)

* feat: upgrade to MCP 1.10.1 with streamable HTTP transport

- Upgrade from MCP 1.9.4 to 1.10.1
- Add streamablehttp_client support
- Run uv sync --upgrade for dependency updates
- Update README.md

* Bump version to 0.14.0

Author: jonigl

README.md

@@ -20,7 +20,7 @@
   <img src="https://raw.githubusercontent.com/jonigl/mcp-client-for-ollama/v0.13.0/misc/ollmcp-demo.gif" alt="MCP Client for Ollama Demo">
 </p>
 <p align="center">
-  <a href="https://asciinema.org/a/jxc6N8oKZAWrzH8aK867zhXdO" target="_blank">🎥 View this demo as an asciinema recording</a>
+  <a href="https://asciinema.org/a/jxc6N8oKZAWrzH8aK867zhXdO" target="_blank">🎥 Watch this demo as an Asciinema recording</a>
 </p>
 
 ## Table of Contents
@@ -398,7 +398,7 @@ The configuration saves:
 
 ## Server Configuration Format
 
-The JSON configuration file supports STDIO, SSE, and Streamable HTTP server types:
+The JSON configuration file supports STDIO, SSE, and Streamable HTTP server types (MCP 1.10.1):
 
 ```json
 {
@@ -432,7 +432,7 @@ The JSON configuration file supports STDIO, SSE, and Streamable HTTP server type
 }
 ```
 > [!NOTE]
-> If you specify a URL without a type, the client will default to using Streamable HTTP transport.
+> **MCP 1.10.1 Transport Support**: The client now supports the latest Streamable HTTP transport with improved performance and reliability. If you specify a URL without a type, the client will default to using Streamable HTTP transport.
 
 ## Compatible Models
 
@@ -470,11 +470,13 @@ This project is licensed under the MIT License - see the [LICENSE](LICENSE) file
 
 ## Acknowledgments
 
-- [Model Context Protocol](https://modelcontextprotocol.io/) for the specification and examples
 - [Ollama](https://ollama.com/) for the local LLM runtime
+- [Model Context Protocol](https://modelcontextprotocol.io/) for the specification and examples
 - [Rich](https://rich.readthedocs.io/) for the terminal user interface
 - [Typer](https://typer.tiangolo.com/) for the modern CLI experience
+- [Prompt Toolkit](https://python-prompt-toolkit.readthedocs.io/) for the interactive command line interface
 - [UV](https://www.uvicorn.org/) for the lightning-fast Python package manager and virtual environment management
+- [Asciinema](https://asciinema.org/) for the demo recording
 
 ---
 

cli-package/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "ollmcp"
-version = "0.13.0"
+version = "0.14.0"
 description = "CLI for MCP Client for Ollama - An easy-to-use command for interacting with Ollama through MCP"
 readme = "README.md"
 requires-python = ">=3.10"
@@ -9,7 +9,7 @@ authors = [
     {name = "Jonathan Löwenstern"}
 ]
 dependencies = [
-    "mcp-client-for-ollama==0.13.0"
+    "mcp-client-for-ollama==0.14.0"
 ]
 
 [project.scripts]

mcp_client_for_ollama/__init__.py

@@ -1,3 +1,3 @@
 """MCP Client for Ollama package."""
 
-__version__ = "0.13.0"
+__version__ = "0.14.0"

mcp_client_for_ollama/server/connector.py

@@ -4,8 +4,6 @@
 initialization, and communication.
 """
 
-import os
-import shutil
 import os
 import shutil
 from contextlib import AsyncExitStack
@@ -15,6 +13,7 @@
 from mcp import ClientSession, Tool
 from mcp.client.stdio import stdio_client, StdioServerParameters
 from mcp.client.sse import sse_client
+from mcp.client.streamable_http import streamablehttp_client
 
 from .discovery import process_server_paths, parse_server_configs, auto_discover_servers
 
@@ -38,6 +37,7 @@ def __init__(self, exit_stack: AsyncExitStack, console: Optional[Console] = None
         self.sessions = {}  # Dict to store multiple sessions
         self.available_tools = []  # List to store all available tools
         self.enabled_tools = {}  # Dict to store tool enabled status
+        self.session_ids = {}  # Dict to store session IDs for HTTP connections
 
     async def connect_to_servers(self, server_paths=None, config_path=None, auto_discovery=False) -> Tuple[dict, list, dict]:
         """Connect to one or more MCP servers
@@ -137,13 +137,17 @@ async def _connect_to_server(self, server: Dict[str, Any]) -> bool:
 
                 headers = self._get_headers_from_server(server)
 
-                # In MCP 1.9.0, use SSE client for HTTP connections as well
-                # since the dedicated HTTP client is no longer available
-                self.console.print(f"[yellow]Note: Using SSE client for HTTP connection to {server_name}[/yellow]")
-                transport = await self.exit_stack.enter_async_context(sse_client(url, headers=headers))
-                read_stream, write_stream = transport
+                # Use the streamablehttp_client for Streamable HTTP connections
+                transport = await self.exit_stack.enter_async_context(
+                    streamablehttp_client(url, headers=headers)
+                )
+                read_stream, write_stream, session_info = transport
                 session = await self.exit_stack.enter_async_context(ClientSession(read_stream, write_stream))
 
+                # Store session ID if provided
+                if hasattr(session_info, 'session_id') and session_info.session_id:
+                    self.session_ids[server_name] = session_info.session_id
+
             elif server_type == "script":
                 # Connect to script-based server using STDIO
                 server_params = self._create_script_params(server)
@@ -383,17 +387,23 @@ def _get_headers_from_server(self, server: Dict[str, Any]) -> Dict[str, str]:
         if not headers and "config" in server:
             headers = server["config"].get("headers", {})
 
+        # Always add MCP Protocol Version header for HTTP connections
+        server_type = server.get("type", "script")
+        if server_type in ["sse", "streamable_http"]:
+            headers["MCP-Protocol-Version"] = "2025-06-18"
+
         return headers
 
     async def disconnect_all_servers(self):
         """Disconnect from all servers and reset state"""
-        # Close all existing connections
+        # Close all existing connections via exit stack
         await self.exit_stack.aclose()
 
         # Create a new exit stack for future connections
         self.exit_stack = AsyncExitStack()
 
         # Clear all state
-        self.sessions = {}
-        self.available_tools = []
-        self.enabled_tools = {}
+        self.sessions.clear()
+        self.available_tools.clear()
+        self.enabled_tools.clear()
+        self.session_ids.clear()

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "mcp-client-for-ollama"
-version = "0.13.0"
+version = "0.14.0"
 description = "MCP Client for Ollama - A client for connecting to Model Context Protocol servers using Ollama"
 readme = "README.md"
 requires-python = ">=3.10"