✨ Added dynamic dependency injection

Author: serivt

README.md

@@ -1,5 +1,9 @@
 # Pymediator
 
+[![downloads](https://img.shields.io/pypi/dm/django-smooth-migrations.svg)](https://pypistats.org/packages/pymediator)
+[![versions](https://img.shields.io/pypi/pyversions/pymediator.svg)](https://pypi.python.org/pypi/pymediator)
+[![license](https://img.shields.io/github/license/serivt/pymediator.svg)](https://github.com/serivt/pymediator/blob/master/LICENSE)
+
 Provides a lightweight and extensible implementation of the Mediator pattern in Python, specifically designed for systems that follow the CQRS (Command Query Responsibility Segregation) pattern. Its architecture allows for a clear separation of command and query logic, making it ideal for clean architectures and event-driven systems.
 
 ## Install

pymediator/mediator.py

@@ -1,5 +1,5 @@
 from abc import ABC, abstractmethod
-from typing import Any
+from typing import Any, Type, get_type_hints
 
 from pymediator.exceptions import HandlerProtocolViolationException
 from pymediator.handlers import Handler, Request
@@ -57,7 +57,12 @@ def inject(self, **kwargs) -> "Mediator":  # type: ignore[no-untyped-def]
         return Mediator(registry=self.registry, dependencies=kwargs)
 
     def send(self, request: Request) -> Any:
-        handler: Handler = self._registry.get_handler(request)(**self._dependencies)
+        handler_type: Type[Handler] = self._registry.get_handler(request)
+        local_dependencies: dict = {}
+        for name, instance in get_type_hints(handler_type.__init__).items():
+            if name in self._dependencies:
+                local_dependencies[name] = self._dependencies[name]
+        handler: Handler = handler_type(**local_dependencies)
         if not isinstance(handler, Handler):
             raise HandlerProtocolViolationException(handler.__class__.__name__)
         return handler.handle(request)

tests/test_mediators.py

@@ -60,3 +60,45 @@ def handle(self, request: SumRequest) -> int:
         mediator: Mediator = Mediator(registry=registry)
         response: int = mediator.inject(sum_utils=SumUtils()).send(SumRequest(x=3, y=5))
         assert response == 8
+
+    def test_injection_multiple(self) -> None:
+        class SumUtils:
+            def sum(self, x: int, y: int) -> int:
+                return x + y
+
+        class MultiplyUtils:
+            def multiply(self, x: int, y: int) -> int:
+                return x * y
+
+        @dataclass
+        class SumRequest:
+            x: int
+            y: int
+
+        class SumHandler:
+            def __init__(self, sum_utils: SumUtils) -> None:
+                self._sum_utils: SumUtils = sum_utils
+
+            def handle(self, request: SumRequest) -> int:
+                return self._sum_utils.sum(request.x, request.y)
+
+        @dataclass
+        class MultiplyRequest:
+            x: int
+            y: int
+
+        class MultiplyHandler:
+            def __init__(self, multiply_utils: MultiplyUtils) -> None:
+                self._multiply_utils: MultiplyUtils = multiply_utils
+
+            def handle(self, request: MultiplyRequest) -> int:
+                return self._multiply_utils.multiply(request.x, request.y)
+
+        registry: InstanceRegistry = InstanceRegistry()
+        registry.register(SumRequest, SumHandler)
+        registry.register(MultiplyRequest, MultiplyHandler)
+        mediator: Mediator = Mediator(registry=registry).inject(
+            sum_utils=SumUtils(), multiply_utils=MultiplyUtils()
+        )
+        assert mediator.send(SumRequest(x=3, y=5)) == 8
+        assert mediator.send(MultiplyRequest(x=3, y=5)) == 15