feat(api): 添加根据请求头解析图片基础URL功能

- 在 `upload` 和 `list` 函数中，增加了对 `HeaderMap` 的接收，并调用 `resolve_image_base_url` 函数来解析图片的基础URL。
- 添加了 `resolve_image_base_url` 函数，该函数根据请求头中的 `HOST` 字段解析图片的基础URL，若请求头中没有 `HOST` 字段，则使用配置中的 `cdn_base_url`。
- 修改了 `ImageService::upload` 和 `ImageService::list` 函数的调用，增加了 `base_url` 参数，以便在生成 `ImageInfo` 时使用解析后的基础URL。

Author: ExquisiteCore

crates/api/src/images.rs

@@ -34,8 +34,11 @@ pub fn public_routes() -> Router<AppState> {
 async fn upload(
     State(state): State<AppState>,
     auth: AuthUser,
+    headers: HeaderMap,
     mut multipart: Multipart,
 ) -> Result<ApiResponse<ImageInfo>, AppError> {
+    let base_url = resolve_image_base_url(&headers, &state.config.image.cdn_base_url);
+
     let mut file_name = None;
     let mut content_type = None;
     let mut data = None;
@@ -71,6 +74,7 @@ async fn upload(
         &content_type,
         data,
         &state.config.image,
+        &base_url,
     )
     .await?;
 
@@ -86,12 +90,14 @@ struct ListQuery {
 async fn list(
     State(state): State<AppState>,
     auth: AuthUser,
+    headers: HeaderMap,
     Query(query): Query<ListQuery>,
 ) -> Result<ApiResponse<Vec<ImageInfo>>, AppError> {
+    let base_url = resolve_image_base_url(&headers, &state.config.image.cdn_base_url);
     let page = query.page.unwrap_or(1);
     let per_page = query.per_page.unwrap_or(20);
     let (items, total) =
-        ImageService::list(&state.db, auth.user_id, &state.config.image.cdn_base_url, page, per_page)
+        ImageService::list(&state.db, auth.user_id, &base_url, page, per_page)
             .await?;
     Ok(ApiResponse::paginated(items, page, per_page, total))
 }
@@ -161,6 +167,22 @@ async fn serve_thumb(
     Ok((StatusCode::OK, headers, data))
 }
 
+fn resolve_image_base_url(headers: &HeaderMap, cdn_base_url: &str) -> String {
+    if !cdn_base_url.is_empty() {
+        return cdn_base_url.to_string();
+    }
+    if let Some(host) = headers.get(header::HOST).and_then(|v| v.to_str().ok()) {
+        let scheme = if host.starts_with("localhost") || host.starts_with("127.0.0.1") {
+            "http"
+        } else {
+            "https"
+        };
+        format!("{scheme}://{host}/img")
+    } else {
+        String::new()
+    }
+}
+
 fn check_referer(headers: &HeaderMap, allowed: &[String]) -> Result<(), AppError> {
     if allowed.is_empty() {
         return Ok(());

crates/core/src/image.rs

@@ -73,6 +73,7 @@ impl ImageService {
         content_type: &str,
         data: Vec<u8>,
         config: &ImageConfig,
+        base_url: &str,
     ) -> Result<ImageInfo, AppError> {
         // 1. Validate format
         if !ALLOWED_TYPES.contains(&content_type) {
@@ -100,7 +101,7 @@ impl ImageService {
             .await?;
 
         if let Some(existing) = existing {
-            return Ok(ImageInfo::from_model(existing, &config.cdn_base_url));
+            return Ok(ImageInfo::from_model(existing, base_url));
         }
 
         // 5. Decode image
@@ -169,7 +170,7 @@ impl ImageService {
         };
 
         let model = record.insert(db).await?;
-        Ok(ImageInfo::from_model(model, &config.cdn_base_url))
+        Ok(ImageInfo::from_model(model, base_url))
     }
 
     pub async fn list(