feat: 改进4K放大重试逻辑和日志大字段截断

- 4K放大失败时使用通用重试逻辑，支持403、reCAPTCHA、超时等多种错误类型
- 日志记录时对 encodedImage 等大字段进行截断处理，避免4K base64数据撑爆日志

Co-Authored-By: Warp <agent@warp.dev>

src/core/logger.py

@@ -57,6 +57,32 @@ class DebugLogger:
         """Write separator line"""
         self.logger.info(char * length)
 
+    def _truncate_large_fields(self, data: Any, max_length: int = 200) -> Any:
+        """对大字段进行截断处理，特别是 base64 编码的图片数据
+        
+        Args:
+            data: 要处理的数据
+            max_length: 字符串字段的最大长度
+        
+        Returns:
+            截断后的数据副本
+        """
+        if isinstance(data, dict):
+            result = {}
+            for key, value in data.items():
+                # 对特定的大字段进行截断
+                if key in ("encodedImage", "base64", "imageData", "data") and isinstance(value, str) and len(value) > max_length:
+                    result[key] = f"{value[:100]}... (truncated, total {len(value)} chars)"
+                else:
+                    result[key] = self._truncate_large_fields(value, max_length)
+            return result
+        elif isinstance(data, list):
+            return [self._truncate_large_fields(item, max_length) for item in data]
+        elif isinstance(data, str) and len(data) > 10000:
+            # 对超长字符串进行截断（可能是未知的 base64 字段）
+            return f"{data[:100]}... (truncated, total {len(data)} chars)"
+        return data
+
     def log_request(
         self,
         method: str,
@@ -166,12 +192,16 @@ class DebugLogger:
             # Body
             self.logger.info("\n📦 Response Body:")
             if isinstance(body, (dict, list)):
-                body_str = json.dumps(body, indent=2, ensure_ascii=False)
+                # 对大字段进行截断处理
+                body_to_log = self._truncate_large_fields(body)
+                body_str = json.dumps(body_to_log, indent=2, ensure_ascii=False)
                 self.logger.info(body_str)
             elif isinstance(body, str):
                 # Try to parse as JSON
                 try:
                     parsed = json.loads(body)
+                    # 对大字段进行截断处理
+                    parsed = self._truncate_large_fields(parsed)
                     body_str = json.dumps(parsed, indent=2, ensure_ascii=False)
                     self.logger.info(body_str)
                 except:

src/services/generation_handler.py

@@ -915,10 +915,11 @@ class GenerationHandler:
                         error_str = str(e)
                         debug_logger.log_error(f"[UPSAMPLE] 放大失败 (尝试 {retry_attempt + 1}/{max_retries}): {error_str}")
                         
-                        # 检查是否是403错误，需要重试
-                        if "403" in error_str and retry_attempt < max_retries - 1:
+                        # 检查是否是可重试错误（403、reCAPTCHA、超时等）
+                        retry_reason = self.flow_client._get_retry_reason(error_str)
+                        if retry_reason and retry_attempt < max_retries - 1:
                             if stream:
-                                yield self._create_stream_chunk(f"⚠️ 放大遇到403错误，正在重新获取验证码重试 ({retry_attempt + 2}/{max_retries})...\n")
+                                yield self._create_stream_chunk(f"⚠️ 放大遇到{retry_reason}，正在重试 ({retry_attempt + 2}/{max_retries})...\n")
                             # 等待一小段时间后重试
                             await asyncio.sleep(1)
                             continue