test: enhance MCP integration test with tool discovery and user guidance

.replit

@@ -41,3 +41,20 @@ mode = "sequential"
 [[workflows.workflow.tasks]]
 task = "shell.exec"
 args = "python examples/mcp_example/test_integration.py"
+
+[[workflows.workflow]]
+name = "Run MCP Test"
+author = 13983571
+mode = "sequential"
+
+[[workflows.workflow.tasks]]
+task = "shell.exec"
+args = "python examples/mcp_example/math_server.py & "
+
+[[workflows.workflow.tasks]]
+task = "shell.exec"
+args = "sleep 2"
+
+[[workflows.workflow.tasks]]
+task = "shell.exec"
+args = "python examples/mcp_example/test_integration.py"

examples/mcp_example/test_integration.py

@@ -1,43 +1,47 @@
+
 from swarms import Agent
 from swarms.prompts.finance_agent_sys_prompt import FINANCIAL_AGENT_SYS_PROMPT
 from swarms.tools.mcp_integration import MCPServerSseParams
 import logging
 
-# Configure MCP server connection
+def main():
-server = MCPServerSseParams(
+    # Configure MCP server connection
-    url="http://0.0.0.0:6274",
+    server = MCPServerSseParams(
-    headers={"Content-Type": "application/json"},
+        url="http://0.0.0.0:6274",
-    timeout=10.0,
+        headers={"Content-Type": "application/json"},
-    sse_read_timeout=300.0
+        timeout=10.0,
-)
+        sse_read_timeout=300.0
-
+    )
-# Initialize agent with MCP capabilities
+
-agent = Agent(
+    # Initialize agent with MCP capabilities
-    agent_name="Math-Agent",
+    agent = Agent(
-    agent_description="Agent that performs math operations",
+        agent_name="Math-Agent",
-    system_prompt=FINANCIAL_AGENT_SYS_PROMPT,
+        agent_description="Agent that performs math operations",
-    max_loops=1,
+        system_prompt=FINANCIAL_AGENT_SYS_PROMPT,
-    mcp_servers=[server],
+        max_loops=1,
-    streaming_on=True
+        mcp_servers=[server],
-)
+        streaming_on=True
-
+    )
-def test_mcp_operations():
+
-    """Test basic MCP operations with error handling"""
     try:
-        # Test addition
+        # First get available tools from server
-        print("\nTesting addition...")
+        print("\nDiscovering available tools from MCP server...")
-        add_result = agent.run("Use the add tool to add 5 and 3")
+        tools = agent.mcp_tool_handling()
-        print("Addition result:", add_result)
+        print("\nAvailable tools:", tools)
+        
+        while True:
+            # Get user input
+            user_input = input("\nEnter a math operation (or 'exit' to quit): ")
             
-        # Test multiplication
+            if user_input.lower() == 'exit':
-        print("\nTesting multiplication...")
+                break
-        mult_result = agent.run("Use the multiply tool to multiply 4 and 6") 
-        print("Multiplication result:", mult_result)
                 
-        # Test error case
+            # Process user input through agent
-        print("\nTesting error handling...")
+            try:
-        error_result = agent.run("Use the add tool with invalid inputs")
+                result = agent.run(user_input)
-        print("Error handling result:", error_result)
+                print("\nResult:", result)
+            except Exception as e:
+                print(f"Error processing request: {e}")
 
     except Exception as e:
         logging.error(f"Test failed: {e}")
@@ -45,4 +49,4 @@ def test_mcp_operations():
 
 if __name__ == "__main__":
     logging.basicConfig(level=logging.INFO)
-    test_mcp_operations()
+    main()