summaryrefslogtreecommitdiffstats
path: root/result_collection_api/opnfv_testapi/resources
diff options
context:
space:
mode:
authorMorgan Richomme <morgan.richomme@orange.com>2016-06-04 16:59:51 +0000
committerGerrit Code Review <gerrit@172.30.200.206>2016-06-04 16:59:52 +0000
commitc50f95a4e05af030f183af132ad4a5f46121e03f (patch)
treea9bcdfe70f2820ec232a2898012c6db38a409161 /result_collection_api/opnfv_testapi/resources
parentb561bb94f8f5b5e394c693f8b2a0c42995d66d43 (diff)
parentaad984f2b471149f0c8ceaf2487583cb0e64edf1 (diff)
Merge "test APi evolution add filter to retrieve last results"
Diffstat (limited to 'result_collection_api/opnfv_testapi/resources')
-rw-r--r--result_collection_api/opnfv_testapi/resources/handlers.py6
-rw-r--r--result_collection_api/opnfv_testapi/resources/result_handlers.py15
2 files changed, 18 insertions, 3 deletions
diff --git a/result_collection_api/opnfv_testapi/resources/handlers.py b/result_collection_api/opnfv_testapi/resources/handlers.py
index 3d39502..df920c4 100644
--- a/result_collection_api/opnfv_testapi/resources/handlers.py
+++ b/result_collection_api/opnfv_testapi/resources/handlers.py
@@ -106,11 +106,15 @@ class GenericApiHandler(RequestHandler):
@asynchronous
@gen.coroutine
- def _list(self, query=None, res_op=None, *args):
+ def _list(self, query=None, res_op=None, *args, **kwargs):
if query is None:
query = {}
data = []
cursor = self._eval_db(self.table, 'find', query)
+ if 'sort' in kwargs:
+ cursor = cursor.sort(kwargs.get('sort'))
+ if 'last' in kwargs:
+ cursor = cursor.limit(kwargs.get('last'))
while (yield cursor.fetch_next):
data.append(self.format_data(cursor.next_object()))
if res_op is None:
diff --git a/result_collection_api/opnfv_testapi/resources/result_handlers.py b/result_collection_api/opnfv_testapi/resources/result_handlers.py
index 473a38d..0a4c0db 100644
--- a/result_collection_api/opnfv_testapi/resources/result_handlers.py
+++ b/result_collection_api/opnfv_testapi/resources/result_handlers.py
@@ -42,7 +42,7 @@ class GenericResultHandler(GenericApiHandler):
query['start_date'] = obj
elif k == 'trust_indicator':
query[k] = float(v)
- else:
+ elif k != 'last':
query[k] = v
return query
@@ -108,12 +108,23 @@ class ResultsCLHandler(GenericResultHandler):
@type period: L{string}
@in period: query
@required period: False
+ @param last: last days
+ @type last: L{string}
+ @in last: query
+ @required last: False
@param trust_indicator: must be int/long/float
@type trust_indicator: L{string}
@in trust_indicator: query
@required trust_indicator: False
"""
- self._list(self.set_query())
+ last = self.get_query_argument('last', 0)
+ if last is not None:
+ try:
+ last = int(last)
+ except:
+ raise HTTPError(HTTP_BAD_REQUEST, 'last must be int')
+
+ self._list(self.set_query(), sort=[{'start_date', -1}], last=last)
@swagger.operation(nickname="create")
def post(self):