feat(#5): add example user service;

refactor entrypoints and schemas

fix tests and use anyio/asyncio for running async tests

Author: ArielMAJ

.vscode/settings.json

@@ -0,0 +1,5 @@
+{
+  "python.testing.pytestArgs": ["tests"],
+  "python.testing.unittestEnabled": false,
+  "python.testing.pytestEnabled": true
+}

api/app.py

@@ -1,18 +1,27 @@
+from contextlib import asynccontextmanager
 from pathlib import Path
 
 from api.config import Config
-from api.entrypoints.router import api_router
+from api.entrypoints import router
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
 from fastapi_async_sqlalchemy import SQLAlchemyMiddleware
 
 # from fastapi.responses import JSONResponse
 from fastapi_cache import FastAPICache
 from fastapi_cache.backends.inmemory import InMemoryBackend
+from loguru import logger
 
 APP_ROOT = Path(__file__).parent
 
 
+@asynccontextmanager
+async def lifespan(app: FastAPI):
+    logger.info("starting up")
+    yield
+    logger.info("shutting down")
+
+
 def get_app() -> FastAPI:
     """
     Get FastAPI application.
@@ -23,6 +32,8 @@ def get_app() -> FastAPI:
     """
     _app = FastAPI(
         title="fastapi-backend-template",
+        description="FastAPI backend template.",
+        lifespan=lifespan,
         # default_response_class=JSONResponse,
     )
 
@@ -39,7 +50,7 @@ def get_app() -> FastAPI:
         engine_args=Config.DATABASE.ENGINE_ARGS,
         commit_on_exit=True,
     )
-    _app.include_router(router=api_router)
+    _app.include_router(router=router)
 
     FastAPICache.init(InMemoryBackend(), prefix="fastapi-cache")
     return _app

api/entrypoints/__init__.py

@@ -0,0 +1,3 @@
+from api.entrypoints.router import router
+
+__all__ = ["router"]

api/entrypoints/monitoring/views.py api/entrypoints/monitoring.pyapi/entrypoints/monitoring/views.py renamed to api/entrypoints/monitoring.py

@@ -1,5 +1,5 @@
-from api.entrypoints.v1.random_number.schema import RandomResponse
-from api.services.random_number_service import RandomNumberService
+from api.schemas.random_number import RandomResponse
+from api.services.random_number_service import RandomResponseService
 from fastapi import APIRouter
 from fastapi_cache.decorator import cache
 
@@ -14,4 +14,4 @@ async def random_number():
 
     :returns: random number to user.
     """
-    return await RandomNumberService.get_random_number()
+    return await RandomResponseService.get_random_number()

api/entrypoints/monitoring/__init__.py

@@ -1,4 +1,4 @@
-from api.entrypoints.v1.root_response.schema import RootResponse
+from api.schemas.root_response import RootResponse
 from api.services.root_response_service import RootResponseService
 from fastapi import APIRouter
 from fastapi_cache.decorator import cache

api/entrypoints/v1/random_number/views.py api/entrypoints/random_response.pyapi/entrypoints/v1/random_number/views.py renamed to api/entrypoints/random_response.py

@@ -1,6 +1,10 @@
-from api.entrypoints import monitoring, v1
+from api.entrypoints import monitoring, random_response, root_response, user
 from fastapi.routing import APIRouter
 
-api_router = APIRouter()
-api_router.include_router(monitoring.router)
-api_router.include_router(v1.router, prefix="/v1", tags=["v1"])
+router = APIRouter()
+router.include_router(monitoring.router, tags=["Monitoring"])
+router.include_router(
+    random_response.router, prefix="/random_number", tags=["Random Number"]
+)
+router.include_router(root_response.router, prefix="", tags=["Root Response"])
+router.include_router(user.router, prefix="/user", tags=["User"])

api/entrypoints/v1/root_response/views.py api/entrypoints/root_response.pyapi/entrypoints/v1/root_response/views.py renamed to api/entrypoints/root_response.py

@@ -1,9 +1,8 @@
 from typing import List
 
-from api.database.models.users import User
 from api.schemas.user import UserCreate
+from api.services.user_service import UserService
 from fastapi import APIRouter
-from loguru import logger
 
 router = APIRouter()
 
@@ -16,7 +15,7 @@ async def get_users() -> List[UserCreate]:
     Returns:
         List[User]: A list of User objects.
     """
-    return await User.get_all()
+    return await UserService.get_all()
 
 
 @router.get("/{user_id}", response_model=UserCreate)
@@ -30,7 +29,7 @@ async def get_user(user_id: int):
     Returns:
         User: The User object.
     """
-    return await User.get_by_id(user_id)
+    return await UserService.get_user(user_id)
 
 
 @router.post("/", response_model=UserCreate)
@@ -44,8 +43,7 @@ async def create_user(user: UserCreate):
     Returns:
         User: The created User object.
     """
-    logger.info(user.model_dump())
-    return await User.new(**user.model_dump())
+    return await UserService.create_user(user)
 
 
 @router.put("/{user_id}", response_model=None)
@@ -60,7 +58,7 @@ async def update_user(user_id: int, user: UserCreate):
     Returns:
         User: The updated User object.
     """
-    return await User.update_by_id(user_id, **user.model_dump())
+    return await UserService.update_user(user_id, user)
 
 
 @router.delete("/{user_id}")
@@ -71,5 +69,4 @@ async def delete_user(user_id: int):
     Args:
         user_id (int): The ID of the user.
     """
-    await User.delete_by_id(user_id)
-    return {"message": "User deleted successfully"}
+    return await UserService.delete_user(user_id)