feat: add stock market analysis agent and corresponding server

- Implemented `mock_stock_server.py` to handle stock-related computations
- Added a stock analysis agent in `mock_multi_agent.py` to process financial queries
- Updated `.replit` configuration to support new server integration

.replit

@@ -63,6 +63,14 @@ name = "Run Mock MCP System"
 author = 13983571
 mode = "sequential"
 
+[[workflows.workflow.tasks]]
+task = "shell.exec"
+args = "python examples/mcp_example/mock_stock_server.py &"
+
+[[workflows.workflow.tasks]]
+task = "shell.exec"
+args = "sleep 2"
+
 [[workflows.workflow.tasks]]
 task = "shell.exec"
 args = "python examples/mcp_example/mock_math_server.py &"

examples/mcp_example/mock_multi_agent.py

@@ -41,12 +41,22 @@ class MathAgent:
 
 class MultiAgentMathSystem:
     def __init__(self):
-        base_url = "http://0.0.0.0:8000"
+        math_url = "http://0.0.0.0:8000"
-        self.calculator = MathAgent("Calculator", base_url)
+        stock_url = "http://0.0.0.0:8001"
+        self.calculator = MathAgent("Calculator", math_url)
+        self.stock_analyst = MathAgent(
+            "StockAnalyst", 
+            stock_url,
+            "Stock market analysis agent specializing in financial calculations and market analysis"
+        )
 
     async def process_task(self, task: str):
-        result = await self.calculator.process(task)
+        # Process with both agents
-        return [result]  # Keep list format for compatibility
+        results = await asyncio.gather(
+            self.calculator.process(task),
+            self.stock_analyst.process(task)
+        )
+        return results
 
     def run_interactive(self):
         print("\nMulti-Agent Math System")

examples/mcp_example/mock_stock_server.py

@@ -0,0 +1,30 @@
+
+from fastmcp import FastMCP
+import time
+
+# Initialize MCP server
+mcp = FastMCP("Stock-Mock-Server")
+
+@mcp.tool()
+def calculate_simple_moving_average(prices: list[float], period: int) -> float:
+    """Calculate Simple Moving Average"""
+    try:
+        time.sleep(0.1)  # Simulate processing time
+        if len(prices) < period:
+            return {"error": "Not enough data points"}
+        return sum(prices[-period:]) / period
+    except Exception as e:
+        return {"error": f"Error calculating SMA: {str(e)}"}
+
+@mcp.tool()
+def calculate_percentage_change(old_value: float, new_value: float) -> float:
+    """Calculate percentage change between two values"""
+    try:
+        time.sleep(0.1)  # Simulate processing time
+        return ((new_value - old_value) / old_value) * 100
+    except Exception as e:
+        return {"error": f"Error calculating percentage change: {str(e)}"}
+
+if __name__ == "__main__":
+    print("Starting Mock Stock Server on port 8001...")
+    mcp.run(transport="sse", host="0.0.0.0", port=8001)