Skip to content

Commit 698a853

Browse files
committed
feat: implement sync commumication
1 parent 7b7f51f commit 698a853

12 files changed

Lines changed: 17 additions & 17 deletions

File tree

src/core/bootstrap/event.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,15 @@
1-
from src.core.email.factory import create_email_service
2-
from src.core.events.bus import EventBus, get_event_bus
3-
from src.modules.user.contracts.events.emails.event import (
1+
from modules.user.domain.events.emails.event import (
42
PasswordResetRequestedEvent,
53
UserRegisteredEvent,
64
WelcomeEmailEvent,
75
)
8-
from src.modules.user.contracts.events.emails.handler import (
6+
from modules.user.infrastructure.events.emails.handler import (
97
SendPasswordResetEmailHandler,
108
SendVerificationEmailHandler,
119
SendWelcomeEmailHandler,
1210
)
11+
from src.core.email.factory import create_email_service
12+
from src.core.events.bus import EventBus, get_event_bus
1313

1414

1515
def register_event_handlers(bus: EventBus | None = None) -> None:

src/core/dependency/providers.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
from fastapi import Depends
22

3+
from modules.user.providers import UserModuleProvider
34
from src.core.database.postgres.session import get_unit_of_work
4-
from src.modules.user.contracts.providers import UserModuleProvider
55
from src.shared.unit_of_work import UnitOfWork
66

77

src/core/events/bus.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
from functools import lru_cache
22

3-
from src.modules.user.contracts.events.base import Event
4-
from src.modules.user.contracts.events.handler import EventHandler
3+
from shared.events.base import Event
4+
from shared.events.handler import EventHandler
55

66

77
class EventBus:

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
from uuid import UUID
22

3+
from modules.user.providers import UserModuleProvider
34
from src.modules.todo import (
45
TodoNotFoundError,
56
TodoRepository,
67
UnauthorizedTodoAccessError,
78
)
89
from src.modules.todo.presentation.schemas.response import TodoWithOwnerResponse
910
from src.modules.user import UserNotFoundError
10-
from src.modules.user.contracts.providers import UserModuleProvider
1111

1212

1313
class GetTodoDetailWithOwnerHandler:

src/modules/todo/presentation/dependency.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
from fastapi import Depends
22
from sqlalchemy.ext.asyncio import AsyncSession
33

4+
from modules.user.providers import UserModuleProvider
45
from src.core.database.postgres.session import get_db, get_unit_of_work
56
from src.core.dependency.providers import get_user_module_provider
67
from src.modules.todo.application.create_todo.handler import CreateTodoHandler
@@ -16,7 +17,6 @@
1617
from src.modules.todo.infrastructure.repositories.todo_repository import (
1718
SQLAlchemyTodoRepository,
1819
)
19-
from src.modules.user.contracts.providers import UserModuleProvider
2020
from src.shared.unit_of_work import UnitOfWork
2121

2222

src/modules/user/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
from src.modules.user.contracts.providers import UserProfile
1+
from modules.user.providers import UserProfile
22
from src.modules.user.domain.exceptions.user_exception import (
33
UserAlreadyExistsError,
44
UserNotFoundError,

src/modules/user/application/auth/register_user/handler.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
import secrets
22

3+
from modules.user.domain.events.emails.event import UserRegisteredEvent
34
from src.core.authorization.domain.service import AuthorizationService
45
from src.core.authorization.permissions import DEFAULT_USER_ROLE
56
from src.core.events.bus import get_event_bus
@@ -8,7 +9,6 @@
89
from src.modules.user.application.auth.register_user.validation import (
910
validate_register_user_command,
1011
)
11-
from src.modules.user.contracts.events.emails.event import UserRegisteredEvent
1212
from src.modules.user.domain.entities.user import User
1313
from src.modules.user.domain.exceptions.user_exception import UserAlreadyExistsError
1414
from src.modules.user.domain.repositories.user_repository import UserRepository

src/modules/user/contracts/events/emails/event.py renamed to src/modules/user/domain/events/emails/event.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
from dataclasses import dataclass
22

3-
from src.modules.user.contracts.events.base import Event
3+
from shared.events.base import Event
44

55

66
@dataclass

src/modules/user/contracts/events/emails/handler.py renamed to src/modules/user/infrastructure/events/emails/handler.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
1-
from src.core.config import settings
2-
from src.core.email.service import EmailService
3-
from src.modules.user.contracts.events.emails.event import (
1+
from modules.user.domain.events.emails.event import (
42
PasswordResetRequestedEvent,
53
UserRegisteredEvent,
64
WelcomeEmailEvent,
75
)
8-
from src.modules.user.contracts.events.handler import EventHandler
6+
from shared.events.handler import EventHandler
7+
from src.core.config import settings
8+
from src.core.email.service import EmailService
99

1010

1111
class SendVerificationEmailHandler(EventHandler):

0 commit comments

Comments
 (0)