add: add plot(matplotlib) and financial technical indicators' caculator tools, and add py test script

Author: zou-y-t

config/agent_quickstart_search.yaml

@@ -24,6 +24,9 @@ main_agent:
 
   tool_config:
     - tool-searching-serper
+    - tool-financial-search
+    - tool-plot
+    - tool-technical-indicators
 
   max_turns: -1  # Maximum number of turns for main agent execution
   max_tool_calls_per_turn: 10  # Maximum number of tool calls per turn

config/tool/tool-financial-search.yaml

@@ -0,0 +1,7 @@
+name: "tool-financial-search"
+tool_command: "python"
+args:
+  - "-m"
+  - "src.tool.mcp_servers.financial_search_server"
+env:
+  FINANCIAL_API_BASE_URL: "${oc.env:FINANCIAL_API_BASE_URL,http://localhost:8060}"

config/tool/tool-plot.yaml

@@ -0,0 +1,8 @@
+name: "tool-plot"
+tool_command: "python"
+args:
+  - "-m"
+  - "src.tool.mcp_servers.plot_tool_mcp_server"
+env:
+  # optional: configure default output dir via env if you want
+  PLOT_OUTPUT_DIR: "${oc.env:PLOT_OUTPUT_DIR,./outputs/plots}"

config/tool/tool-searching-serper.yaml

@@ -1,8 +1,18 @@
+# name: "tool-searching-serper"
+# tool_command: "npx"
+# args:
+#   - "-y"
+#   - "serper-search-scrape-mcp-server"
+# env:
+# # Search API key - this value will be loaded from the .env file at runtime
+#   SERPER_API_KEY: "${oc.env:SERPER_API_KEY}"
+
+
 name: "tool-searching-serper"
-tool_command: "npx"
+tool_command: "python"
 args:
-  - "-y"
-  - "serper-search-scrape-mcp-server"
+  - "-m"
+  - "src.tool.mcp_servers.miroapi_serper_mcp_server"
 env:
-# Search API key - this value will be loaded from the .env file at runtime
   SERPER_API_KEY: "${oc.env:SERPER_API_KEY}"
+  SERPER_BASE_URL: "${oc.env:SERPER_BASE_URL,https://google.serper.dev}"

config/tool/tool-technical-indicators.yaml

@@ -0,0 +1,8 @@
+name: "tool-technical-indicators"
+tool_command: "python"
+args:
+  - "-m"
+  - "src.tool.mcp_servers.technical_indicator_mcp_server"
+env:
+  # optional defaults
+  # nothing required; manager will pass arguments at call time

output.md

@@ -13,6 +13,7 @@ dependencies = [
     "fastmcp>=2.10.6",
     "google-genai>=1.28.0",
     "markitdown-mcp>=0.0.1a3",
+    "matplotlib>=3.8.0",
     "mcp>=1.12.2",
     "mutagen>=1.47.0",
     "openai==1.78.1",

pyproject.toml

@@ -0,0 +1,85 @@
+# ...existing code...
+import os
+import json
+import requests
+from typing import Any, Dict, Optional
+from mcp.server.fastmcp import FastMCP
+
+BASE_URL = os.getenv("FINANCIAL_API_BASE_URL", "http://localhost:8060")
+
+mcp = FastMCP("financial-search-mcp-server")
+
+
+def _post(path: str, payload: Dict[str, Any], stream: bool = False) -> Dict[str, Any]:
+    url = BASE_URL.rstrip("/") + path
+    try:
+        resp = requests.post(url, json=payload, stream=stream, timeout=30)
+        resp.raise_for_status()
+        if stream:
+            # 收集流式返回的每一行 JSON（如果服务以行分块返回 JSON）
+            items = []
+            for line in resp.iter_lines(decode_unicode=True):
+                if not line:
+                    continue
+                try:
+                    items.append(json.loads(line))
+                except Exception:
+                    # 如果不是 JSON，作为文本行保存
+                    items.append({"raw": line})
+            return {"status": "success", "result": {"items": items}}
+        else:
+            body = resp.json()
+            return {"status": "success", "result": body.get("result", body)}
+    except requests.HTTPError as he:
+        try:
+            body = resp.json()
+        except Exception:
+            body = resp.text if resp is not None else str(he)
+        return {"status": "error", "result": {"error": str(he), "body": body}}
+    except Exception as e:
+        return {"status": "error", "result": {"error": str(e)}}
+
+
+@mcp.tool()
+def get_stock_history(ticker: str, start_date: str, end_date: str) -> Dict[str, Any]:
+    """调用 /get_stock_history"""
+    payload = {"ticker": ticker, "start_date": start_date, "end_date": end_date}
+    return _post("/get_stock_history", payload, stream=False)
+
+
+@mcp.tool()
+def get_company_news(ticker: str, start_date: str, end_date: str, crawl_content: bool = True) -> Dict[str, Any]:
+    """调用 /get_company_news，服务如支持流式会按行聚合并返回 items 列表"""
+    payload = {
+        "ticker": ticker,
+        "start_date": start_date,
+        "end_date": end_date,
+        "crawl_content": crawl_content,
+    }
+    return _post("/get_company_news", payload, stream=True)
+
+
+@mcp.tool()
+def get_general_news(start_date: str, end_date: str, crawl_content: bool = True, max_items: int = 100) -> Dict[str, Any]:
+    payload = {
+        "start_date": start_date,
+        "end_date": end_date,
+        "crawl_content": crawl_content,
+        "max_items": max_items,
+    }
+    return _post("/get_general_news", payload, stream=True)
+
+
+@mcp.tool()
+def get_financials_reported(ticker: str, start_date: str, end_date: str, freq: str = "annual") -> Dict[str, Any]:
+    payload = {"ticker": ticker, "start_date": start_date, "end_date": end_date, "freq": freq}
+    return _post("/get_financials_reported", payload, stream=False)
+
+
+if __name__ == "__main__":
+    # 以 FastMCP 的方式启动（根据你项目的 FastMCP 用法调整）
+    try:
+        mcp.run()
+    except Exception:
+        # 若 run 名称不同，改为 mcp.serve() 或按项目其他 MCP 启动方式
+        pass