feat: add raw stream upload functionality

domain/virtual_fs/api.py

@@ -172,6 +172,19 @@ async def upload_stream(
     return success(result)
 
 
+@router.put("/upload-raw/{full_path:path}")
+@audit(action=AuditAction.UPLOAD, description="原始流上传文件")
+@require_path_permission(PathAction.WRITE, "full_path")
+async def upload_raw_stream(
+    request: Request,
+    current_user: Annotated[User, Depends(get_current_active_user)],
+    full_path: str,
+    overwrite: bool = Query(True, description="是否覆盖已存在文件"),
+):
+    result = await VirtualFSService.upload_raw_stream(full_path, request, overwrite)
+    return success(result)
+
+
 @router.get("/{full_path:path}")
 @audit(action=AuditAction.READ, description="浏览目录")
 @require_path_permission(PathAction.READ, "full_path")

domain/virtual_fs/routes.py

@@ -2,7 +2,7 @@ import mimetypes
 import re
 from urllib.parse import quote
 
-from fastapi import HTTPException, UploadFile
+from fastapi import HTTPException, Request, UploadFile
 from fastapi.responses import Response
 
 from domain.config import ConfigService
@@ -271,6 +271,24 @@ class VirtualFSRouteMixin(VirtualFSTempLinkMixin):
             size = int(result or 0)
         return {"uploaded": True, "path": path, "size": size, "overwrite": overwrite}
 
+    @classmethod
+    async def upload_raw_stream(cls, full_path: str, request: Request, overwrite: bool):
+        full_path = cls._normalize_path(full_path)
+        if full_path.endswith("/"):
+            raise HTTPException(400, detail="Path must be a file")
+
+        result = await cls.write_file_stream(full_path, request.stream(), overwrite=overwrite)
+        path = full_path
+        size = 0
+        if isinstance(result, dict):
+            path = result.get("path") or path
+            size_val = result.get("size")
+            if isinstance(size_val, int):
+                size = size_val
+        else:
+            size = int(result or 0)
+        return {"uploaded": True, "path": path, "size": size, "overwrite": overwrite}
+
     @classmethod
     async def list_directory(cls, full_path: str, page_num: int, page_size: int, sort_by: str, sort_order: str):
         full_path = cls._normalize_path(full_path)