wip: add exception handler

Author: grillazz

app/database.py

@@ -2,7 +2,7 @@
 
 from rotoger import AppStructLogger
 from sqlalchemy.ext.asyncio import async_sessionmaker, create_async_engine
-
+from sqlalchemy.exc import SQLAlchemyError
 from app.config import settings as global_settings
 
 logger = AppStructLogger().get_logger()
@@ -29,6 +29,11 @@ async def get_db() -> AsyncGenerator:
         try:
             yield session
             await session.commit()
-        except Exception as e:
-            await logger.aerror(f"Error getting database session: {e}")
-            raise
+        except Exception as ex:
+            if isinstance(ex, SQLAlchemyError):
+                # Re-raise SQLAlchemyError directly without handling
+                raise
+            else:
+                # Handle other exceptions
+                await logger.aerror(f"NonSQLAlchemyError: {repr(ex)}")
+                raise  # Re-raise after logging

app/exception_handlers.py

@@ -0,0 +1,32 @@
+from fastapi import Request
+from fastapi.responses import JSONResponse
+from sqlalchemy.exc import SQLAlchemyError
+import orjson
+from fastapi import FastAPI
+from rotoger import AppStructLogger
+
+logger = AppStructLogger().get_logger()
+
+async def sqlalchemy_exception_handler(request: Request, exc: SQLAlchemyError) -> JSONResponse:
+    request_path = request.url.path
+    try:
+        raw_body = await request.body()
+        request_body = orjson.loads(raw_body) if raw_body else None
+    except orjson.JSONDecodeError:
+        request_body = None
+
+    await logger.aerror(
+        "Database error occurred",
+        sql_error=repr(exc),
+        request_url=request_path,
+        request_body=request_body,
+    )
+
+    return JSONResponse(
+        status_code=500,
+        content={"message": "A database error occurred. Please try again later."},
+    )
+
+def register_exception_handlers(app: FastAPI) -> None:
+    """Register all exception handlers with the FastAPI app."""
+    app.add_exception_handler(SQLAlchemyError, sqlalchemy_exception_handler)

app/exceptions.py

@@ -3,10 +3,10 @@
 
 import asyncpg
 from fastapi import Depends, FastAPI, Request
-from fastapi.responses import HTMLResponse, JSONResponse
+from fastapi.responses import HTMLResponse
 from fastapi.templating import Jinja2Templates
 from rotoger import AppStructLogger
-from sqlalchemy.exc import SQLAlchemyError
+
 
 from app.api.health import router as health_router
 from app.api.ml import router as ml_router
@@ -17,6 +17,7 @@
 from app.config import settings as global_settings
 from app.redis import get_redis
 from app.services.auth import AuthBearer
+from app.exception_handlers import register_exception_handlers
 
 logger = AppStructLogger().get_logger()
 templates = Jinja2Templates(directory=Path(__file__).parent.parent / "templates")
@@ -62,18 +63,8 @@ def create_app() -> FastAPI:
         dependencies=[Depends(AuthBearer())],
     )
 
-    @app.exception_handler(SQLAlchemyError)
-    async def sqlalchemy_exception_handler(request: Request, exc: SQLAlchemyError):
-        await logger.aerror(
-            "A database error occurred",
-            sql_error=repr(exc),
-            request_url=request.url.path,
-            request_body=request.body,
-        )
-        return JSONResponse(
-            status_code=500,
-            content={"message": "A database error occurred. Please try again later."},
-        )
+    # Register exception handlers
+    register_exception_handlers(app)
 
     @app.get("/index", response_class=HTMLResponse)
     def get_index(request: Request):

app/main.py

@@ -20,14 +20,11 @@ def __tablename__(self) -> str:
         return self.__name__.lower()
 
     async def save(self, db_session: AsyncSession):
-        try:
-            db_session.add(self)
-            await db_session.flush()
-            await db_session.refresh(self)
-            return self
-        except SQLAlchemyError as ex:
-            await logger.aerror(f"Error inserting instance of {self}: {repr(ex)}")
-            raise  # This will make the exception handler catch it
+        db_session.add(self)
+        await db_session.flush()
+        await db_session.refresh(self)
+        return self
+
 
     async def delete(self, db_session: AsyncSession):
         try:
@@ -61,5 +58,4 @@ async def save_or_update(self, db_session: AsyncSession):
                     status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
                     detail=repr(exception),
                 ) from exception
-        finally:
-            await db_session.close()
+