view now users redis, tweak tests+app. [redis_readmodel_view]

Author: hjwp

src/allocation/entrypoints/flask_app.py

@@ -40,8 +40,7 @@ def allocate_endpoint():
 
 @app.route("/allocations/<orderid>", methods=['GET'])
 def allocations_view_endpoint(orderid):
-    uow = unit_of_work.SqlAlchemyUnitOfWork()
-    result = views.allocations(orderid, uow)
+    result = views.allocations(orderid)
     if not result:
         return 'not found', 404
     return jsonify(result), 200

src/allocation/views.py

@@ -1,9 +1,9 @@
+from allocation.adapters import redis_eventpublisher
 from allocation.service_layer import unit_of_work
 
-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)
-        ))
-    return [dict(r) for r in results]
+def allocations(orderid):
+    batches = redis_eventpublisher.get_readmodel(orderid)
+    return [
+        {'batchref': b.decode(), 'sku': s.decode()}
+        for s, b in batches.items()
+    ]

tests/integration/test_views.py

@@ -1,8 +1,20 @@
 from datetime import date
-from allocation import views
+import pytest
+import redis
+from allocation import config, views
 from allocation.domain import commands
 from allocation.service_layer import messagebus, unit_of_work
 
+@pytest.fixture
+def cleanup_redis():
+    r = redis.Redis(**config.get_redis_host_and_port())
+    yield
+    for k in r.keys():
+        print('cleaning up redis key', k)
+        r.delete(k)
+
+pytestmark = pytest.mark.usefixtures('cleanup_redis')
+
 
 def test_allocations_view(sqlite_session_factory):
     uow = unit_of_work.SqlAlchemyUnitOfWork(sqlite_session_factory)
@@ -15,7 +27,7 @@ def test_allocations_view(sqlite_session_factory):
     messagebus.handle(commands.Allocate('otherorder', 'sku1', 30), uow)
     messagebus.handle(commands.Allocate('otherorder', 'sku2', 10), uow)
 
-    assert views.allocations('order1', uow) == [
+    assert views.allocations('order1') == [
         {'sku': 'sku1', 'batchref': 'sku1batch'},
         {'sku': 'sku2', 'batchref': 'sku2batch'},
     ]
@@ -28,6 +40,6 @@ def test_deallocation(sqlite_session_factory):
     messagebus.handle(commands.Allocate('o1', 'sku1', 40), uow)
     messagebus.handle(commands.ChangeBatchQuantity('b1', 10), uow)
 
-    assert views.allocations('o1', uow) == [
+    assert views.allocations('o1') == [
         {'sku': 'sku1', 'batchref': 'b2'},
     ]