Function presign_upload_init

apps/base/views.py:666–716

初始化预签名上传，S3返回直传URL，其他存储返回代理URL

(
    data: PresignUploadInitRequest, ip: str = Depends(ip_limit["upload"])
)

@presign_api.post("/upload/init", dependencies=[Depends(share_required_login)])
async def presign_upload_init(
    data: PresignUploadInitRequest, ip: str = Depends(ip_limit["upload"])
):
    """初始化预签名上传，S3返回直传URL，其他存储返回代理URL"""
    validate_file_type(data.file_name)
    if data.file_size > settings.uploadSize:
        raise HTTPException(
            403,
            f"文件大小超过限制，最大为 {settings.uploadSize / (1024 * 1024):.2f} MB",
        )
    if data.expire_style not in settings.expireStyle:
        raise HTTPException(400, "过期时间类型错误")

    upload_id = uuid.uuid4().hex
    path, _, _, filename, save_path = await FileUploadService.generate_file_path(
        data.file_name, upload_id
    )

    storage: FileStorageInterface = storages[settings.file_storage]()
    presigned_url = await storage.generate_presigned_upload_url(
        save_path, PRESIGN_SESSION_EXPIRES
    )

    mode = "direct" if presigned_url else "proxy"
    proxy_urls = build_proxy_upload_urls(upload_id)
    upload_url = presigned_url or proxy_urls["proxy_upload_url"]

    await PresignUploadSession.create(
        upload_id=upload_id,
        file_name=filename,
        file_size=data.file_size,
        save_path=save_path,
        mode=mode,
        expire_value=data.expire_value,
        expire_style=data.expire_style,
        expires_at=await get_now() + timedelta(seconds=PRESIGN_SESSION_EXPIRES),
    )

    ip_limit["upload"].add_ip(ip)
    detail = {
        "upload_id": upload_id,
        "upload_url": upload_url,
        "mode": mode,
        "expires_in": PRESIGN_SESSION_EXPIRES,
    }
    if mode == "proxy":
        detail.update(proxy_urls)

    return APIResponse(
        detail=detail
    )


@presign_api.put(