redis eventconsumer first cut [redis_eventconsumer_first_cut]

Author: hjwp

src/allocation/entrypoints/redis_eventconsumer.py

@@ -0,0 +1,32 @@
+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()