feat(请求头): 新增可选 headers 参数支持自定义请求头

实现工具代码读取 JSON 字符串格式的 headers 参数，并与默认 SSE 请求头合并，支持用户自定义请求头覆盖默认值

Author: mobiusy

http_request_stream/tools/http_request_stream.py

@@ -20,26 +20,47 @@ def _invoke(self, tool_parameters: dict[str, Any]) -> Generator[ToolInvokeMessag
         url = tool_parameters.get("url")
         method = tool_parameters.get("method", "GET")
         body = tool_parameters.get("body", None)
+        headers_str = tool_parameters.get("headers", None)
         if not url:
             raise httpx.InvalidURL("URL cannot be empty.")
 
         if not url.startswith(("http://", "https://")):
             raise httpx.InvalidURL("URL must start with http:// or https://.")
 
+        # 解析 headers 参数：支持用户以 JSON 对象字符串方式传入请求头
+        user_headers: dict[str, Any] = {}
+        if headers_str:
+            try:
+                parsed = loads(headers_str)
+                if isinstance(parsed, dict):
+                    user_headers = parsed
+                else:
+                    raise ValueError("headers must be a JSON object string.")
+            except ValueError:
+                # 用户传入的 headers 字符串不是合法 JSON 或不是对象
+                raise ValueError("headers must be a valid JSON object string.")
+
         # 构造 httpx.stream 的参数，增加 SSE 兼容头部与超时设置
         stream_kwargs: dict[str, Any] = {
             "method": method,
             "url": url,
-            # SSE 推荐的请求头，提升与代理/网关的兼容性
-            "headers": {
-                "Accept": "text/event-stream",
-                "Cache-Control": "no-cache",
-                "Connection": "keep-alive",
-            },
             # 读取不设整体超时，连接阶段限制为 5 秒，避免读超时中断流
             "timeout": httpx.Timeout(timeout=None, connect=5.0),
         }
 
+        # 默认 SSE 兼容请求头，提升与代理/网关的兼容性
+        default_headers: dict[str, str] = {
+            "Accept": "text/event-stream",
+            "Cache-Control": "no-cache",
+            "Connection": "keep-alive",
+        }
+        # 合并用户请求头，用户值覆盖默认值，确保所有值为字符串类型
+        merged_headers: dict[str, str] = {
+            **default_headers,
+            **{str(k): str(v) for k, v in user_headers.items()}
+        }
+        stream_kwargs["headers"] = merged_headers
+
         if body:
             # 检查body是否是合法的json格式
             try:

http_request_stream/tools/http_request_stream.yaml

@@ -75,6 +75,17 @@ parameters:
       pt_BR: request body
     llm_description: 请求主体
     form: llm
+  - name: headers
+    type: string
+    required: false
+    label:
+      en_US: Headers
+      zh_Hans: 请求头
+    human_description:
+      en_US: "Optional request headers in JSON object string, e.g. {\"Authorization\": \"Bearer xxx\", \"X-Custom\": \"value\"}."
+      zh_Hans: "可选的请求头，使用 JSON 对象字符串，例如 {\"Authorization\": \"Bearer xxx\", \"X-Custom\": \"value\"}。"
+    llm_description: "Optional request headers as a JSON object string; when provided, they will be merged with default SSE headers."
+    form: llm
 
 extra:
   python:

http_request_stream/working/progress.md

@@ -9,9 +9,11 @@
 
 ## 已完成工作
 - [2025-11-07 16:53:37 +08:00] 完成 README 文档的全面撰写与结构化说明
+- [2025-11-07 17:51:36 +08:00] 新增可选 headers 参数（JSON 对象字符串），实现工具代码读取并与默认 SSE 请求头合并，支持自定义请求头覆盖默认值
 
 ## 待办事项
-- [ ] 支持自定义请求头与认证信息（如 Bearer Token）
+- [x] 支持自定义请求头（headers 参数，JSON 字符串）
+- [ ] 提供认证信息示例（如 Bearer Token）
 - [ ] 增加更多使用示例（不同服务的 SSE 与分块响应）
 - [ ] 完善错误信息的指引与用户友好提示
 - [ ] 在 GUIDE.md 中补充工作流配置的图示与步骤