handle_command no longer returns

Author: hjwp

src/allocation/entrypoints/flask_app.py

@@ -31,8 +31,7 @@ def allocate_endpoint():
             request.json["orderid"], request.json["sku"], request.json["qty"]
         )
         uow = unit_of_work.SqlAlchemyUnitOfWork()
-        results = messagebus.handle(cmd, uow)
-        batchref = results.pop(0)
+        messagebus.handle(cmd, uow)
     except InvalidSku as e:
         return {"message": str(e)}, 400
 

src/allocation/service_layer/messagebus.py

@@ -13,22 +13,16 @@
 Message = Union[commands.Command, events.Event]
 
 
-def handle(
-    message: Message,
-    uow: unit_of_work.AbstractUnitOfWork,
-):
-    results = []
+def handle(message: Message, uow: unit_of_work.AbstractUnitOfWork):
     queue = [message]
     while queue:
         message = queue.pop(0)
         if isinstance(message, events.Event):
             handle_event(message, queue, uow)
         elif isinstance(message, commands.Command):
-            cmd_result = handle_command(message, queue, uow)
-            results.append(cmd_result)
+            handle_command(message, queue, uow)
         else:
             raise Exception(f"{message} was not an Event or Command")
-    return results
 
 
 def handle_event(
@@ -54,9 +48,8 @@ def handle_command(
     logger.debug("handling command %s", command)
     try:
         handler = COMMAND_HANDLERS[type(command)]
-        result = handler(command, uow=uow)
+        handler(command, uow=uow)
         queue.extend(uow.collect_new_events())
-        return result
     except Exception:
         logger.exception("Exception handling command %s", command)
         raise