Merge pull request #7 from meilisearch/add-dynamic-connection

Add dynamic connection tooling

Author: tpayet

README.md

@@ -8,6 +8,7 @@ A Model Context Protocol (MCP) server for interacting with Meilisearch through L
 - Settings configuration with templates for common use cases (e-commerce, content search, SaaS)
 - Task monitoring and API key management
 - Built-in logging and monitoring tools
+- Dynamic connection configuration to switch between Meilisearch instances
 
 ## Installation
 
@@ -33,8 +34,32 @@ uv pip install -e .
 ### Environment Variables
 
 ```bash
-MEILI_HTTP_ADDR=http://localhost:7700  # Meilisearch URL
-MEILI_MASTER_KEY=your_master_key       # Optional: Meilisearch API key
+MEILI_HTTP_ADDR=http://localhost:7700  # Default Meilisearch URL
+MEILI_MASTER_KEY=your_master_key       # Optional: Default Meilisearch API key
+```
+
+### Dynamic Connection Configuration
+
+The server provides tools to view and update connection settings at runtime:
+
+- `get-connection-settings`: View current connection URL and API key status
+- `update-connection-settings`: Update URL and/or API key to connect to a different Meilisearch instance
+
+Example usage through MCP:
+```json
+// Get current settings
+{
+  "name": "get-connection-settings"
+}
+
+// Update connection settings
+{
+  "name": "update-connection-settings",
+  "arguments": {
+    "url": "http://new-host:7700",
+    "api_key": "new-api-key"
+  }
+}
 ```
 
 ### Running the Server

src/meilisearch_mcp/monitoring.py

@@ -81,7 +81,7 @@ async def get_system_information(self) -> Dict[str, Any]:
         """Get system-level information"""
         try:
             version = self.client.get_version()
-            stats = self.client.get_stats()
+            stats = self.client.get_all_stats()
 
             return {
                 "version": version,

src/meilisearch_mcp/server.py

@@ -39,17 +39,45 @@ def __init__(
             log_dir = os.path.expanduser("~/.meilisearch-mcp/logs")
 
         self.logger = MCPLogger("meilisearch-mcp", log_dir)
+        self.url = url
+        self.api_key = api_key
         self.meili_client = MeilisearchClient(url, api_key)
         self.server = Server("meilisearch")
         self._setup_handlers()
 
+    async def update_connection(self, url: Optional[str] = None, api_key: Optional[str] = None):
+        """Update connection settings and reinitialize client if needed"""
+        if url:
+            self.url = url
+        if api_key:
+            self.api_key = api_key
+        
+        self.meili_client = MeilisearchClient(self.url, self.api_key)
+        self.logger.info("Updated Meilisearch connection settings", url=self.url)
+
     def _setup_handlers(self):
         """Setup MCP request handlers"""
 
         @self.server.list_tools()
         async def handle_list_tools() -> list[types.Tool]:
             """List available tools"""
             return [
+                types.Tool(
+                    name="get-connection-settings",
+                    description="Get current Meilisearch connection settings",
+                    inputSchema={"type": "object", "properties": {}},
+                ),
+                types.Tool(
+                    name="update-connection-settings",
+                    description="Update Meilisearch connection settings",
+                    inputSchema={
+                        "type": "object",
+                        "properties": {
+                            "url": {"type": "string", "optional": True},
+                            "api_key": {"type": "string", "optional": True},
+                        },
+                    },
+                ),
                 types.Tool(
                     name="health-check",
                     description="Check Meilisearch server health",
@@ -241,7 +269,27 @@ async def handle_call_tool(
         ) -> list[types.TextContent]:
             """Handle tool execution"""
             try:
-                if name == "create-index":
+                if name == "get-connection-settings":
+                    return [
+                        types.TextContent(
+                            type="text",
+                            text=f"Current connection settings:\nURL: {self.url}\nAPI Key: {'*' * 8 if self.api_key else 'Not set'}",
+                        )
+                    ]
+
+                elif name == "update-connection-settings":
+                    await self.update_connection(
+                        arguments.get("url"),
+                        arguments.get("api_key")
+                    )
+                    return [
+                        types.TextContent(
+                            type="text",
+                            text=f"Successfully updated connection settings to URL: {self.url}",
+                        )
+                    ]
+
+                elif name == "create-index":
                     result = await self.meili_client.indexes.create_index(
                         arguments["uid"], arguments.get("primaryKey")
                     )