feat: fix the 422

Author: tmgbedu

docker-compose.yml

@@ -13,40 +13,16 @@ services:
             interval: 5s
             timeout: 5s
             retries: 10
-
     db:
-        image: postgres:16
+        image: postgres:17
         environment:
             POSTGRES_DB: database_app_test
             POSTGRES_USER: app
             POSTGRES_PASSWORD: secret
         ports:
             - "5432:5432"
-        volumes:
-            - postgres_data:/var/lib/postgresql/data
         healthcheck:
-            test: [ "CMD-SHELL", "pg_isready -U app -d database_app_test" ]
+            test: [ "CMD", "pg_isready", "-U", "app", "-d", "database_app_test" ]
             interval: 5s
             timeout: 5s
             retries: 10
-
-    minio:
-        image: minio/minio:latest
-        command: server /data --console-address ":9001"
-        environment:
-            MINIO_ROOT_USER: minioadmin
-            MINIO_ROOT_PASSWORD: minioadmin
-        ports:
-            - "9000:9000"
-            - "9001:9001"
-        volumes:
-            - minio_data:/data
-        healthcheck:
-            test: [ "CMD", "mc", "ready", "local" ]
-            interval: 5s
-            timeout: 5s
-            retries: 10
-
-volumes:
-    postgres_data:
-    minio_data:

example/config-app/uv.lock

@@ -1,6 +1,6 @@
 import hashlib
 
-from fastapi import HTTPException
+from fastapi.exceptions import RequestValidationError
 
 from app.http.schemas.auth import StudentRegistrationRequest
 from app.models import User, Profile
@@ -9,7 +9,14 @@
 async def register(request: StudentRegistrationRequest):
     existing_user = await User.where("email", request.email).first()
     if existing_user:
-        raise HTTPException(status_code=400, detail="Email already registered")
+        raise RequestValidationError(
+            errors=[{
+                "loc": ("body", "email"),
+                "msg": "Email already registered",
+                "type": "value_error",
+                "input": request.email,
+            }]
+        )
 
     password = hashlib.md5(request.password.encode()).hexdigest()
     user = User(

example/database-app/app/students/controllers/registration.py

@@ -61,5 +61,6 @@ async def test_user_cannot_register_with_duplicate_email(self):
         await self.post("/students/register", json=payload)
 
         response = await self.post("/students/register", json=payload)
-        assert response.status_code == 400
-        assert response.json()["detail"] == "Email already registered"
+        assert response.status_code == 422
+        errors = response.json()["errors"]
+        assert "email" in errors

example/database-app/tests/features/students/test_register.py

@@ -1,3 +1,14 @@
+class HttpExceptionHandler:
+    """
+    Handles FastAPI HTTPException by returning the exception's own status code and detail.
+    """
+
+    async def render(self, request, exc):
+        from fastapi.responses import JSONResponse
+
+        return JSONResponse(status_code=exc.status_code, content={"detail": exc.detail})
+
+
 class HTTPExceptionHandler:
     """
     The base exception handler for FastAPI applications.
@@ -26,3 +37,45 @@ async def render(self, request, exc):
             content = {"message": "Server Error"}
 
         return JSONResponse(status_code=500, content=content)
+
+
+class ValidationExceptionHandler:
+    """
+    Handles RequestValidationError with content negotiation.
+
+    JSON requests (API clients) receive a 422 Unprocessable Entity response.
+    Non-JSON requests (browser/Inertia) have errors flashed to the session
+    and are redirected back to the referring page.
+    """
+
+    def report(self, exc) -> None:
+        pass
+
+    async def render(self, request, exc):
+        accept = request.headers.get("accept", "")
+        content_type = request.headers.get("content-type", "")
+
+        wants_json = (
+            "application/json" in accept
+            or content_type.startswith("application/json")
+        )
+
+        errors = {}
+        for err in exc.errors():
+            field = ".".join(str(x) for x in err["loc"][1:])
+            errors.setdefault(field, []).append(err["msg"])
+
+        if wants_json:
+            from fastapi.responses import JSONResponse
+
+            return JSONResponse(status_code=422, content={"errors": errors})
+
+        if "session" in request.scope:
+            request.session["errors"] = errors
+
+        from starlette.responses import RedirectResponse
+
+        return RedirectResponse(
+            url=request.headers.get("referer", "/"),
+            status_code=303,
+        )

example/database-app/uv.lock

@@ -1,4 +1,4 @@
-from fastapi_startkit.fastapi.exceptions import HTTPExceptionHandler
+from fastapi_startkit.fastapi.exceptions import HttpExceptionHandler, HTTPExceptionHandler, ValidationExceptionHandler
 from fastapi import FastAPI
 
 from fastapi_startkit.fastapi.commands import ServeCommand
@@ -26,6 +26,8 @@ def _register_exception_handlers(self):
 
         exception_manager = self.app.exception_manager
         exception_manager.register_handler(Exception, HTTPExceptionHandler())
+        exception_manager.register_handler(HTTPException, HttpExceptionHandler())
+        exception_manager.register_handler(RequestValidationError, ValidationExceptionHandler())
 
         async def handler(request, exc):
             return await exception_manager.handle(exc, {"request": request})

fastapi_startkit/src/fastapi_startkit/fastapi/exceptions.py

@@ -12,8 +12,6 @@ def register(self) -> None:
         self.app.bind("inertia", Inertia)
 
     def boot(self) -> None:
-        self.register_validation_handler()
-
         self.app.add_middleware(InertiaMiddleware)
 
         if self.app.has("templates"):
@@ -28,8 +26,3 @@ def inertia_helper(page):
             templates.env.globals["inertia"] = inertia_helper
             templates.env.globals["Inertia"] = self.app.make("inertia")
 
-    def register_validation_handler(self) -> None:
-        from fastapi.exceptions import RequestValidationError
-        from .exceptions import InertiaValidationHandler
-
-        self.app.exception_manager.register_handler(RequestValidationError, InertiaValidationHandler())

fastapi_startkit/src/fastapi_startkit/fastapi/providers/fastapi_provider.py

@@ -107,6 +107,10 @@ async def insert(self, query: str, bindings: list | None = None) -> int | None:
 
         return getattr(result, "lastrowid", None)
 
+    async def insert_get_id(self, query: str, bindings: list | None = None) -> int | None:
+        result = await self.execute(query, bindings)
+        return getattr(result, "lastrowid", None)
+
     async def update(self, query: str, bindings: list | None = None) -> int:
         result = await self.execute(query, bindings)