fix: 上传素材后视频库立即显示（创建 PROCESSING 状态 Asset） (#1644)

Co-authored-by: xiaoxia <dev@xiaoxiajianji.com>
Co-committed-by: xiaoxia <dev@xiaoxiajianji.com>

apps/api/app/api/routes/upload.py

@@ -23,6 +23,7 @@ from app.schemas.upload import (
 from fastapi import APIRouter, Depends, File, Form, HTTPException, UploadFile, status
 
 from packages.application import SubmitIngestJobCommand, SubmitIngestJobUseCase
+from packages.domain import Asset, AssetStatus
 
 logger = logging.getLogger(__name__)
 
@@ -80,6 +81,40 @@ def _validate_mime_type(content_type: str | None) -> str:
     return base_type
 
 
+def _infer_mime_type_from_storage_key(storage_key: str) -> str:
+    """从 storage_key 推断 MIME 类型（与 worker 端保持一致）。"""
+    lower_filename = storage_key.rsplit("/", 1)[-1].lower()
+    _MIME_MAP = {
+        ".mov": "video/quicktime", ".mp4": "video/mp4", ".avi": "video/x-msvideo",
+        ".mkv": "video/x-matroska", ".webm": "video/webm",
+        ".png": "image/png", ".gif": "image/gif", ".bmp": "image/bmp",
+        ".svg": "image/svg+xml", ".jpg": "image/jpeg", ".jpeg": "image/jpeg",
+        ".mp3": "audio/mpeg", ".wav": "audio/wav", ".ogg": "audio/ogg",
+        ".flac": "audio/flac", ".m4a": "audio/x-m4a",
+    }
+    for ext, mime in _MIME_MAP.items():
+        if lower_filename.endswith(ext):
+            return mime
+    return "video/mp4"  # default
+
+
+def _create_pending_asset(
+    asset_repository, project_id, library_id, storage_key, filename, mime_type, user_id, file_hash=""
+):
+    """立即创建一条 PROCESSING 状态的 Asset 记录，使前端能马上看到新素材。"""
+    asset = Asset.create(
+        project_id=project_id,
+        library_id=library_id,
+        name=filename,
+        storage_key=storage_key,
+        mime_type=mime_type,
+        status=AssetStatus.PROCESSING,
+        uploaded_by_user_id=user_id,
+        file_hash=file_hash,
+    )
+    return asset_repository.create(asset)
+
+
 def _submit_ingest_job(
     project_id: str,
     library_id: str,
@@ -209,6 +244,20 @@ async def complete_direct_upload(
                 url=storage_service.get_url(normalized_key),
             )
 
+    # 立即创建 Asset 记录（PROCESSING 状态），使前端刷新后即可看到新素材
+    filename = normalized_key.rsplit("/", 1)[-1]
+    mime_type = _infer_mime_type_from_storage_key(normalized_key)
+    pending_asset = _create_pending_asset(
+        asset_repository=asset_repository,
+        project_id=request.project_id,
+        library_id=request.library_id,
+        storage_key=normalized_key,
+        filename=filename,
+        mime_type=mime_type,
+        user_id=authenticated_user.user.id,
+        file_hash=request.file_hash,
+    )
+
     job = _submit_ingest_job(
         project_id=request.project_id,
         library_id=request.library_id,
@@ -216,7 +265,12 @@ async def complete_direct_upload(
         ingest_job_repository=ingest_job_repository,
         file_hash=request.file_hash,
     )
-    return DirectUploadCompleteResponse(storage_key=normalized_key, ingest_job_id=job.id, url=storage_service.get_url(normalized_key))
+    return DirectUploadCompleteResponse(
+        storage_key=normalized_key,
+        ingest_job_id=job.id,
+        asset_id=pending_asset.id,
+        url=storage_service.get_url(normalized_key),
+    )
 
 
 @router.post(
@@ -284,6 +338,18 @@ async def upload_asset(
             detail=f"Failed to upload file: {type(error).__name__}",
         ) from error
 
+    # 立即创建 Asset 记录（PROCESSING 状态），使前端刷新后即可看到新素材
+    pending_asset = _create_pending_asset(
+        asset_repository=asset_repository,
+        project_id=project_id,
+        library_id=library_id,
+        storage_key=storage_key,
+        filename=safe_filename,
+        mime_type=validated_content_type,
+        user_id=authenticated_user.user.id,
+        file_hash=file_hash,
+    )
+
     job = _submit_ingest_job(
         project_id=project_id,
         library_id=library_id,
@@ -295,5 +361,6 @@ async def upload_asset(
     return UploadAssetResponse(
         storage_key=storage_key,
         ingest_job_id=job.id,
+        asset_id=pending_asset.id,
         url=file_url,
     )