Merge branch 'notify_system'

src/presentation/dependencies/commands.py

@@ -10,17 +10,19 @@ from src.application.commands import (
     ListOrganizationWalletsCommand,
     ListPurchaseRequestsCommand,
 )
-from src.application.contracts import ILogger
+from src.application.contracts import ILogger, IQueueMessanger
 from src.infrastructure.wallet_balances import WalletBalanceService
 from src.presentation.dependencies.logger import get_logger
 from src.presentation.dependencies.unit_of_work import get_unit_of_work
+from src.presentation.dependencies.messanger import get_queue_messanger
 
 
 def get_create_purchase_request_command(
     logger: ILogger = Depends(get_logger),
     unit_of_work: IUnitOfWork = Depends(get_unit_of_work),
+    messanger: IQueueMessanger = Depends(get_queue_messanger),
 ) -> CreatePurchaseRequestCommand:
-    return CreatePurchaseRequestCommand(unit_of_work=unit_of_work, logger=logger)
+    return CreatePurchaseRequestCommand(unit_of_work=unit_of_work, logger=logger, messanger=messanger)
 
 
 def get_list_purchase_requests_command(

src/presentation/dependencies/messanger.py

@@ -0,0 +1,7 @@
+from functools import lru_cache
+from src.application.contracts import IQueueMessanger
+from src.infrastructure.messanger import RabbitClient
+
+@lru_cache
+def get_queue_messanger() -> IQueueMessanger:
+    return RabbitClient()