handlers talk to redis [redis_readmodel_handlers]

Author: hjwp

src/allocation/service_layer/handlers.py

@@ -72,24 +72,8 @@ def publish_allocated_event(
     redis_eventpublisher.publish('line_allocated', event)
 
 
-def add_allocation_to_read_model(
-        event: events.Allocated, uow: unit_of_work.SqlAlchemyUnitOfWork,
-):
-    with uow:
-        uow.session.execute(
-            'INSERT INTO allocations_view (orderid, sku, batchref)'
-            ' VALUES (:orderid, :sku, :batchref)',
-            dict(orderid=event.orderid, sku=event.sku, batchref=event.batchref)
-        )
-        uow.commit()
+def add_allocation_to_read_model(event: events.Allocated, _):
+    redis_eventpublisher.update_readmodel(event.orderid, event.sku, event.batchref)
 
-def remove_allocation_from_read_model(
-        event: events.Deallocated, uow: unit_of_work.SqlAlchemyUnitOfWork,
-):
-    with uow:
-        uow.session.execute(
-            'DELETE FROM allocations_view '
-            ' WHERE orderid = :orderid AND sku = :sku',
-            dict(orderid=event.orderid, sku=event.sku)
-        )
-        uow.commit()
+def remove_allocation_from_read_model(event: events.Deallocated, _):
+    redis_eventpublisher.update_readmodel(event.orderid, event.sku, None)