Init notification-service.

.github/workflows/python-checks.yml

@@ -34,8 +34,11 @@ jobs:
       - name: Run mypy app
         run: uv run mypy app
 
-      - name: Run mypy mediaservice
-        run: uv run mypy mediaservice
+      - name: Run mypy media-service
+        run: uv run mypy media-service
+
+      - name: Run mypy notification-service
+        run: uv run mypy notification-service
 
       - name: Run mypy packages
         run: uv run mypy packages

.gitignore

@@ -221,4 +221,6 @@ __marimo__/
 
 .secrets
 config.local.yaml
-mediaservice/.env
+media-service/.env
+notification-service/.env
+.env.docker-compose

.pre-commit-config.yaml

@@ -24,11 +24,18 @@ repos:
           args: ["app"]
 
         - id: mypy
-          alias: mypy mediaservice
-          name: Run mypy mediaservice
+          alias: mypy media-service
+          name: Run mypy media-service
           language: system
           exclude: tests
-          args: ["mediaservice"]
+          args: ["media-service"]
+
+        - id: mypy
+          alias: mypy notification-service
+          name: Run mypy notification-service
+          language: system
+          exclude: tests
+          args: ["notification-service"]
 
         - id: mypy
           alias: mypy packages

app/alembic/env.py

@@ -32,7 +32,7 @@
 # ... etc.
 config.set_main_option(
     "sqlalchemy.url",
-    settings.database.url_database,
+    settings.database.url,
 )
 
 

app/api/api_v1/__init__.py

@@ -1,7 +1,8 @@
 __all__ = ("router",)
 from fastapi import APIRouter
 
-from .auth import router as auth_router
+from api.api_v1.auth import router as auth_router
+
 from .favorite_movies import router as favorite_movies_router
 from .genres import router as genres_router
 from .media import router as media_router

app/api/api_v1/auth/__init__.py

@@ -0,0 +1,17 @@
+__all__ = ("router",)
+
+from fastapi import APIRouter
+
+from .login_views import router as login_router
+from .recover_views import router as recover_account_router
+from .refresh_token_views import router as refresh_token_router
+from .registration_views import router as registration_router
+
+router = APIRouter(
+    prefix="/auth",
+)
+
+router.include_router(registration_router)
+router.include_router(login_router)
+router.include_router(recover_account_router)
+router.include_router(refresh_token_router)

app/api/api_v1/auth/login_views.py

@@ -0,0 +1,49 @@
+from fastapi import APIRouter
+from starlette import status
+
+from dependencies.annotations.security import GetLoginDataDep
+from dependencies.annotations.services import AuthServiceDep
+from schemas.auth import SendConfirmationCodeRequest, VerifyUserEmail
+from schemas.token_info import TemporaryTokenInfo, TokenInfo
+
+router = APIRouter(
+    prefix="/login",
+    tags=["Login"],
+)
+
+
+@router.post(
+    "/",
+    response_model=TemporaryTokenInfo,
+    status_code=status.HTTP_200_OK,
+)
+async def login_user(
+    login_data: GetLoginDataDep,
+    auth_service: AuthServiceDep,
+) -> TemporaryTokenInfo:
+    return await auth_service.authenticate_user(login_data)
+
+
+@router.post(
+    "/resend-confirmation-code",
+    status_code=status.HTTP_200_OK,
+)
+async def resend_authenticate_confirmation_code(
+    send_confirmation_code_request: SendConfirmationCodeRequest,
+    auth_service: AuthServiceDep,
+) -> None:
+    await auth_service.send_authenticate_confirmation_code(
+        send_confirmation_code_request,
+    )
+
+
+@router.post(
+    "/verify",
+    status_code=status.HTTP_200_OK,
+    response_model=TokenInfo,
+)
+async def verify_authenticate_user(
+    verify_authenticate_user_data: VerifyUserEmail,
+    auth_service: AuthServiceDep,
+) -> TokenInfo:
+    return await auth_service.verify_authenticate_user(verify_authenticate_user_data)

app/api/api_v1/auth/recover_views.py

@@ -0,0 +1,54 @@
+from fastapi import APIRouter
+from starlette import status
+
+from dependencies.annotations.services import AuthServiceDep
+from schemas.auth import (
+    RecoverAccountRequest,
+    ResetPasswordRequest,
+    SendConfirmationCodeRequest,
+    VerifyUserEmail,
+)
+from schemas.token_info import TemporaryTokenInfo
+
+router = APIRouter(
+    prefix="/recover",
+    tags=["Recover"],
+)
+
+
+@router.post(
+    "/",
+    response_model=TemporaryTokenInfo,
+    status_code=status.HTTP_200_OK,
+)
+async def recover_account(
+    recover_account_data: RecoverAccountRequest,
+    auth_service: AuthServiceDep,
+) -> TemporaryTokenInfo:
+    return await auth_service.recover_account(recover_account_data)
+
+
+@router.post("/resend-confirmation-code")
+async def resend_recover_account_confirmation_code(
+    send_confirmation_code_request: SendConfirmationCodeRequest,
+    auth_service: AuthServiceDep,
+) -> None:
+    return await auth_service.send_recover_account_confirmation_code(
+        send_confirmation_code_request,
+    )
+
+
+@router.post("/verify")
+async def verify_recover_account(
+    verify_recover_account_data: VerifyUserEmail,
+    auth_service: AuthServiceDep,
+) -> TemporaryTokenInfo:
+    return await auth_service.verify_recover_account(verify_recover_account_data)
+
+
+@router.post("/reset-password")
+async def reset_password(
+    reset_password_data: ResetPasswordRequest,
+    auth_service: AuthServiceDep,
+) -> None:
+    await auth_service.reset_password(reset_password_data)

app/api/api_v1/auth/refresh_token_views.py

@@ -0,0 +1,27 @@
+from fastapi import (
+    APIRouter,
+    status,
+)
+
+from dependencies.annotations.security import (
+    AuthUserByRefreshTokenDep,
+)
+from dependencies.annotations.services import AuthServiceDep
+from schemas.token_info import TokenInfo
+
+router = APIRouter(
+    tags=["Refresh Access Token"],
+)
+
+
+@router.post(
+    "/refresh",
+    response_model=TokenInfo,
+    response_model_exclude_unset=True,
+    status_code=status.HTTP_200_OK,
+)
+async def refresh_access_token(
+    user_id: AuthUserByRefreshTokenDep,
+    auth_service: AuthServiceDep,
+) -> TokenInfo:
+    return await auth_service.refresh_access_token(user_id)

app/api/api_v1/auth/registration_views.py

@@ -0,0 +1,47 @@
+from fastapi import APIRouter
+from starlette import status
+
+from dependencies.annotations.services import AuthServiceDep
+from schemas.auth import SendConfirmationCodeRequest, VerifyUserEmail
+from schemas.token_info import TemporaryTokenInfo, TokenInfo
+from schemas.user import UserRegistration
+
+router = APIRouter(
+    prefix="/register",
+    tags=["Registration"],
+)
+
+
+@router.post(
+    "/",
+    response_model=TemporaryTokenInfo,
+    status_code=status.HTTP_200_OK,
+)
+async def register_user(
+    registration_user_data: UserRegistration,
+    auth_service: AuthServiceDep,
+) -> TemporaryTokenInfo:
+    return await auth_service.register_user(registration_user_data)
+
+
+@router.post(
+    "/resend-confirmation-code",
+    status_code=status.HTTP_200_OK,
+)
+async def resend_register_confirmation_code(
+    send_confirmation_code_request: SendConfirmationCodeRequest,
+    auth_service: AuthServiceDep,
+) -> None:
+    await auth_service.send_register_confirmation_code(send_confirmation_code_request)
+
+
+@router.post(
+    "/verify",
+    response_model=TokenInfo,
+    status_code=status.HTTP_201_CREATED,
+)
+async def verify_register_user(
+    verify_register_user_data: VerifyUserEmail,
+    auth_service: AuthServiceDep,
+) -> TokenInfo:
+    return await auth_service.verify_register_user(verify_register_user_data)

app/api/api_v1/media.py

@@ -33,7 +33,7 @@ async def get_presign_url(
     ],
 ) -> PresignUrlResponse:
     return await http_request_service.get_schema_from_request(
-        url=settings.mediaservice.create_presign_url_endpoint,
+        url=settings.media_service.create_presign_url_endpoint,
         method=MethodType.post.value,  # type: ignore[arg-type]
         json=presign_url_create.model_dump(),
         response_schema=PresignUrlResponse,  # type: ignore[arg-type]

app/cache_services/favorite_movie.py

@@ -1,6 +1,6 @@
 from typing import cast
 
-from core.redis.cache_service import CacheService
+from core.redis.service import RedisService
 from schemas.favorite_movie import (
     FavoriteMovieCreate,
     FavoriteMovieWithMovieResponse,
@@ -13,7 +13,7 @@ class FavoriteMovieCacheService:
     def __init__(
         self,
         favorite_movie_service: FavoriteMovieService,
-        cache_service: CacheService,
+        cache_service: RedisService,
     ) -> None:
         self.favorite_movie_service = favorite_movie_service
         self.cache_service = cache_service