yes

app/api/v1/gcs.py

@@ -2,9 +2,12 @@ from __future__ import annotations
 
 import base64
 import json
+import mimetypes
 import re
 import time
+from pathlib import Path
 from typing import Any, Dict, Optional
+from urllib.parse import urlparse
 
 from fastapi import APIRouter, Depends, File, Form, Header, HTTPException, Query, Response, UploadFile
 
@@ -441,10 +444,10 @@ async def list_objects(
              summary="Upload an object from a file or a URL (up to the server upload limit)")
 async def upload_object(
     bucket: str,
-    name: str = Form(..., min_length=1, max_length=1024, description="Destination object name"),
+    name: Optional[str] = Form(None, min_length=1, max_length=1024, description="Destination object name (defaults to the uploaded file name)"),
     file: Optional[UploadFile] = File(None, description="Object content to upload"),
     file_url: Optional[str] = Form(None, description="Publicly reachable URL whose content becomes the object"),
-    content_type: str = Form("application/octet-stream", description="Content-Type of the uploaded object"),
+    content_type: Optional[str] = Form(None, description="Content-Type of the uploaded object (auto-detected when omitted)"),
     metadata_json: str = Form(None, description="Optional JSON object of object metadata to set on upload"),
     if_generation_match: Optional[int] = Form(None, description="Generation match condition"),
     credentials_file: Optional[UploadFile] = File(None, description="Service account JSON file (alternative to inline credentials)"),
@@ -458,12 +461,27 @@ async def upload_object(
         raise HTTPException(status_code=422, detail="Either 'file' or 'file_url' must be provided to upload an object.")
     if file is not None and file_url:
         raise HTTPException(status_code=422, detail="Provide either 'file' or 'file_url', not both.")
-    if not re.fullmatch(r"[\w./+-]{1,255}", content_type):
-        raise HTTPException(status_code=422, detail="content_type must be a valid media type.")
+
+    if name is None:
+        if file is not None and file.filename:
+            name = Path(file.filename).name
+        elif file_url:
+            parsed_url = urlparse(file_url)
+            name = Path(parsed_url.path).name or "download"
+    if not name or not name.strip():
+        raise HTTPException(status_code=422, detail="Object name must be non-empty and must not start with '/'.")
     cleaned_name = name.strip()
-    if not cleaned_name or cleaned_name.startswith("/"):
+    if cleaned_name.startswith("/"):
         raise HTTPException(status_code=422, detail="Object name must be non-empty and must not start with '/'.")
 
+    if content_type is None:
+        if file is not None and file.content_type:
+            content_type = file.content_type
+        else:
+            content_type = mimetypes.guess_type(cleaned_name)[0] or "application/octet-stream"
+    if not re.fullmatch(r"[\w./+-]{1,255}", content_type):
+        raise HTTPException(status_code=422, detail="content_type must be a valid media type.")
+
     if credentials_file is not None:
         cred_bytes = await _read_file_limited(credentials_file, what="credentials file")
         creds = await _resolve(service, file_bytes=cred_bytes, file_name=credentials_file.filename)
@@ -477,8 +495,8 @@ async def upload_object(
             raise HTTPException(status_code=exc.status_code, detail=exc.message)
         if len(content) > _MAX_UPLOAD_BYTES:
             raise HTTPException(status_code=413, detail=f"Content from file_url exceeds the {_MAX_UPLOAD_BYTES} byte upload limit")
-        if content_type == "application/octet-stream":
-            content_type = fetched_type or content_type
+        if fetched_type and (content_type == "application/octet-stream" or content_type == mimetypes.guess_type(cleaned_name)[0]):
+            content_type = fetched_type
     else:
         content = await _read_file_limited(file, what="file")
 

app/services/gcs_service.py

@@ -515,7 +515,7 @@ class GCSService:
     async def test_bucket_permissions(
         self, creds: GCSCredentials, bucket: str, permissions: List[str],
     ) -> Dict[str, Any]:
-        params = {"permissions": ",".join(permissions)}
+        params = {"permissions": permissions}
         return await self._request("GET", f"/b/{quote(bucket, safe='')}/iam/testPermissions", creds, params=params)
 
     # ------------------------------------------------------------------

app/services/media_conversion_service.py

@@ -308,6 +308,12 @@ def _convert_image_bytes(data: bytes, params: ImageConversionParams, out_path: P
         img = img.resize(target, Image.LANCZOS)
 
     fmt = _fmt_str(params.format)
+    if detected == fmt:
+        raise MediaConversionError(
+            f"Input is already {fmt}. Same-format conversion is not supported; "
+            "choose a different output format.",
+            status_code=422,
+        )
     if fmt == "JPEG":
         img = _normalise_for_jpeg(img)
     elif fmt in ("PNG", "WEBP") and img.mode not in ("RGB", "RGBA", "L", "LA"):