0001-wscall-add-action-if-error-in-application-12916.patch

Thomas Noël, 19 septembre 2016 14:20

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

Subject: [PATCH] wscall: add action if error in application (#12916)

 tests/test_workflows.py | 140 ++++++++++++++++++++++++++++++++++++++++++++++++
 tests/utilities.py      |   8 +++
 wcs/wf/wscall.py        |  45 ++++++++++++----
 3 files changed, 183 insertions(+), 10 deletions(-)

         assert qs['evalme'] == [formdata.get_display_id()]
         assert qs['str'] == ['abcd']
     def test_webservice_call_error_handling(pub):
         pub.substitutions.feed(MockSubstitutionVariables())
         FormDef.wipe()
         formdef = FormDef()
         formdef.name = 'baz'
         formdef.fields = []
         formdef.store()
         formdata = formdef.data_class()()
         formdata.just_created()
         formdata.store()
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/json-err1'
         item.post = False
         item.action_on_app_error = ':stop'
         with pytest.raises(AbortActionException):
             item.perform(formdata)
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/json-errheader1'
         item.post = False
         item.action_on_app_error = ':stop'
         with pytest.raises(AbortActionException):
             item.perform(formdata)
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/json-err0'
         item.post = False
         item.varname = 'xxx'
         item.perform(formdata)
         assert formdata.workflow_data['xxx_status'] == 200
         assert formdata.workflow_data['xxx_app_error_code'] == 0
         assert formdata.workflow_data['xxx_response'] == {'data': 'foo', 'err': 0}
         assert formdata.workflow_data.get('xxx_time')
         formdata.workflow_data = None
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/json-err0'
         item.post = False
         item.varname = 'xxx'
         item.action_on_app_error = ':stop'
         item.perform(formdata)
         assert formdata.workflow_data['xxx_status'] == 200
         assert formdata.workflow_data['xxx_app_error_code'] == 0
         assert formdata.workflow_data['xxx_response'] == {'data': 'foo', 'err': 0}
         assert formdata.workflow_data.get('xxx_time')
         formdata.workflow_data = None
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/json-err1'
         item.post = False
         item.varname = 'xxx'
         item.perform(formdata)
         assert formdata.workflow_data['xxx_status'] == 200
         assert formdata.workflow_data['xxx_app_error_code'] == 1
         assert 'xxx_response' not in formdata.workflow_data
         assert formdata.workflow_data.get('xxx_time')
         formdata.workflow_data = None
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/json-err1'
         item.post = False
         item.varname = 'xxx'
         item.action_on_app_error = ':stop'
         with pytest.raises(AbortActionException):
             item.perform(formdata)
         assert formdata.workflow_data['xxx_status'] == 200
         assert formdata.workflow_data['xxx_app_error_code'] == 1
         assert formdata.workflow_data['xxx_error_response'] == {'data': '', 'err': 1}
         assert 'xxx_response' not in formdata.workflow_data
         assert formdata.workflow_data.get('xxx_time')
         formdata.workflow_data = None
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/json-errheader0'
         item.post = False
         item.varname = 'xxx'
         item.perform(formdata)
         assert formdata.workflow_data['xxx_status'] == 200
         assert formdata.workflow_data['xxx_app_error_code'] == 0
         assert formdata.workflow_data['xxx_app_error_header'] == '0'
         assert formdata.workflow_data['xxx_response'] == {'foo': 'bar'}
         assert formdata.workflow_data.get('xxx_time')
         formdata.workflow_data = None
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/json-errheader1'
         item.post = False
         item.varname = 'xxx'
         item.perform(formdata)
         assert formdata.workflow_data['xxx_status'] == 200
         assert formdata.workflow_data['xxx_app_error_code'] == 1
         assert formdata.workflow_data['xxx_app_error_header'] == '1'
         assert formdata.workflow_data['xxx_error_response'] == {'foo': 'bar'}
         assert 'xxx_response' not in formdata.workflow_data
         assert formdata.workflow_data.get('xxx_time')
         formdata.workflow_data = None
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/json-errheader1'
         item.post = False
         item.varname = 'xxx'
         item.action_on_app_error = ':stop'
         with pytest.raises(AbortActionException):
             item.perform(formdata)
         assert formdata.workflow_data['xxx_status'] == 200
         assert formdata.workflow_data['xxx_app_error_code'] == 1
         assert formdata.workflow_data['xxx_app_error_header'] == '1'
         assert formdata.workflow_data['xxx_error_response'] == {'foo': 'bar'}
         assert 'xxx_response' not in formdata.workflow_data
         assert formdata.workflow_data.get('xxx_time')
         formdata.workflow_data = None
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/xml-errheader'
         item.post = False
         item.varname = 'xxx'
         item.response_type = 'attachment'
         item.record_errors = True
         item.perform(formdata)
         assert formdata.workflow_data.get('xxx_status') == 200
         assert formdata.workflow_data.get('xxx_app_error_code') == 1
         assert formdata.workflow_data.get('xxx_app_error_header') == '1'
         assert 'xxx_response' not in formdata.workflow_data
         item = WebserviceCallStatusItem()
         item.url = 'http://remote.example.net/xml-errheader'
         item.post = False
         item.varname = 'xxx'
         item.response_type = 'attachment'
         item.record_errors = True
         item.action_on_app_error = ':stop'
         with pytest.raises(AbortActionException):
             item.perform(formdata)
         assert formdata.workflow_data.get('xxx_status') == 200
         assert formdata.workflow_data.get('xxx_app_error_code') == 1
         assert formdata.workflow_data.get('xxx_app_error_header') == '1'
         assert 'xxx_response' not in formdata.workflow_data
     def test_timeout(pub):
         workflow = Workflow(name='timeout')

                 'http://remote.example.net/404-json': (404, '{"err": 1}', None),
                 'http://remote.example.net/500': (500, 'internal server error', None),
                 'http://remote.example.net/json': (200, '{"foo": "bar"}', None),
                 'http://remote.example.net/json-err0': (200, '{"data": "foo", "err": 0}', None),
                 'http://remote.example.net/json-err1': (200, '{"data": "", "err": 1}', None),
                 'http://remote.example.net/json-errheader0': (200, '{"foo": "bar"}',
                                                   {'x-error-code': '0'}),
                 'http://remote.example.net/json-errheader1': (200, '{"foo": "bar"}',
                                                   {'x-error-code': '1'}),
                 'http://remote.example.net/xml': (200, '<?xml version="1.0"><foo/>',
                                                   {'content-type': 'text/xml'}),
                 'http://remote.example.net/xml-errheader': (200, '<?xml version="1.0"><foo/>',
                                                   {'content-type': 'text/xml', 'x-error-code': '1'}),
                 }.get(base_url, (200, '', {}))
             class FakeResponse(object):

         _method = None
         response_type = 'json'
         action_on_app_error = ':pass'
         action_on_4xx = ':stop'
         action_on_5xx = ':stop'
         action_on_bad_data = ':pass'
-...
         def get_parameters(self):
             return ('url', 'post', 'varname', 'request_signature_key', 'post_data',
                     'action_on_4xx', 'action_on_5xx', 'action_on_bad_data',
                     'action_on_app_error', 'action_on_4xx', 'action_on_5xx', 'action_on_bad_data',
                     'action_on_network_errors', 'notify_on_errors',
                     'record_errors', 'label', 'method', 'response_type',
                     'qs_data')
-...
             error_actions = [(':stop', _('Stop')), (':pass', _('Ignore'))]
             error_actions.extend([(x.id, _('Jump to %s') % x.name) for x in
                 self.parent.parent.possible_status])
             for attribute in ('action_on_4xx', 'action_on_5xx', 'action_on_network_errors',
                     'action_on_bad_data'):
             for attribute in ('action_on_app_error', 'action_on_4xx', 'action_on_5xx',
                               'action_on_network_errors', 'action_on_bad_data'):
                 if not attribute in parameters:
                     continue
                 if attribute == 'action_on_bad_data':
-...
                 else:
                     attrs = {}
                 label = {
                         'action_on_app_error': _('Action on application error'),
                         'action_on_4xx': _('Action on HTTP error 4xx'),
                         'action_on_5xx': _('Action on HTTP error 5xx'),
                         'action_on_bad_data': _('Action on non-JSON response'),
-...
                 self.action_on_error(self.action_on_network_errors, formdata,
                         exc_info=sys.exc_info())
             app_error_code = 0
             app_error_code_header = response.getheader('x-error-code')
             if app_error_code_header:
                 # result is good only if header value is '0'
                 try:
                     app_error_code = int(app_error_code_header)
                 except ValueError as e:
                     app_error_code = app_error_code_header
             elif self.response_type == 'json':
                 try:
                     d = json_loads(data)
                 except (ValueError, TypeError) as e:
                     pass
                 else:
                     if isinstance(d, dict) and d.get('err'):
                         app_error_code = d['err']
             if self.varname:
                 workflow_data = {
                     '%s_status' % self.varname: status,
                     '%s_time' % self.varname: datetime.datetime.now().isoformat(),
                     '%s_app_error_code' % self.varname: app_error_code,
+                }
                 if app_error_code_header:
                     workflow_data['%s_app_error_header' % self.varname] = app_error_code_header
                 if status in (204, 205):
                     pass # not returning any content
                 elif (status // 100) == 2:
                 elif (status // 100) == 2 and app_error_code == 0:
                     self.store_response(formdata, response, data, workflow_data)
                 else: # on error, record data if it is JSON
                     try:
-...
                 formdata.update_workflow_data(workflow_data)
                 formdata.store()
             if app_error_code != 0:
                 self.action_on_error(self.action_on_app_error, formdata, response, data=data)
             if (status // 100) == 4:
                 self.action_on_error(self.action_on_4xx, formdata, response, data=data)
             if (status // 100) == 5:
-...
                             response, data=data, exc_info=sys.exc_info())
                 else:
                     workflow_data['%s_response' % self.varname] = d
                     if isinstance(d.get('data'), dict) and d['data'].get('display_id'):
                         formdata.id_display = d.get('data', {}).get('display_id')
                     elif d.get('display_id'):
                         formdata.id_display = d.get('display_id')
                     if isinstance(d, dict):
                         if isinstance(d.get('data'), dict) and d['data'].get('display_id'):
                             formdata.id_display = d.get('data', {}).get('display_id')
                         elif d.get('display_id'):
                             formdata.id_display = d.get('display_id')
             else: # store result as attachment
                 content_type = response.getheader('content-type') or ''
                 if content_type:
-...
         def get_target_status(self):
             targets = []
             for attribute in ('action_on_4xx', 'action_on_5xx', 'action_on_bad_data',
                     'action_on_network_errors'):
             for attribute in ('action_on_app_error', 'action_on_4xx', 'action_on_5xx',
                               'action_on_bad_data', 'action_on_network_errors'):
                 value = getattr(self, attribute)
                 if value in (':pass', ':stop'):
                     continue
+    -

Projet

Général

Profil

Produits Entr'ouvert » w.c.s.

0001-wscall-add-action-if-error-in-application-12916.patch