mirror of
https://github.com/ansible/awx.git
synced 2026-03-26 05:15:02 -02:30
Merge pull request #2936 from ryanpetrello/fix-1775
properly sanitize long event keys
This commit is contained in:
@@ -35,9 +35,9 @@ def sanitize_event_keys(kwargs, valid_keys):
|
|||||||
for key in [
|
for key in [
|
||||||
'play', 'role', 'task', 'playbook'
|
'play', 'role', 'task', 'playbook'
|
||||||
]:
|
]:
|
||||||
if isinstance(kwargs.get(key), six.string_types):
|
if isinstance(kwargs.get('event_data', {}).get(key), six.string_types):
|
||||||
if len(kwargs[key]) > 1024:
|
if len(kwargs['event_data'][key]) > 1024:
|
||||||
kwargs[key] = Truncator(kwargs[key]).chars(1024)
|
kwargs['event_data'][key] = Truncator(kwargs['event_data'][key]).chars(1024)
|
||||||
|
|
||||||
|
|
||||||
def create_host_status_counts(event_data):
|
def create_host_status_counts(event_data):
|
||||||
|
|||||||
@@ -53,9 +53,9 @@ def test_really_long_event_fields(field):
|
|||||||
with mock.patch.object(JobEvent, 'objects') as manager:
|
with mock.patch.object(JobEvent, 'objects') as manager:
|
||||||
JobEvent.create_from_data(**{
|
JobEvent.create_from_data(**{
|
||||||
'job_id': 123,
|
'job_id': 123,
|
||||||
field: 'X' * 4096
|
'event_data': {field: 'X' * 4096}
|
||||||
})
|
})
|
||||||
manager.create.assert_called_with(**{
|
manager.create.assert_called_with(**{
|
||||||
'job_id': 123,
|
'job_id': 123,
|
||||||
field: 'X' * 1021 + '...'
|
'event_data': {field: 'X' * 1021 + '...'}
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user