From 4888a0eb01f98915eb435593c56aa2e816f2bd67 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E5=BE=B7=E5=AE=87?= Date: Sat, 19 Sep 2026 13:16:25 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E5=93=8D=E5=BA=94=E8=A7=A3?= =?UTF-8?q?=E6=9E=90=E9=94=99=E8=AF=AF=E7=9A=84=20provider=20=E5=BD=92?= =?UTF-8?q?=E5=B1=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit parse_json_payload 增加 ImageProvider 参数，ResponseParse 使用实际 provider 共享的 handle_image_response 解析失败时不再把 Tiantoken 响应记成 vector-engine --- .../platform-image/src/image_provider/protocol/payload.rs | 5 +++-- .../platform-image/src/image_provider/protocol/response.rs | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/server-rs/crates/platform-image/src/image_provider/protocol/payload.rs b/server-rs/crates/platform-image/src/image_provider/protocol/payload.rs index 1dc8388ac..b6e420819 100644 --- a/server-rs/crates/platform-image/src/image_provider/protocol/payload.rs +++ b/server-rs/crates/platform-image/src/image_provider/protocol/payload.rs @@ -1,19 +1,20 @@ use serde_json::Value; use crate::image_provider::{ - constants::VECTOR_ENGINE_PROVIDER, error::PlatformImageError, + types::ImageProvider, util::{ParsedJsonPayload, truncate_raw}, }; pub(super) fn parse_json_payload( raw_text: &str, failure_context: &str, + provider: ImageProvider, ) -> Result { serde_json::from_str::(raw_text) .map(|payload| ParsedJsonPayload { payload }) .map_err(|error| PlatformImageError::ResponseParse { - provider: VECTOR_ENGINE_PROVIDER, + provider: provider.as_str(), message: format!("{failure_context}：解析响应失败：{error}"), raw_excerpt: truncate_raw(raw_text), audit: None, diff --git a/server-rs/crates/platform-image/src/image_provider/protocol/response.rs b/server-rs/crates/platform-image/src/image_provider/protocol/response.rs index 67c88e3c6..fa7ad079c 100644 --- a/server-rs/crates/platform-image/src/image_provider/protocol/response.rs +++ b/server-rs/crates/platform-image/src/image_provider/protocol/response.rs @@ -66,7 +66,7 @@ pub(crate) async fn handle_image_response( }); } - let response_json = match parse_json_payload(response_text, failure_context) { + let response_json = match parse_json_payload(response_text, failure_context, provider) { Ok(response_json) => response_json, Err(error) => { let audit = build_failure_audit(