Feat: support SSE params (v0.0.6)

Author: meme-dayo

README.md

@@ -37,6 +37,7 @@ Each `MCP client` (ReAct Agent) node can connect `MCP servers`.
   - dify_plugin(0.0.1b72→v0.1.0)
 - Add UI-TARS SDK integration for GUI automation capabilities (v0.0.5)
 - Support Streamable HTTP MCP client
+- Feat SSE param: `/sse?key=value` (v0.0.6)
 
 ## 🤖 UI-TARS Integration
 

manifest.yaml

@@ -1,4 +1,4 @@
-version: 0.0.5
+version: 0.0.6
 type: plugin
 author: 3dify-project
 name: mcp_client
@@ -37,7 +37,7 @@ plugins:
   agent_strategies:
     - provider/agent.yaml
 meta:
-  version: 0.0.5
+  version: 0.0.6
   arch:
     - amd64
     - arm64

strategies/mcpReAct-UI-TARS.py

@@ -188,7 +188,7 @@ def _invoke(self, parameters: dict[str, Any]) -> Generator[AgentInvokeMessage]:
 
             elif mcp_server_cmd_or_url.get("url"): # SSE or Streamable HTTP
                 url = mcp_server_cmd_or_url["url"]
-                if url.endswith("/sse"): # SSE
+                if url.endswith("/sse") or ("/sse?" in url): # SSE
                     mcp_tool_list, mcp_resource_list, mcp_prompt_list, self.mcp_sessions[mcp_server_name] = self._run_async(self._setup_sse_mcp(mcp_server_cmd_or_url))
                 elif url.endswith("/mcp"): # Stremable HTTP
                     mcp_tool_list, mcp_resource_list, mcp_prompt_list, self.mcp_sessions[mcp_server_name] = self._run_async(self._setup_streamable_http_mcp(mcp_server_cmd_or_url))

strategies/mcpReAct.py

@@ -177,7 +177,7 @@ def _invoke(self, parameters: dict[str, Any]) -> Generator[AgentInvokeMessage]:
 
             elif mcp_server_cmd_or_url.get("url"): # SSE or Streamable HTTP
                 url = mcp_server_cmd_or_url["url"]
-                if url.endswith("/sse"): # SSE
+                if url.endswith("/sse") or ("/sse?" in url): # SSE
                     mcp_tool_list, mcp_resource_list, mcp_prompt_list, self.mcp_sessions[mcp_server_name] = self._run_async(self._setup_sse_mcp(mcp_server_cmd_or_url))
                 elif url.endswith("/mcp"): # Stremable HTTP
                     mcp_tool_list, mcp_resource_list, mcp_prompt_list, self.mcp_sessions[mcp_server_name] = self._run_async(self._setup_streamable_http_mcp(mcp_server_cmd_or_url))