Merge branch 'master' of github.com:PacktPublishing/Hands-on-Microservices-with-Python

Author: pfwd

.gitignore

@@ -0,0 +1,2 @@
+.idea
+venv/*

Dockerfile

@@ -0,0 +1,18 @@
+FROM python:3-alpine
+
+MAINTAINER Peter Fisher
+
+COPY ./app /app
+
+WORKDIR /app
+
+RUN apk add --update \
+    py-mysqldb \
+    gcc \
+    libc-dev \
+    mariadb-dev \
+  && pip install -r requirements.txt \
+  && rm -rf /var/cache/apk/*
+
+CMD ["python", "app.py"]
+

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2018 Packt
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,7 @@
+# Hands on Microservices with Python
+Published by Packt
+
+Author: [Peter Fisher](http://howtocodewell.net)
+
+## Install
+Please follow [installation instructions](doc/INSTALL.md)

app/__init__.py

@@ -0,0 +1,74 @@
+from flask import Flask, g
+
+from flask_login import LoginManager, user_loaded_from_header
+from flask_bootstrap import Bootstrap
+from frontend import frontend_blueprint
+from user_api import user_api_blueprint
+from product_api import product_api_blueprint
+from order_api import order_api_blueprint
+from flask.sessions import SecureCookieSessionInterface
+import models
+import base64
+
+app = Flask(__name__)
+
+login_manager = LoginManager(app)
+login_manager.init_app(app)
+login_manager.login_view = 'frontend.login'
+
+bootstrap = Bootstrap(app)
+
+app.config.update(dict(
+    SECRET_KEY="powerful secretkey",
+    WTF_CSRF_SECRET_KEY="a csrf secret key",
+    SQLALCHEMY_DATABASE_URI='mysql+mysqlconnector://root:test@db/order_sys',
+    SQLALCHEMY_TRACK_MODIFICATIONS='false',
+    API_URI='http://192.168.99.100'
+))
+
+models.init_app(app)
+models.create_tables(app)
+
+app.register_blueprint(frontend_blueprint)
+app.register_blueprint(user_api_blueprint)
+app.register_blueprint(product_api_blueprint)
+app.register_blueprint(order_api_blueprint)
+
+
+@login_manager.user_loader
+def load_user(user_id):
+    return models.User.query.filter_by(id=user_id).first()
+
+
+@login_manager.request_loader
+def load_user_from_request(request):
+
+    # try to login using Basic Auth
+    api_key = request.headers.get('Authorization')
+    if api_key:
+        api_key = api_key.replace('Basic ', '', 1)
+        user = models.User.query.filter_by(api_key=api_key).first()
+        if user:
+            return user
+
+    return None
+
+
+class CustomSessionInterface(SecureCookieSessionInterface):
+    """Prevent creating session from API requests."""
+    def save_session(self, *args, **kwargs):
+        if g.get('login_via_header'):
+            return
+        return super(CustomSessionInterface, self).save_session(*args, **kwargs)
+
+
+app.session_interface = CustomSessionInterface()
+
+
+@user_loaded_from_header.connect
+def user_loaded_from_header(self, user=None):
+    g.login_via_header = True
+
+
+if __name__ == '__main__':
+    app.run(debug=True, host='0.0.0.0')

app/app.py

@@ -0,0 +1,4 @@
+
+from flask_sqlalchemy import SQLAlchemy
+
+

app/database/db.py

@@ -0,0 +1,72 @@
+[{
+    "name" : "Bananas",
+    "slug" : "bananas",
+    "price": "£200",
+    "in_stock" : 1,
+    "image": "489px-Banana.png"
+  },
+  {
+    "name" : "Apple",
+    "slug" : "apple",
+    "link": "",
+    "price": "£200",
+    "in_stock" : 1,
+    "image": "apple.png"
+  },
+  {
+    "name" : "Rubber Duck",
+    "slug" : "rubber-ducks",
+    "link": "",
+    "price": "£200",
+    "in_stock" : 1,
+    "image": "rubber_duck.png"
+  },
+  {
+    "name" : "Fidget Spinner Red",
+    "slug" : "fidget-spinner-red",
+    "link": "",
+    "price": "£200",
+    "in_stock" : 1,
+    "image": "fidget-spinner-2399715_960_720.png"
+  },
+  {
+    "name" : "Fidget Spinner Blue",
+    "slug" : "fidget-spinner-blue",
+    "link": "",
+    "price": "£200",
+    "in_stock" : 1,
+    "image": "Fidget_spinner_in_blue.png"
+  },
+  {
+    "name" : "Fidget Spinner Yellow",
+    "slug" : "fidget-spinner-yellow",
+    "link": "",
+    "price": "£200",
+    "in_stock" : 1,
+    "image": "fidget-spinner-yellow.png"
+  },
+    {
+    "name" : "Red Book",
+    "slug" : "book-red",
+    "link": "",
+    "price": "£200",
+    "in_stock" : 1,
+    "image": "book-red.png"
+  },
+    {
+    "name" : "Tomato",
+    "slug" : "tomato",
+    "link": "",
+    "price": "£200",
+    "in_stock" : 1,
+    "image": "tomato.png"
+  },
+  {
+    "name" : "Coffee",
+    "slug" : "coffee",
+    "link": "",
+    "price": "£200",
+    "in_stock" : 1,
+    "image": "coffee.png"
+  }
+]

app/database/products.json

@@ -0,0 +1,17 @@
+{
+  "peter_fisher": {
+    "first_name" : "peter",
+    "last_name" : "Fisher",
+    "is_admin": 1
+  },
+  "john_davies": {
+    "first_name" : "John",
+    "last_name" : "Daives",
+    "is_admin" : 0
+  },
+  "clare_white": {
+    "first_name" : "Clare",
+    "last_name" : "White",
+    "is_admin" : 0
+  }
+}

app/database/users.json

@@ -0,0 +1,6 @@
+from flask import Blueprint
+
+frontend_blueprint = Blueprint('frontend', __name__, template_folder='templates')
+
+
+from . import routes

app/frontend/__init__.py

@@ -0,0 +1,21 @@
+from flask import abort
+import requests
+
+
+def get_request(url):
+    try:
+        r = requests.get(url)
+        r.raise_for_status()
+        return r.json()
+    except requests.exceptions.HTTPError as err_http:
+        print ("HTTP error: ", err_http)
+        abort(404)
+    except requests.exceptions.ConnectionError as err_connection:
+        print ("Cannot connect: ", err_connection)
+        abort(404)
+    except requests.exceptions.Timeout as err_timeout:
+        print ("Timeout: ", err_timeout)
+        abort(404)
+    except requests.exceptions.RequestException as err_request:
+        print ("Error with request: ", err_request)
+        abort(404)

app/frontend/api.py

@@ -0,0 +1,30 @@
+from flask_wtf import FlaskForm
+from wtforms import StringField, PasswordField, SubmitField, HiddenField, IntegerField, SelectField
+from wtforms.validators import DataRequired, Email
+
+
+class LoginForm(FlaskForm):
+    username = StringField('Username', validators=[DataRequired()])
+    password = PasswordField('Password', validators=[DataRequired()])
+    submit = SubmitField('Login')
+
+
+class RegisterForm(FlaskForm):
+    username = StringField('Username', validators=[DataRequired()])
+    first_name = StringField('First name', validators=[DataRequired()])
+    last_name = StringField('last name', validators=[DataRequired()])
+    email = StringField('Email address', validators=[DataRequired(), Email()])
+    password = PasswordField('Password', validators=[DataRequired()])
+    submit = SubmitField('Register')
+
+
+class OrderItemForm(FlaskForm):
+    product_id = HiddenField(validators=[DataRequired()])
+    quantity = IntegerField(validators=[DataRequired()])
+    order_id = HiddenField()
+    submit = SubmitField('Update')
+
+
+class ItemForm(FlaskForm):
+    product_id = HiddenField(validators=[DataRequired()])
+    quantity = HiddenField(validators=[DataRequired()], default=1)