Log analysis session database failures

app.py

@@ -21,6 +21,8 @@ from zipfile import ZipFile
 import httpx
 import numpy as np
 import cv2
+from email.message import Message
+from email.utils import collapse_rfc2231_value
 from dotenv import load_dotenv
 from fastapi import FastAPI, File, Form, HTTPException, Request, UploadFile
 from fastapi.responses import FileResponse, JSONResponse
@@ -125,6 +127,8 @@ app = FastAPI(title="Sporalize AI", lifespan=lifespan)
 @app.exception_handler(httpx.HTTPStatusError)
 async def backend_error(request: Request, error: httpx.HTTPStatusError):
     status = error.response.status_code
+    logger.error("Analysis backend request failed: path=%s status=%s response=%s",
+        request.url.path, status, error.response.text[:500])
     return JSONResponse({"detail": "Backend request failed"}, status_code=status if status < 500 else 502)
 
 
@@ -167,6 +171,19 @@ def drive_file_id(link):
     return next(group for group in match.groups() if group)
 
 
+def drive_file_name(content_disposition, file_id):
+    message = Message()
+    if content_disposition:
+        message["content-disposition"] = content_disposition
+    name = message.get_filename()
+    if isinstance(name, tuple):
+        name = collapse_rfc2231_value(name)
+    name = (name or f"{file_id}.mp4").replace("\\", "/")
+    name = Path(name).name
+    name = "".join(character for character in name if character.isprintable()).strip()
+    return name[:255] or f"{file_id}.mp4"
+
+
 async def download_drive_file(link, destination):
     file_id = drive_file_id(link)
     url = f"https://drive.google.com/uc?export=download&confirm=t&id={file_id}"
@@ -275,10 +292,11 @@ def probe_drive(payload: dict):
             file_id = drive_file_id(str(link))
             with httpx.stream("GET", f"https://drive.google.com/uc?export=download&confirm=t&id={file_id}", follow_redirects=True, timeout=30) as response:
                 content_type = response.headers.get("content-type", "")
+                content_disposition = response.headers.get("content-disposition", "")
                 size = int(response.headers.get("content-length", "0") or 0)
                 if not response.is_success or "text/html" in content_type.lower():
                     raise ValueError("File is not publicly downloadable")
-            result.update(ok=True, fileId=file_id, fileName=f"{file_id}.mp4", sizeBytes=size or None, contentType=content_type)
+            result.update(ok=True, fileId=file_id, fileName=drive_file_name(content_disposition, file_id), sizeBytes=size or None, contentType=content_type)
         except Exception as error:
             result.update(ok=False, code="unavailable", error=str(error))
         results.append(result)

src/analysis.ts

@@ -51,7 +51,10 @@ export function analysisRouter(db: SupabaseClient, secret: string) {
         p_reference: playerId.success ? null : input.playerId,
         p_name: input.name || `Session ${input.clientId.slice(0, 8)}`,
       });
-      if (error) return res.status(error.code === "P0001" ? 409 : 503).json({ error: "Unable to prepare analysis session" });
+      if (error) {
+        console.error("Unable to prepare analysis session", { code: error.code, message: error.message });
+        return res.status(error.code === "P0001" ? 409 : 503).json({ error: "Unable to prepare analysis session" });
+      }
       return res.json(data);
     } catch (error) { next(error); }
   });
@@ -76,7 +79,10 @@ export function analysisRouter(db: SupabaseClient, secret: string) {
         p_session_id: sessionId, p_user_id: res.locals.userId, p_status: input.status,
         p_path: input.status === "completed" ? input.path : null, p_actions: actions,
       });
-      if (error) return res.status(error.code === "P0001" ? 409 : 503).json({ error: "Unable to save analysis" });
+      if (error) {
+        console.error("Unable to save analysis results", { code: error.code, message: error.message });
+        return res.status(error.code === "P0001" ? 409 : 503).json({ error: "Unable to save analysis" });
+      }
       return res.json({ ok: true });
     } catch (error) { next(error); }
   });