feat(image): 新增Codex链路生图支持2k/4k分辨率

- 新增Codex链路生图功能，支持2k和4k分辨率
- 支持RT刷新账号信息
- 简化了Codex图像响应处理逻辑，移除流式处理相关代码
- 直接获取图像结果并返回，提高图像生成效率
- 移除原有的事件类型统计和上游错误处理代码
- 更新版本号至1.2.2并更新变更日志

CHANGELOG.md

@@ -2,6 +2,11 @@
 
 ## Unreleased
 
+## 1.2.2 - 2026-05-29
+
++ [新增] 新增Codex链路生图、支持2k,4k。
++ [新增] 支持RT刷新账号信息。
+
 ## 1.2.0 - 2026-05-28
 
 + [新增] 当前版本基线，包含 Web 面板、画图、号池管理、注册机、图片管理、日志管理和设置能力。

VERSION

@@ -1 +1 @@
-1.2.1
+1.2.2

services/protocol/conversation.py

@@ -651,113 +651,30 @@ def _codex_response_images(value: Any) -> list[str]:
     return []
 
 
-def _codex_response_error(value: Any) -> tuple[str, str]:
-    if not isinstance(value, dict):
-        return "", ""
-    error = value.get("error")
-    if not isinstance(error, dict):
-        response = value.get("response")
-        error = response.get("error") if isinstance(response, dict) and response.get("status") == "failed" else None
-    if not isinstance(error, dict):
-        return "", ""
-    message = str(error.get("message") or "").strip()
-    code = str(error.get("code") or error.get("type") or "server_error").strip()
-    return message or "Codex responses failed upstream.", code
-
-
 def stream_codex_image_outputs(
         backend: OpenAIBackendAPI,
         request: ConversationRequest,
         index: int = 1,
         total: int = 1,
 ) -> Iterator[ImageOutput]:
-    text_parts: list[str] = []
-    event_count = 0
-    event_types: dict[str, int] = {}
-    for event in backend.iter_codex_image_response_events(
-            prompt=request.prompt,
-            images=request.images or [],
-            size=request.size,
-            quality=request.quality,
-    ):
-        event_type = str(event.get("type") or "")
-        event_count += 1
-        event_types[event_type or "<missing>"] = event_types.get(event_type or "<missing>", 0) + 1
-        upstream_error, upstream_code = _codex_response_error(event)
-        if upstream_error:
-            logger.warning({
-                "event": "codex_response_upstream_error",
-                "model": request.model,
-                "size": request.size,
-                "quality": request.quality,
-                "event_count": event_count,
-                "event_types": event_types,
-                "upstream_code": upstream_code,
-                "upstream_error": upstream_error,
-            })
-            raise ImageGenerationError(
-                upstream_error,
-                status_code=502,
-                error_type="server_error",
-                code=upstream_code or "server_error",
-            )
-        if event_type == "response.output_text.delta":
-            delta = str(event.get("delta") or "")
-            if delta:
-                text_parts.append(delta)
-                yield ImageOutput(
-                    kind="progress",
-                    model=request.model,
-                    index=index,
-                    total=total,
-                    text=delta,
-                    upstream_event_type=event_type,
-                )
-            continue
-        images = _codex_response_images(event)
-        if images:
-            logger.info({
-                "event": "codex_response_image_result_found",
-                "model": request.model,
-                "size": request.size,
-                "quality": request.quality,
-                "event_count": event_count,
-                "event_types": event_types,
-                "image_count": len(images),
-                "image_result_lengths": [len(item) for item in images[:10]],
-            })
-            data = format_image_result(
-                [{"b64_json": item, "revised_prompt": request.prompt} for item in images],
-                request.prompt,
-                request.response_format,
-                request.base_url,
-                int(time.time()),
-            )["data"]
-            if data:
-                yield ImageOutput(kind="result", model=request.model, index=index, total=total, data=data)
-                return
-        if event_type:
-            yield ImageOutput(
-                kind="progress",
-                model=request.model,
-                index=index,
-                total=total,
-                upstream_event_type=event_type,
-            )
-    message = "".join(text_parts).strip()
-    if message:
-        yield ImageOutput(kind="message", model=request.model, index=index, total=total, text=message)
+    images = _codex_response_images(list(backend.iter_codex_image_response_events(
+        prompt=request.prompt,
+        images=request.images or [],
+        size=request.size,
+        quality=request.quality,
+    )))
+    if not images:
+        raise ImageGenerationError("No image result found in response")
+    data = format_image_result(
+        [{"b64_json": item, "revised_prompt": request.prompt} for item in images],
+        request.prompt,
+        request.response_format,
+        request.base_url,
+        int(time.time()),
+    )["data"]
+    if data:
+        yield ImageOutput(kind="result", model=request.model, index=index, total=total, data=data)
         return
-    logger.warning({
-        "event": "codex_response_no_image_result",
-        "model": request.model,
-        "size": request.size,
-        "quality": request.quality,
-        "image_input_count": len(request.images or []),
-        "event_count": event_count,
-        "event_types": event_types,
-        "output_text_len": len("".join(text_parts)),
-    })
     raise ImageGenerationError("No image result found in response")