vbatts/quay
Archived
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Make sure a JSON error in build or trigger config never causes a crash

Browse source
This commit is contained in:
Joseph Schorr 2014-03-11 14:52:20 -04:00
parent c5fa12329c
commit e650da5278
1 changed files with 22 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
endpoints/api.py
View file

@ -1129,9 +1129,16 @@ def get_repo(namespace, repository):
abort(403) # Permission denied
def get_trigger_config(trigger):
try:
return json.loads(trigger.config)
except:
return {}
def trigger_view(trigger):
if trigger and trigger.uuid:
config_dict = json.loads(trigger.config)
config_dict = get_trigger_config(trigger)
build_trigger = BuildTrigger.get_trigger_for_service(trigger.service.name)
return {
'service': trigger.service.name,
@ -1144,15 +1151,23 @@ def trigger_view(trigger):
return None
def get_job_config(build_obj):
try:
return json.loads(build_obj.job_config)
except:
return None
def build_status_view(build_obj, can_write=False):
status = build_logs.get_status(build_obj.uuid)
return {
'id': build_obj.uuid,
'phase': build_obj.phase,
'started': build_obj.started,
'display_name': build_obj.display_name,
'status': status,
'job_config': json.loads(build_obj.job_config) if can_write else None,
'job_config': get_job_config(build_obj) if can_write else None,
'is_writer': can_write,
'trigger': trigger_view(build_obj.trigger),
'resource_key': build_obj.resource_key,
@ -1419,7 +1434,7 @@ def activate_build_trigger(namespace, repository, trigger_uuid):
return
handler = BuildTrigger.get_trigger_for_service(trigger.service.name)
existing_config_dict = json.loads(trigger.config)
existing_config_dict = get_trigger_config(trigger)
if handler.is_active(existing_config_dict):
abort(400)
return
@ -1478,13 +1493,12 @@ def manually_start_build_trigger(namespace, repository, trigger_uuid):
return
handler = BuildTrigger.get_trigger_for_service(trigger.service.name)
existing_config_dict = json.loads(trigger.config)
if not handler.is_active(existing_config_dict):
config_dict = get_trigger_config(trigger)
if not handler.is_active(config_dict):
abort(400)
return
specs = handler.manual_start(trigger.auth_token,
json.loads(trigger.config))
specs = handler.manual_start(trigger.auth_token, config_dict)
dockerfile_id, tags, name, subdir = specs
repo = model.get_repository(namespace, repository)
@ -1571,7 +1585,7 @@ def delete_build_trigger(namespace, repository, trigger_uuid):
return
handler = BuildTrigger.get_trigger_for_service(trigger.service.name)
config_dict = json.loads(trigger.config)
config_dict = get_trigger_config(trigger)
if handler.is_active(config_dict):
try:
handler.deactivate(trigger.auth_token, config_dict)