Serverless Function Deploy

.github/workflows/deploy.yml

@@ -3,10 +3,10 @@ run-name: ${{ github.actor }} function deploy
 
 on:
   push:
-    branches: [ dev ]
+    branches: [ dev, "cicd/**" ]
 
 jobs:
-  Deploy:
+  function-deploy:
     runs-on: ubuntu-latest
     environment: dev
     steps:
@@ -28,11 +28,12 @@ jobs:
             DB_ENDPOINT=${{ secrets.DB_ENDPOINT }}
             DB_ACCESS_KEY=${{ secrets.DB_ACCESS_KEY }}
             DB_SECRET_KEY=${{ secrets.DB_SECRET_KEY }}
-            DB_TABLE=${{vars.VERSION}}
+            DB_TABLE=dev
             VERSION=${{vars.VERSION}}
           include: |
-            ./src
-            ./packages
+            src/
+            packages/
+            settings.py
             function_app.py
             requirements.txt
           exclude: |

function_app.py

@@ -1,15 +1,18 @@
 import logging
+
+import semver
+
 from packages import dispatcher
-from src.entrypoints import rest as app_rest
 from settings import config, init_loggers
+from src.entrypoints import rest as app_rest
 
 init_loggers(__name__)
 
 logger = logging.getLogger()
 
 logger.info("FASTAPI APPLICATION CREATION...")
 
-fastapi_app = app_rest.new_fastapi_app(config.VERSION)
+fastapi_app = app_rest.new_fastapi_app(semver.Version.parse(config.VERSION))
 
 logger.info("PASS ASGI APP TO FUNCTION")
 

packages/dispatcher/_dispatcher.py

@@ -80,7 +80,7 @@ async def _invoke_app(self, api_gateway_event: dict):
                 logger.debug(f"Output response: {asgi_app_response}")
                 return asgi_app_response
 
-    async def __call__(self, event: dict):
+    async def __call__(self, event: dict, context: dict):
         logger.info("DISPATCHER STARTUP")
 
         if not event:

requirements-dev.txt

@@ -4,6 +4,5 @@ black
 isort
 
 mypy
-pydantic-mypy
 
 -r requirements.txt

requirements.txt

@@ -7,4 +7,5 @@ types-aioboto3
 types-aiobotocore-dynamodb
 asgi-lifespan
 pyjwt
-argon2-cffi
+argon2-cffi
+semver

settings.py

@@ -21,7 +21,7 @@ class Settings(pydantic_settings.BaseSettings):
 
     VERSION: str = pydantic.Field()
 
-    LOG_LEVEL: str = pydantic.Field(str)
+    LOG_LEVEL: str = pydantic.Field("DEBUG")
     LOG_FORMATTER: str = pydantic.Field("{asctime} {levelname:10s} {message:50s} ({funcName} - {pathname}:{lineno})")
 
     model_config = pydantic_settings.SettingsConfigDict(case_sensitive=True)

src/entrypoints/rest/app.py

@@ -2,10 +2,11 @@
 import logging
 
 import fastapi
+import semver
 
 import settings
-from src.entrypoints.rest.routers import tasks as tasks_router, auth as auth_router
 from src.database.dynamo import connection as dyno_connection
+from src.entrypoints.rest.routers import auth as auth_router, tasks as tasks_router
 
 _logger = logging.getLogger(__name__)
 
@@ -31,8 +32,14 @@ async def _lifespan(_: fastapi.FastAPI):
     _logger.info("REST APPLICATION SHUTDOWN - SUCCESS")
 
 
-def new_fastapi_app(version: str) -> fastapi.FastAPI:
-    app = fastapi.FastAPI(lifespan=_lifespan, version=version, root_path=f"/{version}")
+def new_fastapi_app(version: semver.Version) -> fastapi.FastAPI:
+    app = fastapi.FastAPI(
+        title="TODO Tasks Service",
+        description="Simple todos tasks service built with FastAPI and DynamoDB (provide by aioboto3 lib)",
+        lifespan=_lifespan,
+        version=str(version.finalize_version()),
+        root_path=f"/api/v{version.major}",
+    )
 
     app.include_router(tasks_router.router)
     app.include_router(auth_router.router)

src/entrypoints/rest/routers/auth.py

@@ -13,7 +13,7 @@
 router = fastapi.APIRouter(prefix="/auth", tags=["Auth"])
 
 
-@router.post("/register")
+@router.post("/register", status_code=fastapi.status.HTTP_201_CREATED)
 async def register_user(dyno: repositories_depends.DynoDepends, user_register_dto: user_dtos.UserRegister):
     """
     Register new user endpoint.
@@ -25,7 +25,6 @@ async def register_user(dyno: repositories_depends.DynoDepends, user_register_dt
     if public_user is not None:
         try:
             await user_handlers.register_new_user(dyno, public_user, user_register_dto.password)
-            return fastapi.Response(status_code=fastapi.status.HTTP_201_CREATED)
         except user_exception.UserCreationException:
             raise fastapi.HTTPException(
                 fastapi.status.HTTP_500_INTERNAL_SERVER_ERROR, "Unknown error in user creation..."
@@ -41,8 +40,8 @@ async def login_user(dyno: repositories_depends.DynoDepends, credentials: auth_d
     user = await user_handlers.login_user(dyno, credentials.username, credentials.password)
     if user:
         access, refresh = auth_handlers.generate_access_refresh(user)
-
         return auth_dtos.AuthSuccess(access_token=access.jwt, refresh_token=refresh.jwt, expires_in=access.exp)
+
     raise fastapi.HTTPException(fastapi.status.HTTP_401_UNAUTHORIZED, "Email or password is incorrect")