handler for view model update

Author: hjwp

src/allocation/service_layer/handlers.py

@@ -66,3 +66,18 @@ def publish_allocated_event(
     uow: unit_of_work.AbstractUnitOfWork,
 ):
     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()

src/allocation/views.py

@@ -3,10 +3,10 @@
 
 def allocations(orderid: str, uow: unit_of_work.SqlAlchemyUnitOfWork):
     with uow:
-        results = list(
-            uow.session.execute(
-                "SELECT sku, batchref FROM allocations_view WHERE orderid = :orderid",
-                dict(orderid=orderid),
-            )
+        results = uow.session.execute(
+            """
+            SELECT sku, batchref FROM allocations_view WHERE orderid = :orderid
+            """,
+            dict(orderid=orderid),
         )
     return [dict(r) for r in results]