X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fpybind%2Fmgr%2Frestful%2Fapi%2Frequest.py;fp=src%2Fceph%2Fsrc%2Fpybind%2Fmgr%2Frestful%2Fapi%2Frequest.py;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=b22b80bff8a45104cd2a32feb25f6f9f2d58246c;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/pybind/mgr/restful/api/request.py b/src/ceph/src/pybind/mgr/restful/api/request.py deleted file mode 100644 index b22b80b..0000000 --- a/src/ceph/src/pybind/mgr/restful/api/request.py +++ /dev/null @@ -1,92 +0,0 @@ -from pecan import expose, request, response -from pecan.rest import RestController - -from restful import module -from restful.decorators import auth, lock, paginate - - -class RequestId(RestController): - def __init__(self, request_id): - self.request_id = request_id - - - @expose(template='json') - @auth - def get(self, **kwargs): - """ - Show the information for the request id - """ - request = filter( - lambda x: x.id == self.request_id, - module.instance.requests - ) - - if len(request) != 1: - response.status = 500 - return {'message': 'Unknown request id "%s"' % str(self.request_id)} - - request = request[0] - return request - - - @expose(template='json') - @auth - @lock - def delete(self, **kwargs): - """ - Remove the request id from the database - """ - for index in range(len(module.instance.requests)): - if module.instance.requests[index].id == self.request_id: - return module.instance.requests.pop(index) - - # Failed to find the job to cancel - response.status = 500 - return {'message': 'No such request id'} - - - -class Request(RestController): - @expose(template='json') - @paginate - @auth - def get(self, **kwargs): - """ - List all the available requests - """ - return module.instance.requests - - - @expose(template='json') - @auth - @lock - def delete(self, **kwargs): - """ - Remove all the finished requests - """ - num_requests = len(module.instance.requests) - - module.instance.requests = filter( - lambda x: not x.is_finished(), - module.instance.requests - ) - - # Return the job statistics - return { - 'cleaned': num_requests - len(module.instance.requests), - 'remaining': len(module.instance.requests), - } - - - @expose(template='json') - @auth - def post(self, **kwargs): - """ - Pass through method to create any request - """ - return module.instance.submit_request([[request.json]], **kwargs) - - - @expose() - def _lookup(self, request_id, *remainder): - return RequestId(request_id), remainder