switch to a notifications class [notifications_class]

Author: hjwp

src/allocation/adapters/email.py

@@ -0,0 +1,31 @@
+#pylint: disable=too-few-public-methods
+import abc
+import smtplib
+from allocation import config
+
+
+class AbstractNotifications(abc.ABC):
+
+    @abc.abstractmethod
+    def send(self, destination, message):
+        raise NotImplementedError
+
+
+DEFAULT_HOST = config.get_email_host_and_port()['host']
+DEFAULT_PORT = config.get_email_host_and_port()['port']
+
+
+
+class EmailNotifications(AbstractNotifications):
+
+    def __init__(self, smtp_host=DEFAULT_HOST, port=DEFAULT_PORT):
+        self.server = smtplib.SMTP(smtp_host, port=port)
+        self.server.noop()
+
+    def send(self, destination, message):
+        msg = f'Subject: allocation service notification\n{message}'
+        self.server.sendmail(
+            from_addr='[email protected]',
+            to_addrs=[destination],
+            msg=msg
+        )

src/allocation/adapters/notifications.py

@@ -1,20 +1,26 @@
 import inspect
 from typing import Callable
-from allocation.adapters import email, orm, redis_eventpublisher
+from allocation.adapters import orm, redis_eventpublisher
+from allocation.adapters.notifications import (
+    AbstractNotifications, EmailNotifications
+)
 from allocation.service_layer import handlers, messagebus, unit_of_work
 
 
 def bootstrap(
     start_orm: bool = True,
     uow: unit_of_work.AbstractUnitOfWork = unit_of_work.SqlAlchemyUnitOfWork(),
-    send_mail: Callable = email.send,
+    notifications: AbstractNotifications = None,
     publish: Callable = redis_eventpublisher.publish,
 ) -> messagebus.MessageBus:
 
+    if notifications is None:
+        notifications = EmailNotifications()
+
     if start_orm:
         orm.start_mappers()
 
-    dependencies = {'uow': uow, 'send_mail': send_mail, 'publish': publish}
+    dependencies = {'uow': uow, 'notifications': notifications, 'publish': publish}
     injected_event_handlers = {
         event_type: [
             inject_dependencies(handler, dependencies)

src/allocation/bootstrap.py

@@ -19,3 +19,8 @@ def get_redis_host_and_port():
     port = 63791 if host == 'localhost' else 6379
     return dict(host=host, port=port)
 
+def get_email_host_and_port():
+    host = os.environ.get('EMAIL_HOST', 'localhost')
+    port = 11025 if host == 'localhost' else 1025
+    http_port = 18025 if host == 'localhost' else 8025
+    return dict(host=host, port=port, http_port=http_port)

src/allocation/config.py

@@ -5,13 +5,15 @@
 from allocation.domain import commands, events, model
 from allocation.domain.model import OrderLine
 if TYPE_CHECKING:
+    from allocation.adapters import notifications
     from . import unit_of_work
 
 
 class InvalidSku(Exception):
     pass
 
 
+
 def add_batch(
         cmd: commands.CreateBatch, uow: unit_of_work.AbstractUnitOfWork
 ):
@@ -56,9 +58,9 @@ def change_batch_quantity(
 #pylint: disable=unused-argument
 
 def send_out_of_stock_notification(
-        event: events.OutOfStock, send_mail: Callable,
+        event: events.OutOfStock, notifications: notifications.AbstractNotifications,
 ):
-    send_mail(
+    notifications.send(
         '[email protected]',
         f'Out of stock for {event.sku}',
     )