chore: reformat codebase with Black

Author: nanotaboada

.flake8

@@ -4,6 +4,7 @@ max-complexity = 10
 select = E,F,W
 extend-ignore = E203, W503
 exclude = .venv
+per-file-ignores = tests/test_main.py: E501
 count = True
 show-source = True
 statistics = True

databases/player_database.py

@@ -8,6 +8,7 @@
 
 The `STORAGE_PATH` environment variable controls the SQLite file location.
 """
+
 import logging
 import os
 from typing import AsyncGenerator
@@ -21,16 +22,11 @@
 logging.getLogger("sqlalchemy.engine.Engine").handlers = logger.handlers
 
 async_engine = create_async_engine(
-    DATABASE_URL,
-    connect_args={"check_same_thread": False},
-    echo=True
+    DATABASE_URL, connect_args={"check_same_thread": False}, echo=True
 )
 
 async_sessionmaker = sessionmaker(
-    bind=async_engine,
-    class_=AsyncSession,
-    autocommit=False,
-    autoflush=False
+    bind=async_engine, class_=AsyncSession, autocommit=False, autoflush=False
 )
 
 Base = declarative_base()

main.py

@@ -7,6 +7,7 @@
 
 This serves as the entry point for running the API server.
 """
+
 from contextlib import asynccontextmanager
 import logging
 from typing import AsyncIterator
@@ -17,6 +18,7 @@
 UVICORN_LOGGER = "uvicorn.error"
 logger = logging.getLogger(UVICORN_LOGGER)
 
+
 @asynccontextmanager
 async def lifespan(_: FastAPI) -> AsyncIterator[None]:
     """
@@ -25,10 +27,13 @@ async def lifespan(_: FastAPI) -> AsyncIterator[None]:
     logger.info("Lifespan event handler execution complete.")
     yield
 
-app = FastAPI(lifespan=lifespan,
-              title="python-samples-fastapi-restful",
-              description="🧪 Proof of Concept for a RESTful API made with Python 3 and FastAPI",
-              version="1.0.0",)
+
+app = FastAPI(
+    lifespan=lifespan,
+    title="python-samples-fastapi-restful",
+    description="🧪 Proof of Concept for a RESTful API made with Python 3 and FastAPI",
+    version="1.0.0",
+)
 
 app.include_router(player_route.api_router)
 app.include_router(health_route.api_router)

models/player_model.py

@@ -6,6 +6,7 @@
 
 These models are used for data validation and serialization in the API.
 """
+
 from typing import Optional
 from pydantic import BaseModel, ConfigDict
 from pydantic.alias_generators import to_camel
@@ -24,6 +25,7 @@ class MainModel(BaseModel):
                 Here, it uses `to_camel` to convert field names to camelCase.
             populate_by_name (bool): Allows population of fields by name when using Pydantic models.
     """
+
     model_config = ConfigDict(alias_generator=to_camel, populate_by_name=True)
 
 
@@ -44,6 +46,7 @@ class PlayerModel(MainModel):
         league (Optional[str]): The league where the team plays, if any.
         starting11 (Optional[bool]): Indicates if the Player is in the starting 11, if provided.
     """
+
     id: int
     first_name: str
     middle_name: Optional[str]

pyproject.toml

@@ -5,12 +5,16 @@ include = '\.pyi?$'
 exclude = '''
 /(
     \.git
+  | \.github
+  | \.pytest_cache
   | \.venv
-  | build
-  | dist
+  | \.vscode
+  | assets
+  | htmlcov
+  | postman_collections
+  | scripts
+  | storage
   | __pycache__
-  | \.eggs
-  | \.mypy_cache
-  | \.tox
+  | tests/test_main\.py
 )/
 '''

routes/health_route.py

@@ -4,10 +4,12 @@
 Defines a simple endpoint to verify that the service is up and running.
 Returns a JSON response with a "status" key set to "ok".
 """
+
 from fastapi import APIRouter
 
 api_router = APIRouter()
 
+
 @api_router.get("/health", tags=["Health"])
 async def health_check():
     """

routes/player_route.py

@@ -16,6 +16,7 @@
 - PUT /players/{player_id}                : Update an existing Player.
 - DELETE /players/{player_id}             : Delete an existing Player.
 """
+
 from typing import List
 from fastapi import APIRouter, Body, Depends, HTTPException, status, Path, Response
 from sqlalchemy.ext.asyncio import AsyncSession
@@ -29,7 +30,7 @@
 simple_memory_cache = SimpleMemoryCache()
 
 CACHE_KEY = "players"
-CACHE_TTL = 600 # 10 minutes
+CACHE_TTL = 600  # 10 minutes
 
 # POST -------------------------------------------------------------------------
 
@@ -38,11 +39,11 @@
     "/players/",
     status_code=status.HTTP_201_CREATED,
     summary="Creates a new Player",
-    tags=["Players"]
+    tags=["Players"],
 )
 async def post_async(
     player_model: PlayerModel = Body(...),
-    async_session: AsyncSession = Depends(generate_async_session)
+    async_session: AsyncSession = Depends(generate_async_session),
 ):
     """
     Endpoint to create a new player.
@@ -60,6 +61,7 @@ async def post_async(
     await player_service.create_async(async_session, player_model)
     await simple_memory_cache.clear(CACHE_KEY)
 
+
 # GET --------------------------------------------------------------------------
 
 
@@ -68,11 +70,10 @@ async def post_async(
     response_model=List[PlayerModel],
     status_code=status.HTTP_200_OK,
     summary="Retrieves a collection of Players",
-    tags=["Players"]
+    tags=["Players"],
 )
 async def get_all_async(
-    response: Response,
-    async_session: AsyncSession = Depends(generate_async_session)
+    response: Response, async_session: AsyncSession = Depends(generate_async_session)
 ):
     """
     Endpoint to retrieve all players.
@@ -97,11 +98,11 @@ async def get_all_async(
     response_model=PlayerModel,
     status_code=status.HTTP_200_OK,
     summary="Retrieves a Player by its Id",
-    tags=["Players"]
+    tags=["Players"],
 )
 async def get_by_id_async(
     player_id: int = Path(..., title="The ID of the Player"),
-    async_session: AsyncSession = Depends(generate_async_session)
+    async_session: AsyncSession = Depends(generate_async_session),
 ):
     """
     Endpoint to retrieve a Player by its ID.
@@ -127,11 +128,11 @@ async def get_by_id_async(
     response_model=PlayerModel,
     status_code=status.HTTP_200_OK,
     summary="Retrieves a Player by its Squad Number",
-    tags=["Players"]
+    tags=["Players"],
 )
 async def get_by_squad_number_async(
     squad_number: int = Path(..., title="The Squad Number of the Player"),
-    async_session: AsyncSession = Depends(generate_async_session)
+    async_session: AsyncSession = Depends(generate_async_session),
 ):
     """
     Endpoint to retrieve a Player by its Squad Number.
@@ -146,24 +147,27 @@ async def get_by_squad_number_async(
     Raises:
         HTTPException: HTTP 404 Not Found error if the Player with the specified Squad Number does not exist.
     """
-    player = await player_service.retrieve_by_squad_number_async(async_session, squad_number)
+    player = await player_service.retrieve_by_squad_number_async(
+        async_session, squad_number
+    )
     if not player:
         raise HTTPException(status_code=status.HTTP_404_NOT_FOUND)
     return player
 
+
 # PUT --------------------------------------------------------------------------
 
 
 @api_router.put(
     "/players/{player_id}",
     status_code=status.HTTP_204_NO_CONTENT,
     summary="Updates an existing Player",
-    tags=["Players"]
+    tags=["Players"],
 )
 async def put_async(
     player_id: int = Path(..., title="The ID of the Player"),
     player_model: PlayerModel = Body(...),
-    async_session: AsyncSession = Depends(generate_async_session)
+    async_session: AsyncSession = Depends(generate_async_session),
 ):
     """
     Endpoint to entirely update an existing Player.
@@ -182,18 +186,19 @@ async def put_async(
     await player_service.update_async(async_session, player_model)
     await simple_memory_cache.clear(CACHE_KEY)
 
+
 # DELETE -----------------------------------------------------------------------
 
 
 @api_router.delete(
     "/players/{player_id}",
     status_code=status.HTTP_204_NO_CONTENT,
     summary="Deletes an existing Player",
-    tags=["Players"]
+    tags=["Players"],
 )
 async def delete_async(
     player_id: int = Path(..., title="The ID of the Player"),
-    async_session: AsyncSession = Depends(generate_async_session)
+    async_session: AsyncSession = Depends(generate_async_session),
 ):
     """
     Endpoint to delete an existing Player.

schemas/player_schema.py

@@ -5,6 +5,7 @@
 
 Used for async database CRUD operations in the application.
 """
+
 from sqlalchemy import Column, String, Integer, Boolean
 from databases.player_database import Base
 
@@ -30,13 +31,13 @@ class Player(Base):
     __tablename__ = "players"
 
     id = Column(Integer, primary_key=True)
-    first_name = Column(String, name='firstName', nullable=False)
-    middle_name = Column(String, name='middleName')
-    last_name = Column(String, name='lastName', nullable=False)
+    first_name = Column(String, name="firstName", nullable=False)
+    middle_name = Column(String, name="middleName")
+    last_name = Column(String, name="lastName", nullable=False)
     date_of_birth = Column(String, name="dateOfBirth")
-    squad_number = Column(Integer, name='squadNumber', unique=True, nullable=False)
+    squad_number = Column(Integer, name="squadNumber", unique=True, nullable=False)
     position = Column(String, nullable=False)
-    abbr_position = Column(String, name='abbrPosition')
+    abbr_position = Column(String, name="abbrPosition")
     team = Column(String)
     league = Column(String)
     starting11 = Column(Boolean)

services/player_service.py

@@ -11,6 +11,7 @@
 
 Handles SQLAlchemy exceptions with transaction rollback and logs errors.
 """
+
 from sqlalchemy import select
 from sqlalchemy.ext.asyncio import AsyncSession
 from sqlalchemy.exc import SQLAlchemyError
@@ -42,6 +43,7 @@ async def create_async(async_session: AsyncSession, player_model: PlayerModel):
         await async_session.rollback()
         return False
 
+
 # Retrieve ---------------------------------------------------------------------
 
 
@@ -77,7 +79,9 @@ async def retrieve_by_id_async(async_session: AsyncSession, player_id: int):
     return player
 
 
-async def retrieve_by_squad_number_async(async_session: AsyncSession, squad_number: int):
+async def retrieve_by_squad_number_async(
+    async_session: AsyncSession, squad_number: int
+):
     """
     Retrieves a Player by its Squad Number from the database.
 
@@ -93,6 +97,7 @@ async def retrieve_by_squad_number_async(async_session: AsyncSession, squad_numb
     player = result.scalars().first()
     return player
 
+
 # Update -----------------------------------------------------------------------
 
 
@@ -127,6 +132,7 @@ async def update_async(async_session: AsyncSession, player_model: PlayerModel):
         await async_session.rollback()
         return False
 
+
 # Delete -----------------------------------------------------------------------
 
 

tests/player_stub.py

@@ -15,7 +15,7 @@ def __init__(
         abbr_position=None,
         team=None,
         league=None,
-        starting11=None
+        starting11=None,
     ):
         self.id = id
         self.first_name = first_name
@@ -77,5 +77,5 @@ def unknown_player():
         first_name="John",
         last_name="Doe",
         squad_number="999",
-        position="Lipsum"
+        position="Lipsum",
     )