0002-base-resource-add-automatic-up-endpoint-21978.patch

Lauréline Guérin, 11 octobre 2019 14:37

Voir les différences: en ligne côte à côte

Subject: [PATCH 2/3] base resource: add automatic 'up' endpoint (#21978)

if method 'check_status' is defined, provide a 'up' endpoint

 passerelle/base/models.py      | 14 ++++++++
 passerelle/views.py            |  3 ++
 tests/test_generic_endpoint.py | 65 ++++++++++++++++++++++++++++++++++
 3 files changed, 82 insertions(+)

     import passerelle
     import requests
     from passerelle.utils.api import endpoint
     from passerelle.utils.jsonresponse import APIError
     KEYTYPE_CHOICES = (
         ('API', _('API Key')),
-...
             for name, method in inspect.getmembers(self, predicate=inspect.ismethod):
                 if hasattr(method, 'endpoint_info'):
                     method.endpoint_info.object = self
                     endpoint_name = method.endpoint_info.name
                     if endpoint_name == 'up' and hasattr(self.check_status, 'not_implemented'):
                         # hide automatic up endpoint if check_status method is not implemented
                         continue
                     for http_method in method.endpoint_info.methods:
                         # duplicate information to give each method its own entry
                         endpoint_info = copy.copy(method.endpoint_info)
-...
             raise NotImplementedError
         check_status.not_implemented = True
         @endpoint(description=_('Check service availability'))
         def up(self, request, **kwargs):
             try:
                 self.check_status()
             except Exception as e:
                 raise APIError('service not available: %s' % e)
             return {'err': 0}
         def availability(self):
             # "availability" cron job to update service statuses

                     self.endpoint = method
             if not self.endpoint:
                 raise Http404()
             if kwargs.get('endpoint') == 'up' and hasattr(connector.check_status, 'not_implemented'):
                 # hide automatic up endpoint if check_status method is not implemented
                 raise Http404()
             return super(GenericEndpointView, self).dispatch(request, *args, **kwargs)
         def _allowed_methods(self):

     import utils
     from django.core.urlresolvers import reverse
     from passerelle.apps.arcgis.models import ArcGIS
     from passerelle.base.models import ResourceLog, ProxyLogger, BaseResource, HTTPResource
     from passerelle.apps.mdel.models import MDEL
-...
         json_res = app.get('/stub-invoices/fake/httpcall?floating=', status=400).json
         assert json_res['err'] == 1
         assert json_res['err_desc'] == 'invalid value for parameter "floating"'
     class DummyConnectorBase(BaseResource):
         class Meta:
             app_label = 'dummy'
             abstract = True
     class DummyConnectorWithCheckStatus(DummyConnectorBase):
         def check_status(self):
             return
     class DummyConnectorWithCheckStatusFailure(DummyConnectorBase):
         def check_status(self):
             raise Exception('dummy reason')
     class DummyConnectorWithoutCheckStatus(DummyConnectorBase):
         pass
     @pytest.mark.parametrize('connector_class, expected_status, expected_response', [
         (DummyConnectorWithCheckStatus, 200, {'err': 0}),
         (DummyConnectorWithCheckStatusFailure, 200,
          {'err_class': 'passerelle.utils.jsonresponse.APIError',
           'err_desc': 'service not available: dummy reason', 'data': None, 'err': 1}),
         (DummyConnectorWithoutCheckStatus, 404, None),
     ])
     def test_generic_up_endpoint(db, app, connector_class, expected_status, expected_response):
         connector = connector_class()
         connector.id = 42
         url = reverse('generic-endpoint', kwargs={
             'connector': 'foo',
             'slug': 'foo',
             'endpoint': 'up',
         })
         patch_init = mock.patch('passerelle.views.GenericConnectorMixin.init_stuff')
         patch_object = mock.patch('passerelle.views.GenericEndpointView.get_object',
                                   return_value=connector)
         with patch_init, patch_object:
             response = app.get(url, status=expected_status)
         if expected_response is not None:
             assert response.json == expected_response
     @pytest.mark.parametrize('connector_class, expected', [
         (DummyConnectorWithCheckStatus, True),
         (DummyConnectorWithCheckStatusFailure, True),
         (DummyConnectorWithoutCheckStatus, False),
     ])
     def test_generic_up_in_endpoints_infos(db, app, connector_class, expected):
         connector = connector_class()
         connector.id = 42
         up_endpoints = [
             ep for ep in connector.get_endpoints_infos()
             if ep.name == 'up']
         if expected:
             assert len(up_endpoints) == 1
         else:
             assert up_endpoints == []
+    -

Projet

Général

Profil

Produits Entr'ouvert » Passerelle

0002-base-resource-add-automatic-up-endpoint-21978.patch