diff options
author | Milo Casagrande <milo.casagrande@linaro.org> | 2014-04-07 15:03:20 +0200 |
---|---|---|
committer | Milo Casagrande <milo.casagrande@linaro.org> | 2014-04-07 15:15:30 +0200 |
commit | dfff2921d1329294da3c8ef7fc1687842d3777c2 (patch) | |
tree | b1c673d7251e6e338c33970de36330d431ead87a /app/handlers/base.py | |
parent | aa54ebf67098007be12384b2e568756f18a7785d (diff) |
Use the find_and_count function to retrieve documents.
Diffstat (limited to 'app/handlers/base.py')
-rw-r--r-- | app/handlers/base.py | 17 |
1 files changed, 8 insertions, 9 deletions
diff --git a/app/handlers/base.py b/app/handlers/base.py index 7ab3f1c..dcd810b 100644 --- a/app/handlers/base.py +++ b/app/handlers/base.py @@ -29,7 +29,7 @@ from tornado.web import ( from models import DB_NAME from utils.db import ( - find, + find_and_count, find_one, ) from utils.log import get_log @@ -142,18 +142,17 @@ class BaseHandler(RequestHandler): self.write(dict(status=status, message=message)) self.finish() - def _get_callback(self, limit, result): + def _get_callback(self, result): """Callback used for GET operations. :param limit: The number of elements returned. - :param result: The result from the future instance. + :param result: The result from the future instance. A dictionary with + at least the `result` key. """ - response = dict( - status=200, limit=limit, message=dumps(result) - ) + result['result'] = dumps(result['result']) self.set_status(200) - self.write(response) + self.write(result) self.finish() def _is_valid_request(self): @@ -246,11 +245,11 @@ class BaseHandler(RequestHandler): limit = MAX_LIMIT self.executor.submit( - partial(find, self.collection, limit, skip) + partial(find_and_count, self.collection, limit, skip) ).add_done_callback( lambda future: tornado.ioloop.IOLoop.instance().add_callback( - partial(self._get_callback, limit, future.result())) + partial(self._get_callback, future.result())) ) def write_error(self, status_code, **kwargs): |