Normalize uploaded photos' EXIF orientation

Add image normalization for uploaded photos using Pillow. Import Image, ImageOps and UnidentifiedImageError; introduce EXIF_NORMALIZE_EXTS and a _normalize_uploaded_photo(path) helper that applies ImageOps.exif_transpose, converts incompatible modes for JPEG, and saves with reasonable JPEG options. Call the normalizer for files categorized as "photos" and update the stored file size afterward. Errors decoding the image are caught and the original bytes are preserved.

server/app/services/session_store.py

@@ -11,6 +11,7 @@ from typing import Iterable, List, Optional
 from uuid import uuid4
 
 from fastapi import UploadFile
+from PIL import Image, ImageOps, UnidentifiedImageError
 
 from ..core.config import get_settings
 
@@ -18,6 +19,7 @@ from ..core.config import get_settings
 IMAGE_EXTS = {".jpg", ".jpeg", ".png", ".gif", ".webp"}
 DOC_EXTS = {".pdf", ".doc", ".docx"}
 DATA_EXTS = {".csv", ".xls", ".xlsx"}
+EXIF_NORMALIZE_EXTS = {".jpg", ".jpeg", ".png", ".webp"}
 SESSION_ID_RE = re.compile(r"^[0-9a-f]{32}$")
 BUILTIN_PAGE_TEMPLATES = [
     {
@@ -82,6 +84,27 @@ def _category_for(filename: str) -> str:
     return "documents"
 
 
+def _normalize_uploaded_photo(path: Path) -> None:
+    ext = path.suffix.lower()
+    if ext not in EXIF_NORMALIZE_EXTS:
+        return
+
+    try:
+        with Image.open(path) as image:
+            normalized = ImageOps.exif_transpose(image)
+            format_name = image.format
+            if normalized.mode in ("RGBA", "LA", "P") and format_name in {"JPEG", "JPG"}:
+                normalized = normalized.convert("RGB")
+            save_kwargs = {"exif": b""}
+            if format_name in {"JPEG", "JPG"}:
+                save_kwargs["quality"] = 95
+                save_kwargs["optimize"] = True
+            normalized.save(path, format=format_name, **save_kwargs)
+    except (UnidentifiedImageError, OSError, ValueError, TypeError):
+        # Keep original bytes if the file cannot be decoded by Pillow.
+        return
+
+
 def _validate_session_id(session_id: str) -> str:
     if not session_id:
         raise ValueError("Invalid session id.")
@@ -585,6 +608,9 @@ class SessionStore:
                 handle.write(chunk)
 
         category = _category_for(filename)
+        if category == "photos":
+            _normalize_uploaded_photo(dest)
+            size = dest.stat().st_size
         return StoredFile(
             id=file_id,
             name=filename,