src/pyams_content/shared/view/__init__.py
changeset 1217 ac40004d7c73
parent 1168 3b177d6db9db
child 1223 99a4c33e2962
--- a/src/pyams_content/shared/view/__init__.py	Mon Jan 07 11:36:09 2019 +0100
+++ b/src/pyams_content/shared/view/__init__.py	Tue Jan 08 14:02:06 2019 +0100
@@ -9,6 +9,9 @@
 # WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
 # FOR A PARTICULAR PURPOSE.
 #
+from copy import deepcopy
+
+from jedi.evaluate.helpers import deep_ast_copy
 
 __docformat__ = 'restructuredtext'
 
@@ -112,7 +115,7 @@
 
     def get_results(self, context, sort_index=None, reverse=None, limit=None,
                     start=0, length=999, ignore_cache=False, get_count=False, request=None):
-        results = _MARKER
+        results, count = _MARKER, 0
         if not ignore_cache:
             # check for cache
             views_cache = get_cache(VIEWS_CACHE_REGION, VIEWS_CACHE_NAME)
@@ -129,11 +132,13 @@
         # Execute query
         if results is _MARKER:
             registry = get_current_registry()
+            # Look for Elasticsearch query adapter, if available...
             adapter = registry.queryAdapter(self, IViewQuery, name='es')
             if adapter is None:
                 adapter = registry.getAdapter(self, IViewQuery)
             if not sort_index:
                 sort_index = self.order_by
+            # Get query results
             results, count = adapter.get_results(context,
                                                  sort_index,
                                                  reverse if reverse is not None else self.reversed_order,
@@ -189,25 +194,27 @@
             for new_params in adapter.get_params(context, request):
                 if isinstance(new_params, tuple):
                     new_params, do_search = new_params
-                if new_params:
+                if new_params is None:
+                    return None
+                else:
                     params &= new_params
             if not do_search:
                 break
         # activate search
         if do_search:
-            params &= Gt(catalog['push_end_date'], now)
+            filters = Gt(catalog['push_end_date'], now)
             # check content path
             content_path = view.get_content_path(context)
             if content_path is not None:
-                params &= Eq(catalog['parents'], content_path)
+                filters &= Eq(catalog['parents'], content_path)
             # check content types
             content_types = view.get_content_types(context)
             if content_types:
-                params &= Any(catalog['content_type'], content_types)
+                filters &= Any(catalog['content_type'], content_types)
             # check data types
             data_types = view.get_data_types(context)
             if data_types:
-                params &= Any(catalog['data_type'], data_types)
+                filters &= Any(catalog['data_type'], data_types)
         return params
 
     def get_results(self, context, sort_index, reverse, limit, request=None):
@@ -215,14 +222,18 @@
         catalog = get_utility(ICatalog)
         registry = get_current_registry()
         params = self.get_params(context, request)
-        if (not sort_index) or (sort_index == RELEVANCE_ORDER):
-            sort_index = None
-        query = CatalogQuery(catalog).query(params,
-                                            sort_index=sort_index,
-                                            reverse=reverse,
-                                            limit=limit)
-        total_count = query[0]
-        items = CatalogResultSet(query)
+        if params is None:
+            items = CatalogResultSet([])
+            total_count = 0
+        else:
+            if (not sort_index) or (sort_index == RELEVANCE_ORDER):
+                sort_index = None
+            query = CatalogQuery(catalog).query(params,
+                                                sort_index=sort_index,
+                                                reverse=reverse,
+                                                limit=limit)
+            total_count = query[0]
+            items = CatalogResultSet(query)
         for name, adapter in sorted(registry.getAdapters((view,), IViewQueryFilterExtension),
                                     key=lambda x: x[1].weight):
             items = adapter.filter(context, items, request)