Merge pull request #6 from jeantardelli/chapter05_tdd_high_gear_low_gear

Chapter05 tdd high gear low gear

Author: jeantardelli

.travis.yml

@@ -2,5 +2,8 @@ dist: xenial
 language: python
 python: 3.8
 
+install:
+- pip3 install -r requirements.txt
+
 script:
 - make all

Dockerfile

@@ -6,5 +6,5 @@ RUN pip install -r /tmp/requirements.txt
 RUN mkdir -p /code
 COPY *.py /code/
 WORKDIR /code
-ENV FLASK_APP=flask_app.py FLASK_DEBUG=1 PYTHONBUFFERED=1
+ENV FLASK_APP=entrypoints/flask_app.py FLASK_DEBUG=1 PYTHONBUFFERED=1
 CMD flask run --host=0.0.0.0 --port=80

adapters/__init__.py

@@ -1,7 +1,7 @@
 from sqlalchemy import Table, MetaData, Column, Integer, String, Date, ForeignKey
 from sqlalchemy.orm import mapper, relationship
 
-import model
+from domain import model
 
 metadata = MetaData()
 

orm.py renamed to adapters/orm.py

@@ -1,5 +1,5 @@
 import abc
-import model
+from domain import model
 
 class AbstractRepository(abc.ABC):
  @abc.abstractmethod

repository.py renamed to adapters/repository.py

@@ -0,0 +1,48 @@
+from datetime import datetime
+from flask import Flask, request
+from sqlalchemy import create_engine
+from sqlalchemy.orm import sessionmaker
+
+import config
+from domain import model
+from adapters import orm, repository
+from service_layer import services
+
+orm.start_mappers()
+get_session = sessionmaker(bind=create_engine(config.get_mysql_uri()))
+app = Flask(__name__)
+
+@app.route("/add_batch", methods=["POST"])
+def add_batch():
+ session = get_session()
+ repo = repository.SqlAlchemyRepository(session)
+ eta = request.json["eta"]
+ if eta is not None:
+ eta = datetime.fromisoformat(eta).date()
+ services.add_batch(
+ request.json["ref"],
+ request.json["sku"],
+ request.json["qty"],
+ eta,
+ repo,
+ session,
+ )
+ return "OK", 201
+
+
+@app.route("/allocate", methods=["POST"])
+def allocate_endpoint():
+ session = get_session()
+ repo = repository.SqlAlchemyRepository(session)
+ try:
+ batchref = services.allocate(
+ request.json["orderid"],
+ request.json["sku"],
+ request.json["qty"],
+ repo,
+ session,
+ )
+ except (model.OutOfStock, services.InvalidSku) as e:
+ return {"message": str(e)}, 400
+
+ return {"batchref": batchref}, 201