handlers talk to redis [redis_readmodel_handlers]

Author: hjwp

src/allocation/service_layer/handlers.py

@@ -80,31 +80,9 @@ 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)