Page MenuHomec4science
Files F87381507

restful.py
No OneTemporary
Actions

File Metadata

Created
Sat, Oct 12, 08:34

restful.py
View Options

# -*- coding: utf-8 -*-
##
## This file is part of Invenio.
## Copyright (C) 2014 CERN.
##
## Invenio is free software; you can redistribute it and/or
## modify it under the terms of the GNU General Public License as
## published by the Free Software Foundation; either version 2 of the
## License, or (at your option) any later version.
##
## Invenio is distributed in the hope that it will be useful, but
## WITHOUT ANY WARRANTY; without even the implied warranty of
## MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
## General Public License for more details.
##
## You should have received a copy of the GNU General Public License
## along with Invenio; if not, write to the Free Software Foundation, Inc.,
## 59 Temple Place, Suite 330, Boston, MA 02111-1307, USA.
from __future__ import absolute_import
from functools import wraps
from flask.ext.restful import Resource, abort
from invenio.ext.restful import require_api_auth, require_oauth_scopes
from .models import Receiver, ReceiverDoesNotExists, InvalidPayload, \
WebhookError
def error_handler(f):
"""
Decorator to handle exceptions
"""
@wraps(f)
def inner(*args, **kwargs):
try:
return f(*args, **kwargs)
except ReceiverDoesNotExists:
abort(404, message="Receiver does not exists.", status=404)
except InvalidPayload as e:
abort(
415,
message="Receiver does not support the"
" content-type '%s'." % e.args[0],
status=415)
except WebhookError as e:
abort(
500,
message="Internal server error",
status=500
)
return inner
#
# Default decorators
#
api_decorators = [
require_api_auth(),
error_handler,
]
#
# REST Resources
#
class ReceiverEventListResource(Resource):
"""
Receiver event hook
"""
method_decorators = api_decorators
def get(self, oauth, receiver_id=None):
abort(405)
@require_oauth_scopes('webhooks:event')
def post(self, oauth, receiver_id=None):
receiver = Receiver.get(receiver_id)
receiver.consume_event(oauth.access_token.user_id)
return {'status': 202, 'message': 'Accepted'}, 202
def put(self, oauth, receiver_id=None):
abort(405)
def delete(self, oauth, receiver_id=None):
abort(405)
def head(self, oauth, receiver_id=None):
abort(405)
def options(self, oauth, receiver_id=None):
abort(405)
def patch(self, oauth, receiver_id=None):
abort(405)
#
# Register API resources
#
def setup_app(app, api):
api.add_resource(
ReceiverEventListResource,
'/api/hooks/receivers/<string:receiver_id>/events/',
)

Event Timeline

c4science · Help