use bootstrap for redis

hjwp · hjwp · commit a113c8d95bd7 · 2020-03-05T19:59:44.000Z
diff --git a/src/allocation/entrypoints/redis_eventconsumer.py b/src/allocation/entrypoints/redis_eventconsumer.py
@@ -2,30 +2,29 @@
 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__':
