updated

app/api/endpoints/users.py

@@ -5,6 +5,7 @@ from app.api.models.user import User, UpdateUser, UserResponse
 from app.core.database import SessionLocal
 from app.core.security import get_password_hash, verify_password
 from app.core.models import UserInDB
+from app.core.models.User import UserController
 
 database = SessionLocal()
 users_router = router = APIRouter()
@@ -12,16 +13,14 @@ users_router = router = APIRouter()
 
 @router.post("/", status_code=201)
 async def create_user(user: User):
-    db_user = UserInDB(
+    USER = UserController(database)
+    USER.create(
         username=user.username,
         email=user.email,
-        hashed_password=get_password_hash(user.password),
+        password=user.password,
     )
-    database.add(db_user)
-    database.commit()
-    database.refresh(db_user)
-    print(db_user)
-    return {**db_user.data()}
+
+    return USER.details()
 
 
 @router.get("/{user_id}/", response_model=UserResponse)

app/core/errors.py

@@ -17,5 +17,5 @@ async def error_handler(request: Request, exc: Exception) -> JSONResponse:
 
     return JSONResponse(
         status_code=500,
-        content={"detail": "Error Occurs"},
+        content={"detail": str(exc)},
     )

app/core/models/User.py

@@ -10,6 +10,8 @@ from sqlalchemy.sql import func
 
 from app.core.database import Base
 
+from app.core.security import get_password_hash, verify_password
+
 
 class UserInDB(Base):
     __tablename__ = "users"
@@ -34,3 +36,27 @@ class UserInDB(Base):
             "email": self.email,
             "created_at": self.created_at,
         }
+
+
+class UserController:
+    UserInDB = UserInDB
+
+    def __init__(self, database):
+        self.db = database
+
+    def create(self, username: str, email: str, password: str):
+        self.username = username
+        self.email = email
+        self.hashed_password = get_password_hash(password)
+        db_user = UserInDB(
+            username=self.username,
+            email=self.email,
+            hashed_password=self.hashed_password,
+        )
+        self.db.add(db_user)
+        self.db.commit()
+        self.db.refresh(db_user)
+        self.user = db_user.data()
+
+    def details(self):
+        return self.user

app/main.py

@@ -24,7 +24,7 @@ if settings.BACKEND_CORS_ORIGINS:
 app.include_router(api_router, prefix=settings.API_V1_STR)
 
 # # Error handlers
-app.add_exception_handler(422, error_handler)
+# app.add_exception_handler(422, error_handler)
 app.add_exception_handler(500, error_handler)
 
 # Print all routes