[Feature] Add doctors api

Author: RyanSept

healthtools_ke_api/__init__.py

@@ -1,8 +1,9 @@
 from flask import Flask, jsonify
 from werkzeug.exceptions import HTTPException, default_exceptions
 
-from healthtools_ke_api.nurses import nurses_api
-from healthtools_ke_api.sms_handler import sms_handler
+from healthtools_ke_api.views.doctors import doctors_api
+from healthtools_ke_api.views.nurses import nurses_api
+from healthtools_ke_api.views.sms_handler import sms_handler
 
 import os
 import sys
@@ -15,6 +16,7 @@
     print "No config has been specified for use in the environment variables."
     sys.exit()
 
+app.register_blueprint(doctors_api, url_prefix='/doctors')
 app.register_blueprint(nurses_api, url_prefix='/nurses')
 app.register_blueprint(sms_handler)
 

healthtools_ke_api/config.py

@@ -3,6 +3,13 @@
 # Url of memcached server
 MEMCACHED_URL = os.getenv("MEMCACHED_URL")
 
+# Amazon Web Services configs
+AWS_CONFIGS = {
+    "aws_access_key_id": os.getenv("AWS_ACCESS_KEY_ID"),
+    "aws_secret_access_key": os.getenv("AWS_SECRET_KEY"),
+    "region_name": os.getenv("AWS_REGION"),
+}
+
 
 class Config(object):
     # Google Analytics tracking id

healthtools_ke_api/settings.py

@@ -0,0 +1,20 @@
+from unittest import TestCase
+from healthtools_ke_api import app
+from healthtools_ke_api.views.doctors import get_doctors_from_cloudsearch
+
+
+class TestNursesAPI(TestCase):
+    def setUp(self):
+        self.client = app.test_client()
+
+    def test_gets_doctors_from_cloudsearch(self):
+        doctors = get_doctors_from_cloudsearch("Marie")
+        self.assertTrue(len(doctors) > 0)
+
+    def test_doctors_endpoint_with_bad_query(self):
+        response = self.client.get("/doctors/search.json?q=")
+        self.assertIn("A query is required.", response.data)
+
+    def test_doctors_endpoint_gets_doctors(self):
+        response = self.client.get("/doctors/search.json?q=Marie")
+        self.assertIn("success", response.data)

healthtools_ke_api/tests/test_doctors_api.py

@@ -1,6 +1,6 @@
 from unittest import TestCase
 from healthtools_ke_api import app
-from healthtools_ke_api.nurses import get_nurses_from_nc_registry
+from healthtools_ke_api.views.nurses import get_nurses_from_nc_registry
 
 
 class TestNursesAPI(TestCase):

healthtools_ke_api/tests/test_nurses_api.py

@@ -0,0 +1,72 @@
+import boto3
+from flask import Blueprint, request, jsonify, current_app
+
+from healthtools_ke_api.analytics import track_event
+from healthtools_ke_api.settings import AWS_CONFIGS
+
+
+doctors_api = Blueprint('doctors_api', __name__)
+DOCTORS_CLOUDSEARCH_ENDPOINT = "http://doc-cfa-healthtools-ke-doctors-m34xee6byjmzcgzmovevkjpffy.eu-west-1.cloudsearch.amazonaws.com/"
+cloudsearch_client = boto3.client("cloudsearchdomain",
+                                  endpoint_url=DOCTORS_CLOUDSEARCH_ENDPOINT,
+                                  **AWS_CONFIGS)
+
+
+@doctors_api.route('/', methods=['GET'])
+def index():
+    '''
+    Landing endpoint
+    '''
+    msg = {
+        "name": "API to doctors registry on AWS Cloudsearch",
+        "authentication": [],
+        "endpoints": {
+            "/": {"methods": ["GET"]},
+            "/doctors/search.json": {
+                "methods": ["GET"],
+                "args": {
+                    "q": {"required": True}
+                }
+            },
+        }
+    }
+    return jsonify(msg)
+
+
+@doctors_api.route('/search.json', methods=['GET'])
+def search():
+    try:
+        query = request.args.get('q')
+        if not query or len(query) < 1:
+            return jsonify({
+                "error": "A query is required.",
+                "results": "",
+                "data": {"doctors": []}
+            })
+
+        # get doctors by that name from aws
+        response = {}
+        doctors = get_doctors_from_cloudsearch(query)
+
+        if not doctors:
+            response["message"] = "No doctor by that name found."
+
+        response["data"] = {"doctors": doctors}
+        response["status"] = "success"
+
+        results = jsonify(response)
+        return results
+    except Exception as err:
+        return jsonify({
+            "status": "error",
+            "message": str(err),
+            "data": {"doctors": []}
+        })
+
+
+def get_doctors_from_cloudsearch(query):
+    '''
+    Get doctors from AWS cloudsearch
+    '''
+    results = cloudsearch_client.search(query=query)
+    return results["hits"]["hit"]

healthtools_ke_api/doctors.py healthtools_ke_api/views/__init__.pyhealthtools_ke_api/doctors.py renamed to healthtools_ke_api/views/__init__.py

@@ -1,7 +1,7 @@
 from flask import Blueprint, request, current_app
 
 from healthtools_ke_api.analytics import track_event
-from healthtools_ke_api.nurses import get_nurses_from_nc_registry
+from healthtools_ke_api.views.nurses import get_nurses_from_nc_registry
 
 import requests
 import re

healthtools_ke_api/views/doctors.py

@@ -1,16 +1,23 @@
 appdirs==1.4.3
 beautifulsoup4==4.5.3
+boto3==1.4.4
+botocore==1.5.42
 bs4==0.0.1
 click==6.7
+docutils==0.13.1
 Flask==0.12.1
+futures==3.1.1
 gunicorn==19.7.1
 itsdangerous==0.24
 Jinja2==2.9.6
+jmespath==0.9.2
 MarkupSafe==1.0
 nose==1.3.7
 packaging==16.8
 pyparsing==2.2.0
+python-dateutil==2.6.0
 python-memcached==1.58
 requests==2.13.0
+s3transfer==0.1.10
 six==1.10.0
 Werkzeug==0.12.1