use bootstrap for redis

Author: hjwp

src/allocation/entrypoints/redis_eventconsumer.py

@@ -2,30 +2,28 @@
 import logging
 import redis
 
-from allocation import config
+from allocation import bootstrap, 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()
+    bus = bootstrap.bootstrap()
     pubsub = r.pubsub(ignore_subscribe_messages=True)
     pubsub.subscribe("change_batch_quantity")
 
     for m in pubsub.listen():
-        handle_change_batch_quantity(m)
+        handle_change_batch_quantity(m, bus)
 
 
-def handle_change_batch_quantity(m):
+def handle_change_batch_quantity(m, bus):
     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())
+    bus.handle(cmd)
 
 
 if __name__ == "__main__":