Skip to content

Commit 7b7f51f

Browse files
committed
feat: implement sync commumication
1 parent 5acda50 commit 7b7f51f

10 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 modules.user.contracts.events.emails.event import (
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 (
24
PasswordResetRequestedEvent,
35
UserRegisteredEvent,
46
WelcomeEmailEvent,
57
)
6-
from modules.user.contracts.events.emails.handler import (
8+
from src.modules.user.contracts.events.emails.handler import (
79
SendPasswordResetEmailHandler,
810
SendVerificationEmailHandler,
911
SendWelcomeEmailHandler,
1012
)
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.contracts.providers import UserModuleProvider
43
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 modules.user.contracts.events.base import Event
4-
from modules.user.contracts.events.handler import EventHandler
3+
from src.modules.user.contracts.events.base import Event
4+
from src.modules.user.contracts.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.contracts.providers import UserModuleProvider
43
from src.modules.todo import (
54
TodoNotFoundError,
65
TodoRepository,
76
UnauthorizedTodoAccessError,
87
)
98
from src.modules.todo.presentation.schemas.response import TodoWithOwnerResponse
109
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,7 +1,6 @@
11
from fastapi import Depends
22
from sqlalchemy.ext.asyncio import AsyncSession
33

4-
from modules.user.contracts.providers import UserModuleProvider
54
from src.core.database.postgres.session import get_db, get_unit_of_work
65
from src.core.dependency.providers import get_user_module_provider
76
from src.modules.todo.application.create_todo.handler import CreateTodoHandler
@@ -17,6 +16,7 @@
1716
from src.modules.todo.infrastructure.repositories.todo_repository import (
1817
SQLAlchemyTodoRepository,
1918
)
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 modules.user.contracts.providers import UserProfile
1+
from src.modules.user.contracts.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,6 +1,5 @@
11
import secrets
22

3-
from modules.user.contracts.events.emails.event import UserRegisteredEvent
43
from src.core.authorization.domain.service import AuthorizationService
54
from src.core.authorization.permissions import DEFAULT_USER_ROLE
65
from src.core.events.bus import get_event_bus
@@ -9,6 +8,7 @@
98
from src.modules.user.application.auth.register_user.validation import (
109
validate_register_user_command,
1110
)
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

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 modules.user.contracts.events.base import Event
3+
from src.modules.user.contracts.events.base import Event
44

55

66
@dataclass

src/modules/user/contracts/events/emails/handler.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
1-
from modules.user.contracts.events.emails.event import (
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 (
24
PasswordResetRequestedEvent,
35
UserRegisteredEvent,
46
WelcomeEmailEvent,
57
)
6-
from modules.user.contracts.events.handler import EventHandler
7-
from src.core.config import settings
8-
from src.core.email.service import EmailService
8+
from src.modules.user.contracts.events.handler import EventHandler
99

1010

1111
class SendVerificationEmailHandler(EventHandler):

src/modules/user/contracts/events/handler.py

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

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

55

66
class EventHandler(Protocol):

0 commit comments

Comments
 (0)