feat: implement sync commumication

Author: fiqrikm18

poetry.lock

@@ -22,7 +22,9 @@ dependencies = [
     "redis (>=8.0.0,<9.0.0)",
     "jinja2 (>=3.1.6,<4.0.0)",
     "boto3 (>=1.43.34,<2.0.0)",
-    "sendgrid (>=6.12.5,<7.0.0)"
+    "sendgrid (>=6.12.5,<7.0.0)",
+    "pyotp (>=2.10.0,<3.0.0)",
+    "qrcode[pil] (>=8.2,<9.0)"
 ]
 
 [tool.poetry]

pyproject.toml

@@ -1,15 +1,15 @@
-from src.core.email.factory import create_email_service
-from src.core.events.bus import EventBus, get_event_bus
-from src.shared.events.emails.event import (
+from modules.user.contracts.events.emails.event import (
     PasswordResetRequestedEvent,
     UserRegisteredEvent,
     WelcomeEmailEvent,
 )
-from src.shared.events.emails.handler import (
+from modules.user.contracts.events.emails.handler import (
     SendPasswordResetEmailHandler,
     SendVerificationEmailHandler,
     SendWelcomeEmailHandler,
 )
+from src.core.email.factory import create_email_service
+from src.core.events.bus import EventBus, get_event_bus
 
 
 def register_event_handlers(bus: EventBus | None = None) -> None:

src/core/bootstrap/event.py

@@ -1,7 +1,7 @@
 from fastapi import Depends
 
+from modules.user.contracts.providers import UserModuleProvider
 from src.core.database.postgres.session import get_unit_of_work
-from src.modules.user.application.providers import UserModuleProvider
 from src.shared.unit_of_work import UnitOfWork
 
 

src/core/dependency/providers.py

@@ -1,7 +1,7 @@
 from functools import lru_cache
 
-from src.shared.events.base import Event
-from src.shared.events.handler import EventHandler
+from modules.user.contracts.events.base import Event
+from modules.user.contracts.events.handler import EventHandler
 
 
 class EventBus:

src/core/events/bus.py

@@ -1,13 +1,13 @@
 from uuid import UUID
 
+from modules.user.contracts.providers import UserModuleProvider
 from src.modules.todo import (
     TodoNotFoundError,
     TodoRepository,
     UnauthorizedTodoAccessError,
 )
 from src.modules.todo.presentation.schemas.response import TodoWithOwnerResponse
 from src.modules.user import UserNotFoundError
-from src.modules.user.application.providers import UserModuleProvider
 
 
 class GetTodoDetailWithOwnerHandler:

src/modules/todo/application/detail_todo/handler.py

@@ -1,6 +1,7 @@
 from fastapi import Depends
 from sqlalchemy.ext.asyncio import AsyncSession
 
+from modules.user.contracts.providers import UserModuleProvider
 from src.core.database.postgres.session import get_db, get_unit_of_work
 from src.core.dependency.providers import get_user_module_provider
 from src.modules.todo.application.create_todo.handler import CreateTodoHandler
@@ -16,7 +17,6 @@
 from src.modules.todo.infrastructure.repositories.todo_repository import (
     SQLAlchemyTodoRepository,
 )
-from src.modules.user.application.providers import UserModuleProvider
 from src.shared.unit_of_work import UnitOfWork
 
 

src/modules/todo/presentation/dependency.py

@@ -1,4 +1,4 @@
-from src.modules.user.application.providers import UserProfile
+from modules.user.contracts.providers import UserProfile
 from src.modules.user.domain.exceptions.user_exception import (
     UserAlreadyExistsError,
     UserNotFoundError,

src/modules/user/__init__.py

@@ -1,5 +1,6 @@
 import secrets
 
+from modules.user.contracts.events.emails.event import UserRegisteredEvent
 from src.core.authorization.domain.service import AuthorizationService
 from src.core.authorization.permissions import DEFAULT_USER_ROLE
 from src.core.events.bus import get_event_bus
@@ -11,7 +12,6 @@
 from src.modules.user.domain.entities.user import User
 from src.modules.user.domain.exceptions.user_exception import UserAlreadyExistsError
 from src.modules.user.domain.repositories.user_repository import UserRepository
-from src.shared.events.emails.event import UserRegisteredEvent
 from src.shared.unit_of_work import UnitOfWork