beta

Author: pceuropa

README.md

@@ -0,0 +1,13 @@
+## Installation
+```
+pip3 install -r requiremetns.txt
+```
+
+## Configuration
+Change account name and key. You will find thus on portal.azure.com
+
+##  Usage Storage Client
+```
+python3 main.py
+```
+![preview](swagger.png)

db.py

@@ -0,0 +1,90 @@
+from hashlib import sha224
+from json import dumps
+from azure.cosmosdb.table import EntityProperty as ep
+from azure.cosmosdb.table.tableservice import TableService
+from azure.cosmosdb.table.models import EdmType
+import message_pb2
+
+
+"""
+Author: Rafal Marguzewicz
+Email: info@pceuropa.net
+Github: https://github.com/pceuropa/
+Description: App need Azure account name and key to run correctly on http://127.0.0.1:5000/
+"""
+
+
+ACCOUNT_NAME = 'account_name'
+ACCOUNT_KEY = 'acount_key'
+USER_TABLE_NAME = 'users'
+MESSAGE_TABLE_NAME = 'message'
+email = 'test@email.net'
+row_key = '001'
+
+
+class Db(object):
+
+    ts = None
+
+    def __init__(self):
+        """Init connection with cosmosdb"""
+        self.ts = TableService(account_name=ACCOUNT_NAME, account_key=ACCOUNT_KEY)
+
+    def migrate(self):
+        """ Create tabel if not exists"""
+        if not self.ts.exists(USER_TABLE_NAME):
+            self.ts.create_table(USER_TABLE_NAME)
+
+        if not self.ts.exists(MESSAGE_TABLE_NAME):
+            self.ts.create_table(MESSAGE_TABLE_NAME)
+
+    def get_all_users(self):
+        """select email from user"""
+        return [i['PartitionKey'] for i in self.ts.query_entities(USER_TABLE_NAME)]
+
+    def create_user(self, data=None):
+        bjson = ep(EdmType.BINARY, dumps({
+            'email': data['email'],
+            'password': sha224(bytes(data['password'], encoding='utf-8')).hexdigest(),
+            'full_name': data['full_name']
+        }))
+
+        user = {
+            'PartitionKey': data['email'],
+            'RowKey': row_key,
+            'info': bjson
+        }
+
+        if (self.ts.insert_or_replace_entity(USER_TABLE_NAME, user)):
+            return {'success': True}
+
+    def delete_user(self, email=None):
+        if (self.ts.delete_entity(USER_TABLE_NAME, email, row_key)):
+            return {'success': True}
+
+    def create_message(self, email=None, message=None):
+        """ Create message in protobuf"""
+        proto_message = message_pb2.Message()
+        proto_message.title = message['title']
+        proto_message.content = message['content']
+        proto_message.magic_number = message['magic_number']
+        details = ep(EdmType.BINARY, str(proto_message))
+
+        bmessage = {
+            'PartitionKey': email,
+            'RowKey': row_key,
+            'details': details,
+        }
+
+        if (self.ts.insert_or_replace_entity(MESSAGE_TABLE_NAME, bmessage)):
+            return {'success': True}
+
+    def get_user(self, email=''):
+        return self.ts.get_entity(USER_TABLE_NAME, email, row_key)
+
+    def get_message(self, email=''):
+        return self.ts.get_entity(MESSAGE_TABLE_NAME, email, row_key)
+
+    def get_messages(self):
+        messages = self.ts.query_entities(MESSAGE_TABLE_NAME)
+        return list(messages)

main.py

@@ -0,0 +1,70 @@
+from flask import Flask
+from flask_restplus import Api, Resource, fields
+from db import Db
+
+# Extensions initialization
+# =========================
+app = Flask(__name__)
+api = Api(app)
+ns = api.namespace('users', description='TODO operations')
+
+user = api.model('User', {
+    'id': fields.Integer(readOnly=True, description='The task unique identifier'),
+    'email': fields.String(required=True, description='first and last name'),
+    'full_name': fields.String(required=True, description='first and last name'),
+    'password': fields.String(required=True, description='password')
+
+})
+
+message = api.model('Message', {
+    'title': fields.String(required=True, description='title'),
+    'content': fields.String(required=True, description='ble'),
+    'magic_number': fields.Integer(required=True),
+})
+
+db = Db()
+db.migrate()
+
+
+@ns.route('/')
+class CreateUser(Resource):
+
+    @ns.doc('get_all_users')
+    def get(self):
+        return list(db.get_all_users()), 201
+
+    @ns.expect(user)
+    @ns.doc('create_user')
+    def post(self):
+        return db.create_user(api.payload), 201
+
+
+@ns.route('/<email>')
+@ns.doc('delete_user')
+class DeleteUser(Resource):
+
+    def delete(self, email):
+        return db.create_user(email), 201
+
+
+@ns.route('/<email>/message')
+@ns.doc('create_message')
+class Message(Resource):
+
+    def get(self, email):
+        return email, 201
+
+    @ns.expect(message)
+    def post(self, email):
+        return db.create_message(email, api.payload)
+
+
+@ns.route('/message')
+class GetMessage(Resource):
+
+    def get(self):
+        return db.get_messages(), 201
+
+
+if __name__ == '__main__':
+    app.run()

message.proto

@@ -0,0 +1,7 @@
+syntax = "proto3";
+
+message Message{
+  string title = 1;
+  string content = 2;
+  int32 magic_number = 3;
+}