Merge fe008ef into cd89c33

series_tiempo_ar_api/apps/metadata/constants.py

@@ -5,3 +5,11 @@
 PARAM_LIMIT = 'limit'
 PARAM_OFFSET = 'offset'
 PARAM_QUERYSTRING = 'q'
+
+FILTER_ARGS = {
+    # Pares nombre_arg: field del documento en elasticsearch
+    'dataset_theme': 'dataset_theme',
+    'units': 'units',
+    'dataset_publisher_name': 'dataset_publisher_name',
+    'dataset_source': 'dataset_source_keyword'
+}

series_tiempo_ar_api/apps/metadata/indexer/doc_types.py

@@ -12,7 +12,7 @@ class Field(DocType):
     id = Keyword()
     dataset_title = Text()
     dataset_description = Text()
-    theme_description = Text()
+    dataset_theme = Keyword()
     units = Keyword()
     dataset_publisher_name = Keyword()
 

series_tiempo_ar_api/apps/metadata/indexer/metadata_indexer.py

@@ -57,7 +57,7 @@ def scrap_datajson(self):
                 dataset_source_keyword=dataset.get('source'),
                 dataset_description=dataset.get('description'),
                 dataset_publisher_name=dataset.get('publisher', {}).get('name'),
-                theme_description=themes.get(dataset.get('theme', [None])[0])
+                dataset_theme=themes.get(dataset.get('theme', [None])[0])
             )
             actions.append(doc.to_dict(include_meta=True))
         return actions
@@ -72,6 +72,6 @@ def get_dataset(self, identifier):
     def get_themes(theme_taxonomy):
         themes = {}
         for theme in theme_taxonomy:
-            themes[theme['id']] = theme['description']
+            themes[theme['id']] = theme['label']
 
         return themes

series_tiempo_ar_api/apps/metadata/queries/query.py

@@ -60,6 +60,9 @@ def execute(self):
         search = Field.search(using=es_client).query('match', _all=querystring)
         search = search[offset:limit + offset]
 
+        for arg, field in constants.FILTER_ARGS.iteritems():
+            search = self.add_filters(search, arg, field)
+
         hits = search.execute()
         self.response = {
             'data': [],
@@ -80,3 +83,11 @@ def execute(self):
 
     def append_error(self, msg):
         self.errors.append({'error': msg})
+
+    def add_filters(self, search, arg_name, field_name):
+        units = self.args.get(arg_name)
+        if units:
+            units = units.split(',')
+            search = search.filter('terms', **{field_name: units})
+
+        return search

series_tiempo_ar_api/apps/metadata/tests/tests.py

@@ -69,6 +69,23 @@ def test_response_params(self):
         self.assertEqual(result['limit'], int(limit))
         self.assertEqual(result['offset'], int(offset))
 
+    def test_add_filter(self):
+        q = FieldSearchQuery(args={'units': 'unit_test'})
+        search = q.add_filters(Search(), 'units', 'units').to_dict()
+
+        # Esperado: un filter agregado
+        filters = search['query']['bool']['filter']
+        self.assertEqual(len(filters), 1)
+        self.assertEqual(filters[0]['terms']['units'], ['unit_test'])
+
+    def test_add_filter_no_param(self):
+        q = FieldSearchQuery(args={})
+        search = Search()
+        prev_dict = search.to_dict()
+        search = q.add_filters(search, 'units', 'units').to_dict()
+        # Esperado: no se modifica la query si no hay parámetros
+        self.assertEqual(prev_dict, search)
+
 
 class IndexerTests(TestCase):
 

series_tiempo_ar_api/apps/metadata/urls.py

@@ -1,11 +1,12 @@
 #!coding=utf8
 from django.conf.urls import url
 
-from .views import search, dataset_source, field_units, dataset_publisher_name
+from .views import search, dataset_source, field_units, dataset_publisher_name, dataset_theme
 
 urlpatterns = [
     url('^$', search, name='search'),
     url('^dataset_source$', dataset_source, name='dataset_source'),
     url('^field_units$', field_units, name='field_units'),
     url('^dataset_publisher_name', dataset_publisher_name, name='dataset_publisher_name'),
+    url('^dataset_theme$', dataset_theme, name='dataset_theme'),
 ]

series_tiempo_ar_api/apps/metadata/views.py

@@ -29,3 +29,9 @@ def dataset_publisher_name(request):
     response = query_field_terms(field='dataset_publisher_name')
 
     return JsonResponse(response)
+
+
+def dataset_theme(request):
+    response = query_field_terms(field='dataset_theme')
+
+    return JsonResponse(response)