new helpers to update read model [redis_readmodel_client]

hjwp · hjwp · commit 51c336e2e4b7 · 2020-03-05T19:57:00.000Z
diff --git a/src/allocation/adapters/redis_eventpublisher.py b/src/allocation/adapters/redis_eventpublisher.py
@@ -14,3 +14,11 @@
 def publish(channel, event: events.Event):
     logging.debug('publishing: channel=%s, event=%s', channel, event)
     r.publish(channel, json.dumps(asdict(event)))
+
+
+def update_readmodel(orderid, sku, batchref):
+    r.hset(orderid, sku, batchref)
+
+
+def get_readmodel(orderid):
+    return r.hgetall(orderid)
diff --git a/src/allocation/entrypoints/redis_eventconsumer.py b/src/allocation/entrypoints/redis_eventconsumer.py
@@ -27,5 +27,6 @@ def handle_change_batch_quantity(m):
     cmd = commands.ChangeBatchQuantity(ref=data['batchref'], qty=data['qty'])
     messagebus.handle(cmd, uow=unit_of_work.SqlAlchemyUnitOfWork())
 
+
 if __name__ == '__main__':
     main()
