fix(http_request_stream): 添加日志记录并改进错误处理

为HTTP请求流工具添加日志记录功能，使用自定义日志处理器记录错误信息。改进错误处理，在抛出异常前记录详细错误信息，便于问题排查。同时更新README中的版本号至0.0.2。

Author: mobiusy

http_request_stream/README.md

@@ -4,7 +4,7 @@
 
 ## 基本信息
 - 作者：mobiusy
-- 版本：0.0.1
+- 版本：0.0.2
 - 类型：tool
 
 ## 功能特性

http_request_stream/tools/http_request_stream.py

@@ -5,9 +5,17 @@
 from json import loads
 import re
 
+# 导入 logging 和自定义处理器
+import logging
+from dify_plugin.config.logger_format import plugin_logger_handler
+
 from dify_plugin import Tool
 from dify_plugin.entities.tool import ToolInvokeMessage
 
+# 使用自定义处理器设置日志
+logger = logging.getLogger(__name__)
+logger.setLevel(logging.INFO)
+logger.addHandler(plugin_logger_handler)
 
 class HttpRequestStreamTool(Tool):
     def _invoke(self, tool_parameters: dict[str, Any]) -> Generator[ToolInvokeMessage, None, None]:
@@ -23,10 +31,14 @@ def _invoke(self, tool_parameters: dict[str, Any]) -> Generator[ToolInvokeMessag
         body = tool_parameters.get("body", None)
         headers_str = tool_parameters.get("headers", None)
         if not url:
-            raise httpx.InvalidURL("URL cannot be empty.")
+            err_msg = "URL cannot be empty."
+            logger.error(err_msg)
+            raise httpx.InvalidURL(err_msg)
 
         if not url.startswith(("http://", "https://")):
-            raise httpx.InvalidURL("URL must start with http:// or https://.")
+            err_msg = "URL must start with http:// or https://."
+            logger.error(err_msg)
+            raise httpx.InvalidURL(err_msg)
 
         # 解析 headers 参数：支持用户以 JSON 对象字符串方式传入请求头
         user_headers: dict[str, Any] = {}
@@ -36,10 +48,14 @@ def _invoke(self, tool_parameters: dict[str, Any]) -> Generator[ToolInvokeMessag
                 if isinstance(parsed, dict):
                     user_headers = parsed
                 else:
-                    raise ValueError("headers must be a JSON object string.")
+                    err_msg = "headers must be a JSON object string."
+                    logger.error(err_msg)
+                    raise ValueError(err_msg)
             except ValueError:
                 # 用户传入的 headers 字符串不是合法 JSON 或不是对象
-                raise ValueError("headers must be a valid JSON object string.")
+                err_msg = "headers must be a valid JSON object string."
+                logger.error(err_msg)
+                raise ValueError(err_msg)
 
         # 构造 httpx.stream 的参数，增加 SSE 兼容头部与超时设置
         stream_kwargs: dict[str, Any] = {
@@ -68,7 +84,9 @@ def _invoke(self, tool_parameters: dict[str, Any]) -> Generator[ToolInvokeMessag
                 req_body = loads(body)
                 stream_kwargs["json"] = req_body
             except ValueError:
-                raise ValueError("body must be a valid JSON string.")
+                err_msg = "body must be a valid JSON string."
+                logger.error(err_msg)
+                raise ValueError(err_msg)
 
         try:
             # 标记是否已经提取并输出过 conversation_id，避免重复输出
@@ -78,7 +96,10 @@ def _invoke(self, tool_parameters: dict[str, Any]) -> Generator[ToolInvokeMessag
             with httpx.stream(**stream_kwargs) as response:
                 # 对非 2xx 状态码进行友好提示并终止流
                 if response.status_code < 200 or response.status_code >= 300:
-                    raise httpx.HTTPStatusError(f"HTTP Error: {response.status_code}", response=response)
+                    err_msg = f"HTTP Error: {response.status_code}"
+                    logger.error(err_msg)
+                    # 使用 httpx 内置的 raise_for_status 构造并抛出包含 request/response 的异常
+                    response.raise_for_status()
                 for raw_line in response.iter_lines():
                     if raw_line is None:
                         continue
@@ -103,8 +124,11 @@ def _invoke(self, tool_parameters: dict[str, Any]) -> Generator[ToolInvokeMessag
 
         except httpx.HTTPError as e:
             # 捕获 httpx 的 HTTP 异常，并输出到用户侧
+            err_msg = f"HTTP Error: {e}"
+            logger.error(err_msg)
             raise e
         except Exception as e:
             # 捕获其他意料之外的异常，避免中断
+            err_msg = f"Unexpected Error: {e}"
+            logger.error(err_msg)
             raise e
-