feed thru notifications into flask and redis

hjwp · hjwp · commit b641cbed4d73 · 2020-01-03T23:35:41.000Z
diff --git a/src/allocation/entrypoints/flask_app.py b/src/allocation/entrypoints/flask_app.py
@@ -2,7 +2,7 @@
 from flask import Flask, jsonify, request
 
 from allocation.domain import commands
-from allocation.adapters import orm, email, redis_eventpublisher
+from allocation.adapters import notifications, orm, redis_eventpublisher
 from allocation.service_layer import messagebus, unit_of_work
 from allocation.service_layer.handlers import InvalidSku
 from allocation import views
@@ -12,7 +12,7 @@
 uow = unit_of_work.SqlAlchemyUnitOfWork()
 bus = messagebus.MessageBus(
     uow=uow,
-    send_mail=email.send,
+    notifications=notifications.EmailNotifications(),
     publish=redis_eventpublisher.publish
 )
 uow.bus = bus
diff --git a/src/allocation/entrypoints/redis_eventconsumer.py b/src/allocation/entrypoints/redis_eventconsumer.py
@@ -4,7 +4,7 @@
 
 from allocation import config
 from allocation.domain import commands
-from allocation.adapters import email, orm, redis_eventpublisher
+from allocation.adapters import notifications, orm, redis_eventpublisher
 from allocation.service_layer import messagebus, unit_of_work
 
 logger = logging.getLogger(__name__)
@@ -15,7 +15,7 @@ def get_bus():
     uow = unit_of_work.SqlAlchemyUnitOfWork()
     bus = messagebus.MessageBus(
         uow=uow,
-        send_mail=email.send,
+        notifications=notifications.EmailNotifications(),
         publish=redis_eventpublisher.publish
     )
     uow.bus = bus
