Changeset View
Changeset View
Standalone View
Standalone View
swh/objstorage/api/server.py
| Show First 20 Lines • Show All 60 Lines • ▼ Show 20 Lines | |||||
| @asyncio.coroutine | @asyncio.coroutine | ||||
| def check(request): | def check(request): | ||||
| req = yield from decode_request(request) | req = yield from decode_request(request) | ||||
| return encode_data(request.app['objstorage'].check(**req)) | return encode_data(request.app['objstorage'].check(**req)) | ||||
| @asyncio.coroutine | |||||
| def delete(request): | |||||
| req = yield from decode_request(request) | |||||
| return encode_data(request.app['objstorage'].delete(**req)) | |||||
| # Management methods | # Management methods | ||||
| @asyncio.coroutine | @asyncio.coroutine | ||||
| def get_random_contents(request): | def get_random_contents(request): | ||||
| req = yield from decode_request(request) | req = yield from decode_request(request) | ||||
| return encode_data(request.app['objstorage'].get_random(**req)) | return encode_data(request.app['objstorage'].get_random(**req)) | ||||
| Show All 38 Lines | def make_app(config, **kwargs): | ||||
| app.router.add_route('GET', '/', index) | app.router.add_route('GET', '/', index) | ||||
| app.router.add_route('POST', '/check_config', check_config) | app.router.add_route('POST', '/check_config', check_config) | ||||
| app.router.add_route('POST', '/content/contains', contains) | app.router.add_route('POST', '/content/contains', contains) | ||||
| app.router.add_route('POST', '/content/add', add_bytes) | app.router.add_route('POST', '/content/add', add_bytes) | ||||
| app.router.add_route('POST', '/content/get', get_bytes) | app.router.add_route('POST', '/content/get', get_bytes) | ||||
| app.router.add_route('POST', '/content/get/batch', get_batch) | app.router.add_route('POST', '/content/get/batch', get_batch) | ||||
| app.router.add_route('POST', '/content/get/random', get_random_contents) | app.router.add_route('POST', '/content/get/random', get_random_contents) | ||||
| app.router.add_route('POST', '/content/check', check) | app.router.add_route('POST', '/content/check', check) | ||||
| app.router.add_route('POST', '/content/delete', delete) | |||||
| app.router.add_route('POST', '/content/add_stream/{hex_id}', add_stream) | app.router.add_route('POST', '/content/add_stream/{hex_id}', add_stream) | ||||
| app.router.add_route('GET', '/content/get_stream/{hex_id}', get_stream) | app.router.add_route('GET', '/content/get_stream/{hex_id}', get_stream) | ||||
| app.update(config) | app.update(config) | ||||
| app['objstorage'] = get_objstorage(app['cls'], app['args']) | app['objstorage'] = get_objstorage(app['cls'], app['args']) | ||||
| return app | return app | ||||
| def make_app_from_configfile(config_path=DEFAULT_CONFIG_PATH, **kwargs): | def make_app_from_configfile(config_path=DEFAULT_CONFIG_PATH, **kwargs): | ||||
| Show All 17 Lines | |||||