flask now uses commands [chapter_09_commands_ends]

hjwp · hjwp · commit 341827e59e40 · 2019-11-20T21:12:36.000Z
diff --git a/src/allocation/flask_app.py b/src/allocation/flask_app.py
@@ -1,6 +1,6 @@
 from datetime import datetime
 from flask import Flask, jsonify, request
-from allocation import events, exceptions, messagebus, orm, unit_of_work
+from allocation import commands, exceptions, messagebus, orm, unit_of_work
 
 app = Flask(__name__)
 orm.start_mappers()
@@ -11,21 +11,22 @@ def add_batch():
     eta = request.json['eta']
     if eta is not None:
         eta = datetime.fromisoformat(eta).date()
-    event = events.BatchCreated(
+    cmd = commands.CreateBatch(
         request.json['ref'], request.json['sku'], request.json['qty'], eta,
     )
-    messagebus.handle(event, unit_of_work.SqlAlchemyUnitOfWork())
+    uow = unit_of_work.SqlAlchemyUnitOfWork()
+    messagebus.handle(cmd, uow)
     return 'OK', 201
 
 
 @app.route("/allocate", methods=['POST'])
 def allocate_endpoint():
     try:
-        event = events.AllocationRequired(
+        cmd = commands.Allocate(
             request.json['orderid'], request.json['sku'], request.json['qty'],
         )
-        results = messagebus.handle(event, unit_of_work.SqlAlchemyUnitOfWork())
-        batchref = results.pop()
+        uow = unit_of_work.SqlAlchemyUnitOfWork()
+        batchref = messagebus.handle(cmd, uow)
     except exceptions.InvalidSku as e:
         return jsonify({'message': str(e)}), 400
 
