Commit 0e393961 authored by Branson Stephens's avatar Branson Stephens

Added functions for adding EMBB logs, plus unit tests.

parent 76010bf4
......@@ -239,11 +239,41 @@ class GraceDb(GsiRest):
def searches(self):
return self.service_info.get('searches')
def em_facilities(self):
return self.service_info.get('em-facilities')
def wavebands(self):
return self.service_info.get('wavebands')
def eel_statuses(self):
return self.service_info.get('eel-statuses')
def obs_statuses(self):
return self.service_info.get('obs-statuses')
def request(self, method, *args, **kwargs):
if method.lower() in ['post', 'put']:
kwargs['priming_url'] = self.service_url
return GsiRest.request(self, method, *args, **kwargs)
def _getCode(self, input_value, code_dict):
"""Check if input is valid.
Return coded version if it is"""
# code_dict is dict of { code : descriptive_name }
if input_value in code_dict.keys():
# Already coded
return input_value
if not input_value in code_dict.values():
# Not valid
return None
return [code
for code, name in code_dict.items()
if name == input_value][0]
# Search and filecontents are optional when creating an event.
def createEvent(self, group, pipeline, filename, search=None, filecontents=None):
errors = []
......@@ -353,6 +383,61 @@ class GraceDb(GsiRest):
return, body={'message' : message, 'tagname': tagname,
'displayName': displayName}, files=files)
def eels(self, graceid):
Return a list of EMBB log entries.
template = self.templates['embb-event-log-template']
uri = template.format(graceid=graceid)
return self.get(uri)
def writeEel(self, graceid, facility, waveband, eel_status,
obs_status, **kwargs):
Write an EMBB event log entry. The following arguments are required:
graceid, facility, waveband, eel_status, obs_status.
Additional keyword arguments may be passed in to be sent in the POST
data. Only the following kwargs are recognized:
Any other kwargs will be ignored.
# validate facility, waveband, eel_status, and obs_status
if not facility in self.em_facilities:
raise ValueError("facility must be one of %s" % self.em_facilities)
if not waveband in self.wavebands.keys():
raise ValueError("waveband must be one of %s" % self.wavebands.keys())
eel_status = self._getCode(eel_status, self.eel_statuses)
if not eel_status:
raise ValueError("EEL status must be one of %s" % self.eel_statuses.values())
obs_status = self._getCode(obs_status, self.obs_statuses)
if not obs_status:
raise ValueError("Observation status must be one of %s" % self.obs_statuses.values())
template = self.templates['embb-event-log-template']
uri = template.format(graceid=graceid)
body = {
'facility' : facility,
'waveband' : waveband,
'eel_status' : eel_status,
'obs_status' : obs_status,
return, body=body)
def labels(self, graceid, label=""):
template = self.templates['event-label-template']
uri = template.format(graceid=graceid, label=label)
......@@ -80,6 +80,23 @@ class TestGracedb(unittest.TestCase):
self.assertTrue('numRows' in logs)
def test_create_embb_log(self):
"""Create an EMBB log entry."""
comment = "Message is {0}".format(random.random())
resp = gracedb.writeEel(eventId, 'Test', 'em.gamma',
'FO', 'TE', comment=comment)
self.assertEqual(resp.status, 201)
new_embb_log_uri = resp.getheader('Location')
new_embb_log = resp.json()
self.assertEqual(new_embb_log_uri, new_embb_log['self'])
check_new_embb_log = gracedb.get(new_embb_log_uri).json()
self.assertEqual(check_new_embb_log['comment'], comment)
def test_get_embb_log(self):
"""Retrieve EMBB event log"""
eels = gracedb.eels(eventId).json()
self.assertTrue('numRows' in eels)
def test_upload_large_file(self):
"""Upload a large file. Issue"""
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment