mrtoth/baseimage-tutorial-framework
1
0
Fork 0
mirror of https://github.com/avatao-content/baseimage-tutorial-framework synced 2024-11-22 18:31:33 +00:00
Code Issues Releases Wiki Activity

Implement error handling on EventHandler exposing APIs

Browse Source
This commit is contained in:
Kristóf Tóth 2018-03-07 14:45:43 +01:00
parent be6f657de1
commit 2c816d5a38
3 changed files with 18 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
lib/tfw/components/process_managing_event_handler.py
View File

@ -36,6 +36,9 @@ class ProcessManagingEventHandler(TriggerlessEventHandler):
@_with_monitor_paused @_with_monitor_paused
def handle_event(self, key, data_json): def handle_event(self, key, data_json):
data = data_json['data'] try:
self.processmanager(data['command'], data['process_name']) data = data_json['data']
self.uplink.send(self.key, {'data': {'process_name': data['process_name']}}) self.processmanager(data['command'], data['process_name'])
self.uplink.send(self.key, {'data': {'process_name': data['process_name']}})
except KeyError:
log.error('IGNORING MESSAGE: Invalid data_json received: {}'.format(data_json))

11
lib/tfw/components/source_code_event_handler.py
View File

@ -84,10 +84,13 @@ class SourceCodeEventHandler(TriggerlessEventHandler):
data['files'] = self.filemanager.files data['files'] = self.filemanager.files
def handle_event(self, key, data_json): def handle_event(self, key, data_json):
data = data_json['data'] try:
data_json['data'] = self.commands[data['command']](data) data = data_json['data']
self.attach_fileinfo(data) data_json['data'] = self.commands[data['command']](data)
return data_json self.attach_fileinfo(data)
return data_json
except KeyError:
log.error('IGNORING MESSAGE: Invalid data_json received: {}'.format(data_json))
def cleanup(self): def cleanup(self):
self.monitor.stop() self.monitor.stop()

7
lib/tfw/components/terminado_event_handler.py
View File

@ -23,8 +23,11 @@ class TerminadoEventHandler(TriggerlessEventHandler):
def handle_event(self, key, data_json): def handle_event(self, key, data_json):
log.debug('TerminadoEventHandler received event: {}'.format(data_json)) log.debug('TerminadoEventHandler received event: {}'.format(data_json))
data_json['data'] = self.commands[data_json['data']['command']](data_json['data']) try:
return data_json data_json['data'] = self.commands[data_json['data']['command']](data_json['data'])
return data_json
except KeyError:
log.error('IGNORING MESSAGE: Invalid data_json received: {}'.format(data_json))
def write(self, data): def write(self, data):
self.terminado_server.pty.write(data['shellcmd']) self.terminado_server.pty.write(data['shellcmd'])