redis eventconsumer first cut [redis_eventconsumer_first_cut]

hjwp · hjwp · commit 1b4c664f4e53 · 2020-02-21T12:15:28.000Z
diff --git a/src/allocation/entrypoints/redis_eventconsumer.py b/src/allocation/entrypoints/redis_eventconsumer.py
@@ -0,0 +1,31 @@
+import json
+import logging
+import redis
+
+from allocation import config
+from allocation.domain import commands
+from allocation.adapters import orm
+from allocation.service_layer import messagebus, unit_of_work
+
+logger = logging.getLogger(__name__)
+
+r = redis.Redis(**config.get_redis_host_and_port())
+
+
+def main():
+    orm.start_mappers()
+    pubsub = r.pubsub(ignore_subscribe_messages=True)
+    pubsub.subscribe('change_batch_quantity')
+
+    for m in pubsub.listen():
+        handle_change_batch_quantity(m)
+
+
+def handle_change_batch_quantity(m):
+    logging.debug('handling %s', m)
+    data = json.loads(m['data'])
+    cmd = commands.ChangeBatchQuantity(ref=data['batchref'], qty=data['qty'])
+    messagebus.handle(cmd, uow=unit_of_work.SqlAlchemyUnitOfWork())
+
+if __name__ == '__main__':
+    main()
