generic-mcp-client-chat

Dependency "aiohttp@3.9.3" has known CVEs:

Dependency "fastmcp@2.0.0" has known CVEs:

Dependency "requests@2.31.0" has known CVEs:

Pattern "(connect|load|register|add)[_\s-]?(mcp|server|tool)(?!.*(?:verify|validate|checksum|hash|sign|cert|fingerprint|pin))" matched in source_code: "connect_mcp" (at position 4248)

Pattern "(invoke|call|execute)[_\s-]?(?:tool|agent|self)(?!.*(?:depth|level|limit|max[_\s-]?(?:depth|recursi|iter|call)|count))" matched in source_code: "call_tool" (at position 9634)

Pattern "(?:read|write|modify|delete).*(?:file|path|directory)(?!.*(?:lock|mutex|semaphore|flock|atomic))" matched in source_code: "ready include the /mcp path" (at position 4629)

Pattern "session\.(?:get|post|put|delete|patch|request)\s*\([^)]*(?:req|request|input|param|params|args|url|uri|href|target|endpoint|host)" matched in source_code: "session.get(url" (at position 3502)

Dependency "starlette@0.40.0" has known CVEs:

Dependency "mcp@1.8.0" has known CVEs:

Pattern "(?:delay|sleep|timeout|interval)\s*[:=]\s*(?:[^;]*(?:secret|token|password|credential|key|env))" matched in source_code: "timeout=3) as response: # We just care if it responds, status 200-4xx is fine for a basic ping logger.info(f"Availability check for {url} got status: {response.status}") return True # Server is at least responding to HTTP except asyncio.TimeoutError: logger.error(f"Timeout during basic availability check for {url}") return False except aiohttp.ClientConnectorError as e: logger.error(f"Connection error during basic availability check for {url}: {e}") return False except Exception as e: logger.error(f"Unexpected error during basic availability check for {url}: {e}") return False @app.post("/api/connect") async def connect_mcp_server(request: ConnectionRequest): logger.info(f"API call to connect to MCP server: '{request.server_name}' at {request.server_url}") if not request.server_url.startswith(("http://", "https://")): raise HTTPException(status_code=400, detail="Invalid server_url format. Must include http:// or https://") # The server_url for connect should already include the /mcp path if needed by FastMCP server if await check_server_availability(request.server_url): logger.info(f"Basic availability check passed for '{request.server_name}'. Proceeding with FastMCP connection.") success = await mcp_manager.connect(request.server_name, request.server_url) if success: logger.info(f"Successfully initiated connection to '{request.server_name}'.") return {"status": "connected", "server_name": request.server_name} else: logger.error(f"Failed to connect to '{request.server_name}' using MCPManager after availability check.") raise HTTPException(status_code=500, detail=f"Failed to connect to MCP server '{request.server_name}'. Check server logs.") else: logger.error(f"Basic availability check failed for '{request.server_name}' at {request.server_url}.") raise HTTPException(status_code=503, detail=f"MCP server '{request.server_name}' not available at {request.server_url}.") @app.post("/api/disconnect") async def disconnect_mcp_server(request: DisconnectRequest): logger.info(f"API call to disconnect from MCP server: '{request.server_name}'") success = await mcp_manager.disconnect(request.server_name) if success: logger.info(f"Successfully processed disconnect for '{request.server_name}'.") return {"status": "disconnected", "server_name": request.server_name} else: # Disconnect might return False if error during cleanup, but still considered processed. logger.warning(f"Disconnect for '{request.server_name}' completed, possibly with minor issues (e.g., already disconnected).") return {"status": "disconnected_with_issues_or_not_found", "server_name": request.server_name} @app.post("/api/chat") async def chat(request: Request): try: data = await request.json() message = data.get("message", "") # Get response from Claude with all available tools all_tools = [] for server_name in mcp_manager._clients.keys(): if mcp_manager.is_connected(server_name): try: tools = await mcp_manager.list_tools(server_name) logger.info(f"Found {len(tools)} tools on server {server_name}") for tool in tools: tool_info = { "name": f"{server_name}.{tool.name}", # Prefix tool name with server "description": tool.description, "input_schema": tool.inputSchema, "server": server_name } logger.info(f"Adding tool: {tool_info['name']}") all_tools.append(tool_info) except Exception as e: logger.error(f"Error getting tools from server {server_name}: {e}") logger.info(f"Total tools available: {len(all_tools)}") # Create system message with tool descriptions system_content = f"""You are a helpful AI assistant with access to the following tools: {json.dumps(all_tools, indent=2)} When you need to use a tool, respond with a JSON object in this format: {{ "tool": "server_name.tool_name", "parameters": {{ "param_name": "param_value" }} }} For example, to use the echo tool, respond with: {{ "tool": "default_mcp.echo", "parameters": {{ "message": "your message here" }} }} Otherwise, respond normally with your message.""" # Get response from Claude response = anthropic.messages.create( model="claude-3-7-sonnet-20250219", max_tokens=1024, system=system_content, messages=[{"role": "user", "content": message}] ) # Check if response is a tool call try: response_text = response.content[0].text.strip() # Try to extract JSON from code block code_block_match = re.search(r'```json\s*(\{[\s\S]*?\})\s*```', response_text) if code_block_match: json_str = code_block_match.group(1) tool_call = json.loads(json_str) else: # Try to find the first JSON object in the text json_match = re.search(r'(\{[\s\S]*\})', response_text) if json_match: tool_call = json.loads(json_match.group(1)) else: tool_call = json.loads(response_text) if isinstance(tool_call, dict) and "tool" in tool_call and "parameters" in tool_call: # Parse server and tool name server_name, tool_name = tool_call["tool"].split(".", 1) logger.info(f"Executing tool call: {tool_name} on server {server_name}") # Execute the tool call tool_response = await mcp_manager.call_tool( server_name, tool_name, tool_call["parameters"] ) return {"response": str(tool_response)} except Exception as e: logger.error(f"Tool call parsing/execution failed: {e}") # Not a tool call, return Claude's response pass return {"response": response.content[0].text} except Exception as e: logger.error(f"Error in chat endpoint: {e}") raise HTTPException(status_code=500, detail=str(e)) @app.get("/api/servers") async def list_servers(): """List all connected servers""" connected_servers = [] for server_name in mcp_manager._clients.key" (at position 3519)