add handler for Allocated [chapter_11_external_events_ends]

hjwp · hjwp · commit 0b3f74a948b2 · 2020-02-21T12:15:28.000Z
diff --git a/src/allocation/service_layer/handlers.py b/src/allocation/service_layer/handlers.py
@@ -1,6 +1,6 @@
 from __future__ import annotations
 from typing import TYPE_CHECKING
-from allocation.adapters import email
+from allocation.adapters import email, redis_eventpublisher
 from allocation.domain import commands, events, model
 from allocation.domain.model import OrderLine
 if TYPE_CHECKING:
@@ -47,10 +47,18 @@ def change_batch_quantity(
         uow.commit()
 
 
+#pylint: disable=unused-argument
+
 def send_out_of_stock_notification(
         event: events.OutOfStock, uow: unit_of_work.AbstractUnitOfWork,
 ):
     email.send(
         'stock@made.com',
         f'Out of stock for {event.sku}',
     )
+
+
+def publish_allocated_event(
+        event: events.Allocated, uow: unit_of_work.AbstractUnitOfWork,
+):
+    redis_eventpublisher.publish('line_allocated', event)
diff --git a/src/allocation/service_layer/messagebus.py b/src/allocation/service_layer/messagebus.py
@@ -60,6 +60,7 @@ def handle_command(
 
 
 EVENT_HANDLERS = {
+    events.Allocated: [handlers.publish_allocated_event],
     events.OutOfStock: [handlers.send_out_of_stock_notification],
 }  # type: Dict[Type[events.Event], List[Callable]]
 
