fix deletes and add email to errors

Author: mariusandra

backend/app/fastapi.py

@@ -97,7 +97,7 @@ async def validation_exception_handler(request: Request, exc: RequestValidationE
 
     @app.exception_handler(Exception)
     async def unhandled_exception_handler(request: Request, exc: Exception):
-        posthog_capture_exception(exc)
+        posthog_capture_exception(exc, request)
         return JSONResponse(status_code=500, content={"detail": str(exc)})
 
 if __name__ == '__main__':

backend/app/models/frame.py

@@ -194,6 +194,8 @@ async def delete_frame(db: Session, redis: Redis, frame_id: int):
         db.query(Log).filter_by(frame_id=frame_id).delete()
         from .metrics import Metrics
         db.query(Metrics).filter_by(frame_id=frame_id).delete()
+        from .scene_image import SceneImage
+        db.query(SceneImage).filter_by(frame_id=frame_id).delete()
 
         cache_key = f'frame:{frame.frame_host}:{frame.frame_port}:image'
         await redis.delete(cache_key)

backend/app/utils/posthog.py

@@ -1,3 +1,6 @@
+from typing import Optional, Any
+from fastapi import Request
+from jose import jwt, JWTError
 from posthog import Posthog
 
 from app.config import config
@@ -14,12 +17,31 @@ def initialize_posthog() -> None:
         posthog_client = Posthog(project_api_key=token, host=host)
 
 
-def capture_exception(exc: Exception) -> None:
+def _get_email_from_request(request: Request) -> Optional[str]:
+    auth = request.headers.get("Authorization")
+    if not auth or not auth.startswith("Bearer ") or not config.SECRET_KEY:
+        return None
+    token = auth.split(" ", 1)[1]
+    try:
+        payload = jwt.decode(token, config.SECRET_KEY, algorithms=["HS256"])
+    except JWTError:
+        return None
+    return payload.get("sub")
+
+
+def capture_exception(exc: Exception, request: Optional[Request] = None) -> None:
     """Capture an exception with PostHog if initialized."""
     if posthog_client is None:
         return
+
+    kwargs: dict[str, Any] = {}
+    if request is not None:
+        email = _get_email_from_request(request)
+        if email:
+            kwargs["distinct_id"] = email
+            kwargs["properties"] = {"email": email} # TODO: decouple
     try:
-        posthog_client.capture_exception(exc)
+        posthog_client.capture_exception(exc, **kwargs)
     except Exception:
         # Avoid raising exceptions from PostHog itself
-        pass
+        pass