First Commit

Author: José Márquez Doblas

Pipfile

@@ -0,0 +1,14 @@
+[[source]]
+url = "https://pypi.org/simple"
+verify_ssl = true
+name = "pypi"
+
+[packages]
+pytest = "*"
+pytest-cov = "*"
+coverage = "*"
+
+[dev-packages]
+
+[requires]
+python_version = "3.9"

Pipfile.lock

@@ -0,0 +1,8 @@
+from ._exceptions import *
+from ._command import Command
+from ._command_bus import CommandBus
+from ._command_handler import CommandHandler
+from ._query import Query
+from ._query_bus import QueryBus
+from ._query_handler import QueryHandler
+from ._query_response import QueryResponse

__init__.py

@@ -0,0 +1,3 @@
+
+class Command:
+    pass

_command.py

@@ -0,0 +1,23 @@
+from ._command_handler import CommandHandler
+from ._command import Command
+from ._exceptions import CommandAlreadyExistException
+from ._exceptions import CommandHandlerDoesNotExistException
+import threading
+
+
+class CommandBus:
+    def __init__(self):
+        self._commands = {}
+        self._semaphore = threading.Semaphore()
+
+    def subscribe(self, cmd: type, handler: CommandHandler):
+        if cmd in self._commands:
+            raise CommandAlreadyExistException()
+        self._commands[cmd] = handler
+
+    def publish(self, cmd: Command):
+        if cmd.__class__ not in self._commands:
+            raise CommandHandlerDoesNotExistException()
+        self._semaphore.acquire()
+        self._commands[cmd.__class__].handle(cmd)
+        self._semaphore.release()

_command_bus.py

@@ -0,0 +1,9 @@
+from abc import ABC, abstractmethod
+from ._command import Command
+
+
+class CommandHandler(ABC):
+    
+    @abstractmethod
+    def handle(self, cmd: Command):
+        raise NotImplementedError()

_command_handler.py

@@ -0,0 +1,22 @@
+class CommandBusException(Exception):
+    pass
+
+
+class CommandAlreadyExistException(CommandBusException):
+    pass
+
+
+class CommandHandlerDoesNotExistException(CommandBusException):
+    pass
+
+
+class QueryBusException(Exception):
+    pass
+
+
+class QueryAlreadyExistException(QueryBusException):
+    pass
+
+
+class QueryHandlerDoesNotExistException(QueryBusException):
+    pass

_exceptions.py

@@ -0,0 +1,4 @@
+
+
+class Query:
+    pass

_query.py

@@ -0,0 +1,27 @@
+import threading
+from ._query_handler import QueryHandler
+from ._query import Query
+from ._query_response import QueryResponse
+from ._exceptions import QueryAlreadyExistException
+from ._exceptions import QueryHandlerDoesNotExistException
+import threading
+
+
+class QueryBus:
+    def __init__(self):
+        self._querys = {}
+        self._semaphore = threading.Semaphore()
+
+    def subscribe(self, query: Query, handler: QueryHandler):
+        if query in self._querys:
+            raise QueryAlreadyExistException()
+        self._querys[query] = handler
+
+    def publish(self, query: Query) -> QueryResponse:
+        if query.__class__ not in self._querys:
+            raise QueryHandlerDoesNotExistException()
+        self._semaphore.acquire()
+        response: QueryResponse = self._querys[query.__class__].handle(query)
+        self._semaphore.release()
+        return response
+        

_query_bus.py

@@ -0,0 +1,9 @@
+from abc import ABC, abstractmethod
+from ._query import Query
+
+
+class QueryHandler(ABC):
+    
+    @abstractmethod
+    def handle(self, query: Query):
+        raise NotImplementedError()