intial commit

Author: dstar55

.gitignore

@@ -0,0 +1,50 @@
+ Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+
+# C extensions
+*.so
+
+# Distribution / packaging
+bin/
+build/
+develop-eggs/
+dist/
+eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+.tox/
+.coverage
+.cache
+nosetests.xml
+coverage.xml
+
+# Translations
+*.mo
+
+# Mr Developer
+.mr.developer.cfg
+.project
+.pydevproject
+
+# Rope
+.ropeproject
+
+# Django stuff:
+*.log
+*.pot
+
+# Sphinx documentation
+docs/_build/

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2020 Fractus IT d.o.o., [fractus.io](http://fractus.io)
+
+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.

api/__init__.py

@@ -0,0 +1,2 @@
+__author__ = 'fractus.io'
+import api.items

api/items.py

@@ -0,0 +1,108 @@
+from connexion import NoContent
+from flask import jsonify, abort, make_response
+from models import Item, ItemSchema
+from config import db
+import logging
+
+def get_all():
+
+    items = Item.query.order_by(Item.id).all()
+
+    return ItemSchema(many=True).dump(items)
+
+def get_by_id(item_id):
+
+    item = Item.query.filter(Item.id == item_id).one_or_none()
+
+    if item is not None:
+
+        item_schema = ItemSchema()
+        data = item_schema.dump(item)
+        return data
+
+    else:
+        abort(
+            404,
+            "Item not found for Id: {item_id}".format(item_id=item_id),
+        )
+    
+def insert(item):
+
+    print("insert")
+    id = item['id']
+    name = item['name']
+
+    existing_item = (
+        Item.query.filter(Item.id == id)
+        .filter(Item.name == name)
+        .one_or_none()
+    )
+
+    if existing_item is None:
+
+        schema = ItemSchema()
+        new_item= schema.load(item, session=db.session)
+
+        db.session.add(new_item)
+        db.session.commit()
+
+        data = schema.dump(new_item)
+
+        return data, 201
+
+    else:
+        abort(
+            409,
+            "Item id:{id}, name:{name} exists already".format(
+                id=id, name=name
+            ),
+        )
+
+def delete(item_id):
+    
+    item = Item.query.filter(Item.id == item_id).one_or_none()
+
+    if item is not None:
+        
+        db.session.delete(item)
+        db.session.commit()
+        return make_response(
+            "Item {item_id} deleted".format(item_id=item_id), 200
+        )
+    else:
+        abort(
+            404,
+            "Item not found for Id: {item_id}".format(item_id=item_id),
+        )
+
+def update(item_id, item):
+
+    id = item['id']
+    name = item['name']
+
+    existing_item = (
+        Item.query.filter(Item.id == id)
+        .one_or_none()
+    )
+
+    if existing_item is None:
+        abort(
+            404,
+            "Item not found for Id: {item_id}".format(item_id=item_id),
+        )
+    else:
+
+        schema = ItemSchema()
+        updated_item = schema.load(item, session=db.session)
+
+        updated_item.id = existing_item.id
+
+        db.session.merge(updated_item)
+        db.session.commit()
+
+        data = schema.dump(updated_item)
+
+        return data, 200
+
+
+

app.py

@@ -0,0 +1,13 @@
+from connexion.resolver import RestyResolver
+
+import connexion
+import os
+
+import config
+
+app = config.connexion_app
+app.add_api('items.yaml', resolver = RestyResolver('api'))
+
+if __name__ == '__main__':
+
+    app.run(port = 9090)

build_db.py

@@ -0,0 +1,35 @@
+import os
+from config import db
+from models import Item, ItemSchema
+
+# Data to initialize database with
+items = [
+    {"id": 0, "name":"first item"}, 
+    {"id": 1, "name":"second item"}
+]
+
+# Delete database file if it exists currently
+if os.path.exists("items.db"):
+    os.remove("items.db")
+
+# Create the database
+db.create_all()
+
+# iterate over the item structure and populate the database
+for element in items:
+    print(element['name'])
+    item = Item(id = element['id'], name=element['name'])
+    db.session.add(item)
+
+db.session.commit()
+
+# let's check does items are in database
+# Create the list of items from database
+
+items = Item.query.order_by(Item.name).all()
+
+# Serialize the data for the response
+item_schema = ItemSchema(many=True)
+data = item_schema.dump(items)
+
+print(data)

config.py

@@ -0,0 +1,27 @@
+import os
+import connexion
+from flask_sqlalchemy import SQLAlchemy
+from flask_marshmallow import Marshmallow
+from connexion.resolver import RestyResolver
+
+
+base_dir = os.path.dirname(os.path.abspath(__file__))
+database_file = "sqlite:///{}".format(os.path.join(base_dir, "items.db"))
+
+connexion_app = connexion.App(__name__, specification_dir = 'swagger/')
+
+app = connexion_app.app
+
+app.config['SQLALCHEMY_ECHO'] = True
+app.config['SQLALCHEMY_DATABASE_URI'] = database_file
+app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
+
+
+db = SQLAlchemy(app)
+
+ma = Marshmallow(app)
+
+
+
+
+

items.db

@@ -0,0 +1,18 @@
+from config import db, ma
+
+class Item(db.Model):
+
+    __tablename__ = "item"
+    id= db.Column(db.Integer, primary_key = True)
+    name = db.Column(db.String(32))
+
+    
+    def __init__(self, id, name):
+        self.id = id
+        self.name = name
+    
+class ItemSchema(ma.ModelSchema):
+    class Meta:
+        model = Item
+        sqla_session = db.session
+

models.py

@@ -0,0 +1,11 @@
+Flask
+connexion
+swagger-ui-bundle
+#pip install "connexion[swagger-ui]"
+sqlalchemy
+Flask-SQLAlchemy
+flask-marshmallow 
+marshmallow-sqlalchemy 
+marshmallow
+#Flask-Injector
+fastavro

requirements.txt

@@ -0,0 +1,97 @@
+swagger: "2.0"
+
+info:
+  title: "Items API"
+  version: "1.0"
+
+basePath: /v1.0
+
+paths:
+  /items/:
+    get:
+      tags: [Items]
+      summary: 'Get all items'
+      operationId: api.items.get_all
+      responses:
+        '200':
+          description: 'Get all items'
+          schema:
+            type: array
+            items:
+              $ref: '#/definitions/Item'
+
+    post:
+      tags: [Items]
+      operationId: api.items.insert
+      summary: Create na item
+      parameters:
+        - name: item
+          in: body
+          schema:
+            $ref: '#/definitions/Item'
+      responses:
+        200:
+          description: New item created
+          
+  /items/{item_id}:
+    get:
+      tags: [Items]
+      summary: 'Get item by ID'
+      operationId: api.items.get_by_id
+      parameters:
+        - $ref: '#/parameters/item_id'
+      responses:
+        200:
+          description: Return item
+          schema:
+            $ref: '#/definitions/Item'
+        404:
+          description: Item does not exist
+
+    put:
+      tags: [Items]
+      summary: 'Update and item'
+      operationId: api.items.update
+      parameters:
+        - $ref: '#/parameters/item_id'
+        - name: item
+          in: body
+          schema:
+            $ref: '#/definitions/Item'
+      responses:
+        200:
+          description: Item updated
+          schema:
+            $ref: '#/definitions/Item'
+        404:
+          description: Item does not exist
+      
+    delete:
+      tags: [Items]
+      operationId: api.items.delete
+      summary: Remove an item
+      parameters:
+        - $ref: '#/parameters/item_id'
+      responses:
+        204:
+          description: Item deleted
+        404:
+          description: Item does not exist
+
+parameters:
+  item_id:
+    name: item_id
+    description: Item's Unique identifier
+    in: path
+    type: string
+    required: true
+    pattern: "^[a-zA-Z0-9-]+$"
+
+definitions:
+  Item:
+    type: object
+    properties:
+      id:
+        type: integer
+        format: int64
+      name: { type: string }