Auth feature done

Author: Jrhero14

.env.example

@@ -0,0 +1,9 @@
+DB_CONNECTION=mysql
+DB_HOST=localhost
+DB_USERNAME=root
+DB_PASSWORD=
+DB_NAME=testing
+DB_PORT=3306
+
+HASH_SALT=
+HASH_ALGORITHM=HS256

app/controllers/authController.py

@@ -6,7 +6,7 @@
 from app.services import UserService
 
 
-async def registerUser(user: CreateUserDto) -> JSONResponse:
+async def registerUserController(user: CreateUserDto) -> JSONResponse:
 
     # Process Register in UserService
     user = UserService.register(user)
@@ -21,7 +21,7 @@ async def registerUser(user: CreateUserDto) -> JSONResponse:
         headers={"Content-Type": "application/json"}
     )
 
-async def login(body: LoginUserDto):
+async def loginController(body: LoginUserDto):
 
     token = UserService.login(body=body)
 

app/controllers/userController.py

@@ -0,0 +1,20 @@
+from starlette import status
+from starlette.responses import JSONResponse
+
+from app.services import UserService
+from fastapi.encoders import jsonable_encoder
+
+
+async def getUsersController():
+    # Get User in with services
+    users = UserService.getUsers()
+
+    return JSONResponse(
+        status_code=status.HTTP_200_OK,
+        content={
+            "status": "success",
+            "message": "Success get all users",
+            "data": jsonable_encoder(users),
+        },
+        headers={"Content-Type": "application/json"}
+    )

app/middlewares/__init__.py

@@ -0,0 +1,12 @@
+from fastapi import FastAPI
+from fastapi.middleware.cors import CORSMiddleware
+
+
+# function for enabling CORS on web server
+def add(app: FastAPI):
+    app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"])

app/middlewares/cors_middleware.py

@@ -35,4 +35,9 @@ def getbyid(id: int) -> User:
 
 def getByEmail(email: str):
     with SessionLocal() as session:
-        return session.query(User).where(User.email == email).first()
+        return session.query(User).where(User.email == email).first()
+
+
+def getUsers():
+    with SessionLocal() as session:
+        return session.query(User).all()

app/repositories/userRepository.py

@@ -51,3 +51,9 @@ def login(body: LoginUserDto):
     token = create_access_token(payload={"user_id": user.id}, expires_delta=access_token_expires)
 
     return token
+
+
+def getUsers():
+    # Handle query with User Repository to get All users
+    users = userRepository.getUsers()
+    return users

app/services/UserService.py

@@ -24,7 +24,6 @@
 SQLALCHEMY_TRACK_MODIFICATIONS = False
 SQLALCHEMY_DATABASE_URL = f"{DB_CONNECTION}://{DB_USERNAME}:{DB_PASSWORD}@{DB_HOST}:{DB_PORT}/{DB_NAME}"
 
-print(SQLALCHEMY_DATABASE_URL)
 
 engine = create_engine(SQLALCHEMY_DATABASE_URL)
 SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)

database/config.py

@@ -0,0 +1,26 @@
+from fastapi import FastAPI
+from fastapi.exceptions import RequestValidationError
+from starlette.responses import JSONResponse
+
+
+def add(app: FastAPI):
+    @app.exception_handler(RequestValidationError)
+    async def validation_exception_handler(request, exc: RequestValidationError):
+        error_format = {
+            "status": "fail",
+            "message": "Request Validation Error",
+            "errors": []
+        }
+        field_list = []
+        for error in exc.errors():
+            field_error = {
+                "type": error["type"],
+                "location": error["loc"][0],
+                "field": error["loc"][1],
+                "message": error["msg"]
+            }
+            field_list.append(field_error)
+
+        error_format["errors"] = field_list
+
+        return JSONResponse(status_code=422, content=error_format)