Initial Commit

Author: pratapaprasanna

.gitignore

@@ -0,0 +1,9 @@
+lint-results
+*.egg-info
+test-results
+.mypy_cache
+.pytest_cache
+**/__pycache__/*
+.DS_Store
+yarn-error.log
+__pycache__

README.rst

@@ -0,0 +1 @@
+__version__ = '0.1.0'

authenticator/__init__.py

@@ -0,0 +1,23 @@
+from flask_pymongo import PyMongo
+from flask import jsonify
+
+
+class MongoAdapters(object):
+    def __init__(self, app):
+        self.client = PyMongo(app)
+        self.db = self.client.db['nomad']
+
+    def get_all_users(self):
+        collection = self.client.db['users']
+        output = []
+        for user in collection.find():
+            output.append({'name': user['name'], 'email': user['email']})
+        return jsonify({'result': output})
+
+    def add_users(self, name, email):
+        try:
+            collection = self.client.db['users']
+            collection_id = collection.insert({'name': name, 'email': email})
+            return jsonify({'result': collection_id})
+        except Exception:
+            print("ISSUE")

authenticator/adapters/db/api.py

@@ -0,0 +1,29 @@
+from flask import Flask
+from flask import jsonify
+from flask import request
+
+from authenticator.adapters.db import api as db_api
+from authenticator import config
+
+app = Flask(__name__)
+
+app.config['MONGO_DBNAME'] = config.DATABASE
+app.config['MONGO_URI'] = f'mongodb://{config.DB_HOST}:{config.DB_PORT}/{config.DATABASE}'
+
+db_obj = db_api.MongoAdapters(app)
+
+
+@app.route('/users', methods=['GET'])
+def get_users():
+    return db_obj.get_all_users()
+
+
+@app.route('/add', methods=['POST'])
+def add_users():
+    name = request.json['name']
+    email = request.json['email']
+    return db_obj.add_users(name, email)
+
+
+if __name__ == '__main__':
+    app.run(debug=True)

authenticator/app.py

@@ -0,0 +1,3 @@
+DATABASE = "nomad"
+DB_HOST = "localhost"
+DB_PORT = 27017