From 3e70cab812e29e504f714c782c71bc4b79793686 Mon Sep 17 00:00:00 2001
From: Muriithi Frederick Muriuki
Date: Fri, 12 Jan 2018 18:05:45 +0300
Subject: Add elasticsearch_tools module

* Collect variables and functions for using the elasticsearch system in
  a separate module.
---
 wqflask/utility/elasticsearch_tools.py | 22 ++++++++++++++++++++++
 1 file changed, 22 insertions(+)
 create mode 100644 wqflask/utility/elasticsearch_tools.py

(limited to 'wqflask/utility')

diff --git a/wqflask/utility/elasticsearch_tools.py b/wqflask/utility/elasticsearch_tools.py
new file mode 100644
index 00000000..bc7bb240
--- /dev/null
+++ b/wqflask/utility/elasticsearch_tools.py
@@ -0,0 +1,22 @@
+from elasticsearch import Elasticsearch, TransportError
+from utility.tools import ELASTICSEARCH_HOST, ELASTICSEARCH_PORT
+
+es = Elasticsearch([{
+    "host": ELASTICSEARCH_HOST
+    , "port": ELASTICSEARCH_PORT
+}]) 
+
+def get_user_by_unique_column(column_name, column_value):
+    user_details = None
+    try:
+        response = es.search(
+            index = "users"
+            , doc_type = "local"
+            , body = { 
+                "query": { "match": { column_name: column_value } } 
+            })
+        if len(response["hits"]["hits"]) > 0:
+            user_details = response["hits"]["hits"][0]["_source"]
+    except TransportError as te: 
+        pass
+    return user_details
-- 
cgit v1.2.3