Merge pull request #143 from heshengtao/dev

Dev

Author: heshengtao

config/settings_template.json

@@ -11,6 +11,7 @@
     "max_rounds": 0,
     "selectedProvider": null,
     "top_p": 1,
+    "reasoning_effort": null,
     "extra_params":[],
     "systemSettings": {
       "language": "zh-CN",
@@ -69,7 +70,8 @@
       "base_url": "",
       "api_key": "",
       "selectedProvider": null,
-      "temperature": 0.7
+      "temperature": 0.7,
+      "reasoning_effort": null
     },
     "vision": {
       "enabled": false,
@@ -130,6 +132,15 @@
       "e2b_api_key": "",
       "sandbox_url":"http://127.0.0.1:8080"
     },
+    "HASettings": {
+      "enabled": false,
+      "api_key": "",
+      "url": "http://127.0.0.1:8123"
+    },
+    "chromeMCPSettings": {
+      "enabled": false,
+      "url": "http://127.0.0.1:12306/mcp"
+    },
     "custom_http":[],
     "qqBotConfig": {
       "QQAgent":"super-model",
@@ -186,7 +197,14 @@
       "gsvPromptLang": "zh",
       "gsvPromptText": "",
       "gsvRefAudioPath": "",
-      "gsvAudioOptions": []
+      "gsvAudioOptions": [],
+      "selectedProvider": null,
+      "vendor": "OpenAI",
+      "model": "",
+      "base_url": "",
+      "api_key": "",
+      "openaiVoice":"alloy",
+      "openaiSpeed": 1.0
     },
     "liveConfig": {
       "onlyDanmaku": true,

package.json

@@ -122,6 +122,7 @@
     "nsis": {
       "oneClick": false,
       "allowElevation": true,
+      "allowToChangeInstallationDirectory": true,
       "artifactName": "${productName}-Setup-${version}.${ext}",
       "uninstallDisplayName": "${productName}",
       "createDesktopShortcut": true

py/mcp_clients.py

@@ -39,12 +39,18 @@ async def connect(self, config: dict) -> AsyncIterator["ConnectionManager"]:
                 read, write = await stack.enter_async_context(stdio_client(server_params))
             else:
                 mcptype = config.get("type", "ws")
+                if "streamable" in mcptype:
+                    mcptype = "streamablehttp"
                 client_map = {
                     "ws": websocket_client,
                     "sse": sse_client,
                     "streamablehttp": streamablehttp_client,
                 }
-                client = client_map[mcptype](config["url"])
+                headers = config.get("headers", {})
+                if headers:
+                    client = client_map[mcptype](config["url"], headers=headers)
+                else:
+                    client = client_map[mcptype](config["url"])
                 transport = await stack.enter_async_context(client)
                 if mcptype == "streamablehttp":
                     read, write, _ = transport
@@ -69,6 +75,7 @@ def __init__(self) -> None:
         self._monitor_task: Optional[asyncio.Task] = None
         self._shutdown = False
         self._on_failure_callback: Optional[callable] = None  # 新增：失败回调
+        self._tools: list[str] = []
 
     async def initialize(self, server_name: str, server_config: dict, on_failure_callback: Optional[callable] = None) -> None:
         """非阻塞初始化：拉起连接监控协程"""
@@ -116,6 +123,7 @@ async def get_openai_functions(self):
             if not self._conn or not self._conn.session:
                 return []
             tools = (await self._conn.session.list_tools()).tools
+            self._tools = [t.name for t in tools]
             return [
                 {
                     "type": "function",